server

package

v1.0.0 Latest Latest Go to latest Published: Nov 24, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Server struct {
	SessionCount    int64 // 会话数量
	ConnectionCount int64 // 连接数量
	// contains filtered or unexported fields
}

func NewServer(proto gira.Proto) *Server

func (server *Server) OnCreate() error

func (server *Server) OnPeerAdd(peer *gira.Peer)

func (server *Server) OnPeerDelete(peer *gira.Peer)

func (server *Server) OnPeerUpdate(peer *gira.Peer)

func (server *Server) SelectPeer() *Upstream

选择一个节点

func (server *Server) ServeClientStream(client gira.GatewayConn)

客户端流数据 1.处理客户端发过来的第1个消息，必须满足LoginRequest接口 2.验证token 3.验证成功后，创建session,交给session处理接下来的客户端消息

type Upstream struct {
	Id       int32
	FullName string
	Address  string
	// contains filtered or unexported fields
}

hall.ctx

   |
	  |----ctx---
			|
			|--- upstream ctx

func (server *Upstream) HealthCheck() (err error)

func (server *Upstream) NewClientStream(ctx context.Context) (stream hallpb.Hall_ClientStreamClient, err error)

func (server *Upstream) String() string