acceptor

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

type Instance interface {
	Schema() Schema
	// Listen runs the thread that will receive the connection
	Listen(onAccept func(conn net.Conn)) error

	// Shutdown shuts down the acceptor
	Shutdown()
}

type Options struct {
	Core            int
	ReadBufferSize  int
	WriteBufferSize int
	Keepalive       bool
	WriteDeadline   time.Duration
	ReadDeadline    time.Duration
	LengthOffset    int
}

type Schema struct {
	Protocol string
	Addr     string
}

type TCPAcceptor struct {
	*Acceptor
	// contains filtered or unexported fields
}

type WebsocketAcceptor struct {
	*Acceptor
	// contains filtered or unexported fields
}