gateway

Documentation

Index

• func SendAckToSender(senderId string, requestId uint32, messageId int64) error
• func SendToAll(cmd string, requestId uint32, data []byte)
• func TransferToReceiver(receiverId string, cmd string, requestId uint32, data []byte) error
• type Service
  • func NewService(cf config.Rpc) *Service
  • func (s *Service) Ping(c context.Context, req *proto_build.PingRequest) (*proto_build.PingResponse, error)
  • func (s *Service) Register(c context.Context, req *proto_build.RegisterRequest) (*proto_build.RegisterResponse, error)
  • func (s *Service) SendMessage(stream proto_build.GatewayService_SendMessageServer) error
  • func (s *Service) SendToAll(c context.Context, req *proto_build.SendToAllRequest) (*proto_build.SendToAllResponse, error)
  • func (s *Service) UnRegister(c context.Context, req *proto_build.UnRegisterRequest) (*proto_build.UnRegisterResponse, error)

Functions

func SendAckToSender

func SendAckToSender(senderId string, requestId uint32, messageId int64) error

func SendToAll

func SendToAll(cmd string, requestId uint32, data []byte)

func TransferToReceiver

func TransferToReceiver(receiverId string, cmd string, requestId uint32, data []byte) error

Types

type Service

type Service struct {
	service.BasicService
	proto_build.UnimplementedGatewayServiceServer
}

func NewService

func NewService(cf config.Rpc) *Service

func (*Service) Ping

func (s *Service) Ping(c context.Context, req *proto_build.PingRequest) (*proto_build.PingResponse, error)

func (*Service) Register

func (s *Service) Register(c context.Context, req *proto_build.RegisterRequest) (*proto_build.RegisterResponse, error)

func (*Service) SendMessage

func (s *Service) SendMessage(stream proto_build.GatewayService_SendMessageServer) error

func (*Service) SendToAll

func (s *Service) SendToAll(c context.Context, req *proto_build.SendToAllRequest) (*proto_build.SendToAllResponse, error)

func (*Service) UnRegister

func (s *Service) UnRegister(c context.Context, req *proto_build.UnRegisterRequest) (*proto_build.UnRegisterResponse, error)