tcp

Documentation

Index

• type Comm
  • func InitClient(host string, port int, logger *slog.Logger) (*Comm, error)
  • func (c *Comm) Run(ctx context.Context) error
  • func (c *Comm) RxCh() chan json.RawMessage
  • func (c *Comm) TxCh() chan json.RawMessage
• type Server
  • func InitServer(logger *slog.Logger, port int) *Server
  • func (o *Server) Accept(ctx context.Context) error
  • func (o *Server) CommCh() chan *Comm

Types

type Comm

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

func InitClient

func InitClient(host string, port int, logger *slog.Logger) (*Comm, error)

func (*Comm) Run

func (c *Comm) Run(ctx context.Context) error

func (*Comm) RxCh

func (c *Comm) RxCh() chan json.RawMessage

func (*Comm) TxCh

func (c *Comm) TxCh() chan json.RawMessage

type Server

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

func InitServer

func InitServer(logger *slog.Logger, port int) *Server

func (*Server) Accept

func (o *Server) Accept(ctx context.Context) error

func (*Server) CommCh

func (o *Server) CommCh() chan *Comm