server

Documentation

Index

• type AlineGrpcServer
  • func GrpcServerStart(listenAddress string) (*AlineGrpcServer, error)
  • func (s *AlineGrpcServer) AlineChat(stream api.AlineRPC_AlineChatServer) error

Types

type AlineGrpcServer

type AlineGrpcServer struct {
	api.UnimplementedAlineRPCServer
	RecvMsgChan chan *api.AlineMessage
	SendMsgChan chan *api.AlineMessage

	ErrorChan chan error // 用来接收 grpc server 发送消息的错误
	// contains filtered or unexported fields
}

func GrpcServerStart

func GrpcServerStart(listenAddress string) (*AlineGrpcServer, error)

func (*AlineGrpcServer) AlineChat

func (s *AlineGrpcServer) AlineChat(stream api.AlineRPC_AlineChatServer) error

AlineChat 每当有新的连接建立时，都会调用这个函数，不同的连接会有不同的 stream