tcp

Documentation

Index

• type Client
  • func NewClient(conn net.Conn, service ports.DataService, tokenService ports.TokenService) *Client
  • func (c *Client) Close()
  • func (c *Client) HandleMessage(message string)
  • func (c *Client) IsClosed() bool
  • func (c *Client) ReadLoop()
  • func (c *Client) Run()
  • func (c *Client) SendMessage(message string) error
• type Server
  • func NewServer(addr string, cfg *tls.Config) (*Server, error)
  • func (s *Server) AddClient(client *Client)
  • func (s *Server) AddHandler(dataService ports.DataService, tokenService ports.TokenService)
  • func (s *Server) Close() error
  • func (s *Server) CloseAllClients()
  • func (s *Server) RemoveClient(client *Client)
  • func (s *Server) Run(ctx context.Context)

Types

type Client

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

func NewClient

func NewClient(conn net.Conn, service ports.DataService, tokenService ports.TokenService) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) HandleMessage

func (c *Client) HandleMessage(message string)

func (*Client) IsClosed

func (c *Client) IsClosed() bool

func (*Client) ReadLoop

func (c *Client) ReadLoop()

func (*Client) Run

func (c *Client) Run()

func (*Client) SendMessage

func (c *Client) SendMessage(message string) error

type Server

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

func NewServer

func NewServer(addr string, cfg *tls.Config) (*Server, error)

func (*Server) AddClient

func (s *Server) AddClient(client *Client)

func (*Server) AddHandler

func (s *Server) AddHandler(dataService ports.DataService, tokenService ports.TokenService)

func (*Server) Close

func (s *Server) Close() error

func (*Server) CloseAllClients

func (s *Server) CloseAllClients()

func (*Server) RemoveClient

func (s *Server) RemoveClient(client *Client)

func (*Server) Run

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