Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlineGrpcServer ¶ added in v1.0.3
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 ¶ added in v1.0.3
func GrpcServerStart(listenAddress string) (*AlineGrpcServer, error)
func (*AlineGrpcServer) AlineChat ¶ added in v1.0.3
func (s *AlineGrpcServer) AlineChat(stream api.AlineRPC_AlineChatServer) error
AlineChat 每当有新的连接建立时，都会调用这个函数，不同的连接会有不同的 stream
Source Files
Click to show internal directories.
Click to hide internal directories.