Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConnectionAttachment ¶
func NewConnectionAttachment(conn *Connection) topic.Attachment
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
Connection represents an application level connection to the client.
func NewConnection ¶
func NewConnection( conn utils.NetworkConnection, broker *topic.Broker, logger *zap.Logger, ) *Connection
func (*Connection) Close ¶
func (c *Connection) Close() error
func (*Connection) Recv ¶
func (c *Connection) Recv() error
Recv reads from the network connection and handles the request.
func (*Connection) SendDataMessage ¶
func (c *Connection) SendDataMessage(m topic.Message)
type ConnectionAttachment ¶
type ConnectionAttachment struct {
// contains filtered or unexported fields
}
ConnectionAttachment implements a topic attachment to send messages to the connection.
Click to show internal directories.
Click to hide internal directories.