tcp

package

v0.0.0-...-33e1650 Latest Latest Go to latest Published: Apr 27, 2025 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (h MessageHandler) HandleActive(ctx netty.ActiveContext)

func (h MessageHandler) HandleException(ctx netty.ExceptionContext, ex netty.Exception)

func (h MessageHandler) HandleInactive(ctx netty.InactiveContext, ex netty.Exception)

func (h MessageHandler) HandleRead(ctx netty.InboundContext, message netty.Message)

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

Server is an TCP server wrapper.

func NewServer(ctx *transport.Context, codec []codec.Codec, codec2 vulcanus.Codec, handler vulcanus.DataHandler, opts ...ServerOption) *Server

NewServer creates a TCP server by options.

func (s *Server) Start(ctx context.Context) error

Start start the TCP server.

func (s *Server) Stop(ctx context.Context) error

Stop stop the TCP server.

type ServerOption func(*Server)

func Port(port uint32) ServerOption

Port with server port.