protocol

var RunKMessageClient = func(addr string, heartbeatTime int, heartbeatCheckInterval int, operator ZeroKMessageOperator, unk ...string) {
	_uniquekey := ""
	if len(unk) > 0 {
		_uniquekey = unk[0]
	}
	kMessageCli := &kZeroKMessageClient{
		TCPClient: *server.NewTCPClient(
			addr,
			xDEFAULT_AUTH_WAIT,
			int64(heartbeatTime),
			int64(heartbeatCheckInterval),
			xDEFAULT_BUFFER_SIZE,
		),
		uniquekey: _uniquekey,
		operator:  operator,
	}
	kMessageCli.ThisDef(kMessageCli)
	global.Key(ZEROKMSG_CLIENT, kMessageCli)
	kMessageCli.Connect()
}

var RunKMessageServer = func(addr string, heartbeatTime int, operator ZeroKMessageOperator, watchers ...server.ZeroServerWatcher) {
	zerov1serv := &kZeroKMessageKeeper{
		TCPServer: *server.NewTCPServer(
			addr,
			xDEFAULT_AUTH_WAIT,
			int64(heartbeatTime),
			xDEFAULT_BUFFER_SIZE,
			watchers...,
		),
		operator: operator,
	}
	global.Key(ZEROKMSG_SERVER, zerov1serv)
	zerov1serv.RunServer()
}