Versions in this module Expand all Collapse all v0 v0.0.2 Feb 6, 2024 v0.0.1 Feb 1, 2024 Changes in this version + const Broker_BroadcastRoom_FullMethodName + const Broker_Broadcast_FullMethodName + const Broker_PushMsg_FullMethodName + const Broker_Push_FullMethodName + const Broker_Rooms_FullMethodName + var Broker_ServiceDesc = grpc.ServiceDesc + var File_api_broker_broker_proto protoreflect.FileDescriptor + func RegisterBrokerServer(s grpc.ServiceRegistrar, srv BrokerServer) + type BroadcastReply struct + func (*BroadcastReply) Descriptor() ([]byte, []int) + func (*BroadcastReply) ProtoMessage() + func (x *BroadcastReply) ProtoReflect() protoreflect.Message + func (x *BroadcastReply) Reset() + func (x *BroadcastReply) String() string + type BroadcastReq struct + Msg *protocol.Message + ProtoOp int32 + Speed int32 + func (*BroadcastReq) Descriptor() ([]byte, []int) + func (*BroadcastReq) ProtoMessage() + func (x *BroadcastReq) GetMsg() *protocol.Message + func (x *BroadcastReq) GetProtoOp() int32 + func (x *BroadcastReq) GetSpeed() int32 + func (x *BroadcastReq) ProtoReflect() protoreflect.Message + func (x *BroadcastReq) Reset() + func (x *BroadcastReq) String() string + type BroadcastRoomReply struct + func (*BroadcastRoomReply) Descriptor() ([]byte, []int) + func (*BroadcastRoomReply) ProtoMessage() + func (x *BroadcastRoomReply) ProtoReflect() protoreflect.Message + func (x *BroadcastRoomReply) Reset() + func (x *BroadcastRoomReply) String() string + type BroadcastRoomReq struct + Msg *protocol.Message + RoomId string + func (*BroadcastRoomReq) Descriptor() ([]byte, []int) + func (*BroadcastRoomReq) ProtoMessage() + func (x *BroadcastRoomReq) GetMsg() *protocol.Message + func (x *BroadcastRoomReq) GetRoomId() string + func (x *BroadcastRoomReq) ProtoReflect() protoreflect.Message + func (x *BroadcastRoomReq) Reset() + func (x *BroadcastRoomReq) String() string + type BrokerClient interface + Broadcast func(ctx context.Context, in *BroadcastReq, opts ...grpc.CallOption) (*BroadcastReply, error) + BroadcastRoom func(ctx context.Context, in *BroadcastRoomReq, opts ...grpc.CallOption) (*BroadcastRoomReply, error) + Push func(ctx context.Context, in *PushReq, opts ...grpc.CallOption) (*PushReply, error) + PushMsg func(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgReply, error) + Rooms func(ctx context.Context, in *RoomsReq, opts ...grpc.CallOption) (*RoomsReply, error) + func NewBrokerClient(cc grpc.ClientConnInterface) BrokerClient + type BrokerServer interface + Broadcast func(context.Context, *BroadcastReq) (*BroadcastReply, error) + BroadcastRoom func(context.Context, *BroadcastRoomReq) (*BroadcastRoomReply, error) + Push func(context.Context, *PushReq) (*PushReply, error) + PushMsg func(context.Context, *PushMsgReq) (*PushMsgReply, error) + Rooms func(context.Context, *RoomsReq) (*RoomsReply, error) + type PushMsgReply struct + func (*PushMsgReply) Descriptor() ([]byte, []int) + func (*PushMsgReply) ProtoMessage() + func (x *PushMsgReply) ProtoReflect() protoreflect.Message + func (x *PushMsgReply) Reset() + func (x *PushMsgReply) String() string + type PushMsgReq struct + Keys []string + Msg *protocol.Message + ProtoOp int32 + func (*PushMsgReq) Descriptor() ([]byte, []int) + func (*PushMsgReq) ProtoMessage() + func (x *PushMsgReq) GetKeys() []string + func (x *PushMsgReq) GetMsg() *protocol.Message + func (x *PushMsgReq) GetProtoOp() int32 + func (x *PushMsgReq) ProtoReflect() protoreflect.Message + func (x *PushMsgReq) Reset() + func (x *PushMsgReq) String() string + type PushReply struct + BaseReply *protocol.BaseReply + func (*PushReply) Descriptor() ([]byte, []int) + func (*PushReply) ProtoMessage() + func (x *PushReply) GetBaseReply() *protocol.BaseReply + func (x *PushReply) ProtoReflect() protoreflect.Message + func (x *PushReply) Reset() + func (x *PushReply) String() string + type PushReq struct + Messages []*protocol.TransMessage + func (*PushReq) Descriptor() ([]byte, []int) + func (*PushReq) ProtoMessage() + func (x *PushReq) GetMessages() []*protocol.TransMessage + func (x *PushReq) ProtoReflect() protoreflect.Message + func (x *PushReq) Reset() + func (x *PushReq) String() string + type RoomsReply struct + Rooms map[string]bool + func (*RoomsReply) Descriptor() ([]byte, []int) + func (*RoomsReply) ProtoMessage() + func (x *RoomsReply) GetRooms() map[string]bool + func (x *RoomsReply) ProtoReflect() protoreflect.Message + func (x *RoomsReply) Reset() + func (x *RoomsReply) String() string + type RoomsReq struct + func (*RoomsReq) Descriptor() ([]byte, []int) + func (*RoomsReq) ProtoMessage() + func (x *RoomsReq) ProtoReflect() protoreflect.Message + func (x *RoomsReq) Reset() + func (x *RoomsReq) String() string + type UnimplementedBrokerServer struct + func (UnimplementedBrokerServer) Broadcast(context.Context, *BroadcastReq) (*BroadcastReply, error) + func (UnimplementedBrokerServer) BroadcastRoom(context.Context, *BroadcastRoomReq) (*BroadcastRoomReply, error) + func (UnimplementedBrokerServer) Push(context.Context, *PushReq) (*PushReply, error) + func (UnimplementedBrokerServer) PushMsg(context.Context, *PushMsgReq) (*PushMsgReply, error) + func (UnimplementedBrokerServer) Rooms(context.Context, *RoomsReq) (*RoomsReply, error) + type UnsafeBrokerServer interface
Go to main page