connection

Documentation

Index

• type CallbackFunc
• type ConnectionInterface
• type ServerInterface
• type TcpConn
  • func NewTcpConn(conn net.Conn) *TcpConn
  • func (t *TcpConn) Close() error
  • func (t *TcpConn) Read(length int) ([]byte, error)
  • func (t *TcpConn) UpdateLogger(logger *logger.Logger)
  • func (t *TcpConn) Write(data []byte) error
• type TcpServer
  • func NewTcpServer() *TcpServer
  • func (t *TcpServer) GetChannel() chan ConnectionInterface
  • func (t *TcpServer) Start(address string, fn CallbackFunc)
• type TypeConnection

Types

type CallbackFunc

type CallbackFunc func(ConnectionInterface)

type ConnectionInterface

type ConnectionInterface interface {
	Read(int) ([]byte, error)
	Write([]byte) error
	Close() error
	UpdateLogger(*logger.Logger)
}

type ServerInterface

type ServerInterface interface {
	Start(string, CallbackFunc)
	GetChannel() chan ConnectionInterface
}

type TcpConn

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

func NewTcpConn

func NewTcpConn(conn net.Conn) *TcpConn

func (*TcpConn) Close

func (t *TcpConn) Close() error

Close fecha a conexão TCP.

func (*TcpConn) Read

func (t *TcpConn) Read(length int) ([]byte, error)

ReadExactly lê exatamente n bytes da conexão TCP.

func (*TcpConn) UpdateLogger

func (t *TcpConn) UpdateLogger(logger *logger.Logger)

func (*TcpConn) Write

func (t *TcpConn) Write(data []byte) error

Write escreve dados na conexão TCP.

type TcpServer

type TcpServer struct {
	ChNewConn chan ConnectionInterface
	// contains filtered or unexported fields
}

func NewTcpServer

func NewTcpServer() *TcpServer

NewTcpServer cria uma nova instância de TcpServer.

func (*TcpServer) GetChannel

func (t *TcpServer) GetChannel() chan ConnectionInterface

func (*TcpServer) Start

func (t *TcpServer) Start(address string, fn CallbackFunc)

type TypeConnection

type TypeConnection int

const (
	TCP TypeConnection = iota
	WEBSOCKET
)