connect

type CallBack func(input, result *protocol.PlatformMessage, err common_type.PluginError)

type Connection struct {
	Zmq *ZmqEndpoint
	ConnectionHandler
	// contains filtered or unexported fields
}

type ConnectionHandler interface {
	OnConnect() common_type.PluginError
	OnDisconnect() common_type.PluginError
	OnMsg(endpoint *EndpointInfo, content *protocol.PlatformMessage, unmarshalError common_type.PluginError)
	OnError(pluginError common_type.PluginError)
}

type EndpointInfo struct {
	ID   string
	Role Role
	Name string
}

type MessageHandler interface {
	OnConnect() common_type.PluginError
	OnDisconnect() common_type.PluginError
	OnMessage(endpoint *EndpointInfo, content []byte)
	OnError(pluginError common_type.PluginError) // EndpointReceiveErr、EndpointIdentifyErr、EndpointSendErr only
}

type MessagePacker interface {
	// Unpack 从rawData中剥离出发送端和接收端,返回processedData
	Unpack(rawData []byte) (source, target *EndpointInfo, processedData []byte, err common_type.PluginError)
	// Pack 给出发送端和接收端,为rawData加上发送端和接收端信息,生成新的发送内容
	Pack(source, target *EndpointInfo, rawData []byte) (processedData []byte, err common_type.PluginError)
}

type ProtoPacker struct{}

type Role string

type SocketType string

type ZmqEndpoint struct {
	// contains filtered or unexported fields
}