client_broadcast

Documentation

Index

• type CliBroadcastPool
  • func (p *CliBroadcastPool) Get() *ClientBroadcastData
  • func (p *CliBroadcastPool) Init()
  • func (p *CliBroadcastPool) Put(cliMsgData *ClientBroadcastData)
• type ClientBroadcastData
• type ClientMsgChannel
  • func NewClientMsgChannel() *ClientMsgChannel
  • func (p *ClientMsgChannel) Start() error
  • func (p *ClientMsgChannel) Stop()

Types

type CliBroadcastPool

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

func (*CliBroadcastPool) Get

func (p *CliBroadcastPool) Get() *ClientBroadcastData

func (*CliBroadcastPool) Init

func (p *CliBroadcastPool) Init()

func (*CliBroadcastPool) Put

func (p *CliBroadcastPool) Put(cliMsgData *ClientBroadcastData)

type ClientBroadcastData

type ClientBroadcastData struct {
	Type       grpc.ProtoMessageAction
	InputBytes []byte
}

type ClientMsgChannel

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

func NewClientMsgChannel

func NewClientMsgChannel() *ClientMsgChannel

func (*ClientMsgChannel) Start

func (p *ClientMsgChannel) Start() error

func (*ClientMsgChannel) Stop

func (p *ClientMsgChannel) Stop()