transport

Documentation

Index

• type Handler
• type Server
  • func NewServer(address string, router http.Handler, log lib.ILogger) *Server
  • func (s *Server) Run(ctx context.Context) error
• type StatefulTransport
• type StatefulTransportServer
• type StatelessTransport
• type StatelessTransportServer
• type TCPServer
  • func NewTCPServer(serverAddr string, log lib.ILogger) *TCPServer
  • func (p *TCPServer) Run(ctx context.Context) error
  • func (p *TCPServer) SetConnectionHandler(handler Handler)

Types

type Handler

type Handler func(ctx context.Context, transport net.Conn)

type Server

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

func NewServer

func NewServer(address string, router http.Handler, log lib.ILogger) *Server

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

type StatefulTransport

type StatefulTransport interface {
	Connect(ctx context.Context) error
	Close(ctx context.Context) error
	Read(ctx context.Context) ([]byte, error)
	Write(ctx context.Context, data []byte) error
	OnClose(func(reason error))
}

type StatefulTransportServer

type StatefulTransportServer interface {
	Run(ctx context.Context) error
	OnConnect(Handler)
}

tcp, sip and quic are stateful transports

type StatelessTransport

type StatelessTransport interface {
	Read(ctx context.Context) ([]byte, error)
	Write(ctx context.Context, data []byte) error
}

type StatelessTransportServer

type StatelessTransportServer interface {
	Run(ctx context.Context) error
	OnConnect(func(transport StatelessTransport))
}

udp is a stateless transport TODO: update this interface

type TCPServer

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

func NewTCPServer

func NewTCPServer(serverAddr string, log lib.ILogger) *TCPServer

func (*TCPServer) Run

func (p *TCPServer) Run(ctx context.Context) error

func (*TCPServer) SetConnectionHandler

func (p *TCPServer) SetConnectionHandler(handler Handler)