server

Documentation

Index

• func NewConnectionAttachment(conn *Connection) topic.Attachment
• type Connection
  • func NewConnection(conn utils.NetworkConnection, broker *topic.Broker, logger *zap.Logger) *Connection
  • func (c *Connection) Close() error
  • func (c *Connection) Recv() error
  • func (c *Connection) SendDataMessage(m topic.Message)
• type ConnectionAttachment
  • func (c *ConnectionAttachment) Send(ctx context.Context, m topic.Message)
• type Server
  • func NewServer(broker *topic.Broker, logger *zap.Logger) *Server
  • func (s *Server) Serve(lis net.Listener) error

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.

func (*ConnectionAttachment) Send

func (c *ConnectionAttachment) Send(ctx context.Context, m topic.Message)

type Server

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

func NewServer

func NewServer(broker *topic.Broker, logger *zap.Logger) *Server

func (*Server) Serve

func (s *Server) Serve(lis net.Listener) error