client

Documentation

Index

• type Client
  • func NewClient(config *plugin.PluginCfg, Topic string, handleMsg func(msg plugin.IMessage)) (c *Client)
  • func (c *Client) ConnectWithTimeOut(timeout int) (err error)
  • func (client *Client) SendBuffMsg(msgID uint32, ctr byte, data []byte) error
  • func (client *Client) SendMsg(msgID uint32, ctr byte, data []byte) error
  • func (c *Client) SendTopicMsg(id uint32, msg *common.TopMessage) error
  • func (c *Client) SendTopicMsgDirect(id uint32, msg *common.TopMessage) error
  • func (c *Client) Start() error
  • func (client *Client) Stop()

Types

type Client

type Client struct {
	Exit chan struct{}

	Topic string

	Id uint32

	//有缓冲管道，用于读、写两个goroutine之间的消息通信
	In chan common.IMessage

	Packet common.Packet
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewClient

func NewClient(config *plugin.PluginCfg, Topic string, handleMsg func(msg plugin.IMessage)) (c *Client)

func (*Client) ConnectWithTimeOut

func (c *Client) ConnectWithTimeOut(timeout int) (err error)

func (*Client) SendBuffMsg

func (client *Client) SendBuffMsg(msgID uint32, ctr byte, data []byte) error

SendBuffMsg 发生BuffMsg

func (*Client) SendMsg

func (client *Client) SendMsg(msgID uint32, ctr byte, data []byte) error

SendMsg 直接将Message数据发送数据给远程的TCP客户端

func (*Client) SendTopicMsg

func (c *Client) SendTopicMsg(id uint32, msg *common.TopMessage) error

func (*Client) SendTopicMsgDirect

func (c *Client) SendTopicMsgDirect(id uint32, msg *common.TopMessage) error

func (*Client) Start

func (c *Client) Start() error

func (*Client) Stop

func (client *Client) Stop()