evnio

type Action uint8

type Connection interface {
	UniqID() uint64

	RemoteAddr() net.Addr

	LocalAddr() net.Addr

	Context() context.Context

	SetContext(context.Context)

	Send([]byte, Action) error

	Close() error
}

type ConnectionHandler interface {
	OnOpen(c Connection)
	OnMessage(c Connection, data []byte)
	OnClose(c Connection)
}

type EventHandler interface {
	EventHandler(fd int, events poller.Event)
	Close() error
}

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

type ListenHandler func(ncfd int, sa syscall.Sockaddr)

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

type Options struct {
	Addr     string
	NumLoops int
	Protocol Protocol
	Handler  ConnectionHandler
}

type Protocol interface {
	UnPacket(Connection, *bytes.Buffer) []byte
	Packet(Connection, []byte) []byte
}

type Server interface {
	Start() error
	Shutdown() error
}