tcpserver

type Action = gnet.Action

type BuiltInFrameCodec struct {
}

type Conn = gnet.Conn

type DecoderConfig struct {
	ByteOrder           binary.ByteOrder
	LengthFieldOffset   int
	LengthFieldLength   int
	LengthAdjustment    int
	InitialBytesToStrip int
}

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

type EncoderConfig struct {
	ByteOrder                       binary.ByteOrder
	LengthFieldLength               int
	LengthAdjustment                int
	LengthIncludesLengthFieldLength bool
}

type EventService interface {
	OnInitComplete(server Server) (action Action)

	OnShutdown(server Server)

	OnOpened(c Conn) (out []byte, action Action)

	OnClosed(c Conn, err error) (action Action)

	PreWrite()

	React(frame []byte, c Conn) (out []byte, action Action)

	Tick() (delay time.Duration, action Action)
}

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

type GoroutinePool = goroutine.Pool

type ICodec interface {
	Encode(c Conn, buf []byte) ([]byte, error)
	Decode(c Conn) ([]byte, error)
}

type LB = gnet.LoadBalancing

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

type LineBasedFrameCodec struct {
}

type Option func(*TcpServer)

type Server = gnet.Server

type Service struct {
	*gnet.EventServer

	Pool *GoroutinePool
	// contains filtered or unexported fields
}

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