transports

type Connection interface {
	// Send sends data to the connection.
	Send(data []byte) error

	SendWithCallback(data []byte, callback gnet.AsyncCallback) error

	// Close closes the connection.
	Close() error

	// RemoteAddr returns the remote address of the connection.
	RemoteAddr() string
}

type Handler interface {
	Handle(conn Connection, frame []byte)
}

type HandlerFunc func(conn Connection, frame []byte)

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

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

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

type Transport interface {
	Addr() string
	Start(ctx context.Context) error
	Stop() error
}