server

package

v2.2.5 Latest Latest Go to latest Published: Feb 19, 2025 License: MIT Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Conn struct {
	InsKind cluster.Kind // 集群类型
	InsID   string       // 集群ID
	// contains filtered or unexported fields
}

func (c *Conn) Send(buf buffer.Buffer) (err error)

Send 发送消息

type Options struct {
	Addr string // 监听地址
}

type RouteHandler func(conn *Conn, data []byte) error

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

func NewServer(opts *Options) (*Server, error)

func (s *Server) Endpoint() *endpoint.Endpoint

Endpoint 暴露端点

func (s *Server) ExposeAddr() string

ExposeAddr 暴露地址

func (s *Server) ListenAddr() string

ListenAddr 监听地址

func (s *Server) RegisterHandler(route uint8, handler RouteHandler)

RegisterHandler 注册处理器

func (s *Server) Scheme() string

Scheme 协议

func (s *Server) Start() error

Start 启动服务器

func (s *Server) Stop() error

Stop 停止服务器