Documentation ¶
Index ¶
- type Client
- func (c *Client) Close() error
- func (c *Client) ReadFull(buf []byte) (n int, err error)
- func (c *Client) RemoteAddr() net.Addr
- func (c *Client) Run(packetProcessor *RequestPacketProcessor, requestHandler *RequestPacketHandler)
- func (c *Client) Shutdown()
- func (c *Client) WriteMessage(msg message.Message, correlationId int32) error
- type RequestPacketHandler
- type RequestPacketProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { Broker *logical_broker.LogicalBroker // contains filtered or unexported fields }
func NewClient ¶
func NewClient(log logr.Logger, broker *logical_broker.LogicalBroker, conn net.Conn) *Client
func (*Client) RemoteAddr ¶
func (*Client) Run ¶
func (c *Client) Run(packetProcessor *RequestPacketProcessor, requestHandler *RequestPacketHandler)
type RequestPacketHandler ¶
func (*RequestPacketHandler) HandleRequest ¶
func (rh *RequestPacketHandler) HandleRequest(client *Client, inPacket *netCodec.Packet) error
type RequestPacketProcessor ¶
func (*RequestPacketProcessor) ProcessPacket ¶
func (pp *RequestPacketProcessor) ProcessPacket(client *Client) (*netCodec.Packet, error)
Click to show internal directories.
Click to hide internal directories.