messager

Documentation

Index

• type FHandleRequest
• type FRespondentData
• type OperateType
• type TMessageClient
  • func NewMessageClient() (*TMessageClient, error)
  • func (mc *TMessageClient) Close()
  • func (mc *TMessageClient) Send(url string, messageHead byte, messageBody []byte) ([]byte, error)
  • func (mc *TMessageClient) SendData(url string, data []byte) ([]byte, error)
• type TMessageServer
  • func NewMessageServer(url []string, handler FHandleRequest) (*TMessageServer, error)
  • func (ms *TMessageServer) Receive()
  • func (ms *TMessageServer) Start()
  • func (ms *TMessageServer) Stop()

Types

type FHandleRequest

type FHandleRequest func(data []byte) []byte

type FRespondentData

type FRespondentData func() []byte

type OperateType

type OperateType = uint8

const (
	// Portal To Host
	OperateDeletePlugin OperateType = iota // 删除插件
	OperateGetTempConfig
	//OperateSetRunType
	//OperateLoadPlugin
	//OperateUnloadPlugin
	OperateRunPlugin
	OperateStopPlugin
	OperateGetPubError // 获取发布插件的错误信息
	OperateGetPlugins  // 获取Host中插件列表
	OperateSetLicense
	OperateGetProductKey
	OperateForwardMsg // 将消息转发到其他Host
	OperateHeartBeat
	OperatePublishMsg // 发布消息,发给Portal,由Portal转发到其他Host

	// Plugin To Host
	OperateRequestPublish // 由插件发送消息到Host，Host发布后再由Portal转发到其他Host
	OperateShowMessage
)

type TMessageClient

type TMessageClient struct {
	MessageHead byte
	MessageBody []byte
	// contains filtered or unexported fields
}

func NewMessageClient

func NewMessageClient() (*TMessageClient, error)

func (*TMessageClient) Close

func (mc *TMessageClient) Close()

func (*TMessageClient) Send

func (mc *TMessageClient) Send(url string, messageHead byte, messageBody []byte) ([]byte, error)

func (*TMessageClient) SendData

func (mc *TMessageClient) SendData(url string, data []byte) ([]byte, error)

type TMessageServer

type TMessageServer struct {
	MessageHead byte
	MessageBody []byte

	HandleRequest FHandleRequest
	// contains filtered or unexported fields
}

func NewMessageServer

func NewMessageServer(url []string, handler FHandleRequest) (*TMessageServer, error)

func (*TMessageServer) Receive

func (ms *TMessageServer) Receive()

Receive 1、被动收到消息，及时回复确认，将数据写入通道

func (*TMessageServer) Start

func (ms *TMessageServer) Start()

func (*TMessageServer) Stop

func (ms *TMessageServer) Stop()