tcp

Documentation

Index

• type Client
  • func NewClient(uri string) (*Client, error)
  • func (c *Client) Close() error
• type Server
  • func NewServer(ctx context.Context, uri string, log *logger.Logger) (*Server, error)
  • func (s *Server) Send(data []byte) error

Types

type Client

type Client struct {
	Conn   net.Conn
	ReadCh chan []byte
}

func NewClient

func NewClient(uri string) (*Client, error)

NewClient creates a new TCP client

func (*Client) Close

func (c *Client) Close() error

Close - closes the connection

type Server

type Server struct {
	ReadCh chan []byte
	// contains filtered or unexported fields
}

func NewServer

func NewServer(ctx context.Context, uri string, log *logger.Logger) (*Server, error)

NewServer creates a new TCP server

func (*Server) Send

func (s *Server) Send(data []byte) error

Send - sends data to all connections