simpletcp

package

v1.5.0 Latest Latest Go to latest Published: Jun 9, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const BODY = channel.ReplayState(3)

View Source

const FLAG = channel.ReplayState(1)

View Source

const LENGTH = channel.ReplayState(2)

This section is empty.

func VarIntDecode(flag byte, bbf buf.ByteBuf) uint64

func VarIntEncode(val uint64) buf.ByteBuf

type Client struct {
	AutoReconnect func() bool
	Handler       channel.Handler
	// contains filtered or unexported fields
}

func NewClient(handler channel.Handler) *Client

func (c *Client) Channel() channel.Channel

func (c *Client) Disconnect() channel.Future

func (c *Client) Start(remoteAddr net.Addr) channel.Channel

func (c *Client) Write(buf buf.ByteBuf) channel.Future

type Server struct {
	Handler channel.Handler
	// contains filtered or unexported fields
}

func NewServer(handler channel.Handler) *Server

func (s *Server) Channel() channel.Channel

func (s *Server) Start(localAddr net.Addr) channel.Channel

func (s *Server) Stop() channel.Future

type SimpleCodec struct {
	*channel.ReplayDecoder
	// contains filtered or unexported fields
}

func NewSimpleCodec() *SimpleCodec

func (h *SimpleCodec) Write(ctx channel.HandlerContext, obj any, future channel.Future)