Versions in this module Expand all Collapse all v0 v0.2.0-alpha.0 Jun 12, 2023 v0.1.0 Feb 6, 2023 Changes in this version + var File_logic_logic_proto protoreflect.FileDescriptor + var Logic_ServiceDesc = grpc.ServiceDesc + var Type_name = map[int32]string + var Type_value = map[string]int32 + func RegisterLogicServer(s grpc.ServiceRegistrar, srv LogicServer) + type BizMsg struct + AppId string + FromId string + Key string + Msg []byte + Op int32 + Type Type + func (*BizMsg) Descriptor() ([]byte, []int) + func (*BizMsg) ProtoMessage() + func (x *BizMsg) GetAppId() string + func (x *BizMsg) GetFromId() string + func (x *BizMsg) GetKey() string + func (x *BizMsg) GetMsg() []byte + func (x *BizMsg) GetOp() int32 + func (x *BizMsg) GetType() Type + func (x *BizMsg) ProtoReflect() protoreflect.Message + func (x *BizMsg) Reset() + func (x *BizMsg) String() string + type ConnectReply struct + AppId string + Heartbeat int64 + Key string + Mid string + func (*ConnectReply) Descriptor() ([]byte, []int) + func (*ConnectReply) ProtoMessage() + func (x *ConnectReply) GetAppId() string + func (x *ConnectReply) GetHeartbeat() int64 + func (x *ConnectReply) GetKey() string + func (x *ConnectReply) GetMid() string + func (x *ConnectReply) ProtoReflect() protoreflect.Message + func (x *ConnectReply) Reset() + func (x *ConnectReply) String() string + type ConnectReq struct + Proto *protocol.Proto + Server string + func (*ConnectReq) Descriptor() ([]byte, []int) + func (*ConnectReq) ProtoMessage() + func (x *ConnectReq) GetProto() *protocol.Proto + func (x *ConnectReq) GetServer() string + func (x *ConnectReq) ProtoReflect() protoreflect.Message + func (x *ConnectReq) Reset() + func (x *ConnectReq) String() string + type DelGroupsReq struct + AppId string + Gid []string + func (*DelGroupsReq) Descriptor() ([]byte, []int) + func (*DelGroupsReq) ProtoMessage() + func (x *DelGroupsReq) GetAppId() string + func (x *DelGroupsReq) GetGid() []string + func (x *DelGroupsReq) ProtoReflect() protoreflect.Message + func (x *DelGroupsReq) Reset() + func (x *DelGroupsReq) String() string + type DisconnectReq struct + Key string + Server string + func (*DisconnectReq) Descriptor() ([]byte, []int) + func (*DisconnectReq) ProtoMessage() + func (x *DisconnectReq) GetKey() string + func (x *DisconnectReq) GetServer() string + func (x *DisconnectReq) ProtoReflect() protoreflect.Message + func (x *DisconnectReq) Reset() + func (x *DisconnectReq) String() string + type GroupMsg struct + AppId string + Group string + Msg []byte + Op int32 + Type Type + func (*GroupMsg) Descriptor() ([]byte, []int) + func (*GroupMsg) ProtoMessage() + func (x *GroupMsg) GetAppId() string + func (x *GroupMsg) GetGroup() string + func (x *GroupMsg) GetMsg() []byte + func (x *GroupMsg) GetOp() int32 + func (x *GroupMsg) GetType() Type + func (x *GroupMsg) ProtoReflect() protoreflect.Message + func (x *GroupMsg) Reset() + func (x *GroupMsg) String() string + type GroupsKey struct + AppId string + Gid []string + Keys []string + func (*GroupsKey) Descriptor() ([]byte, []int) + func (*GroupsKey) ProtoMessage() + func (x *GroupsKey) GetAppId() string + func (x *GroupsKey) GetGid() []string + func (x *GroupsKey) GetKeys() []string + func (x *GroupsKey) ProtoReflect() protoreflect.Message + func (x *GroupsKey) Reset() + func (x *GroupsKey) String() string + type GroupsMid struct + AppId string + Gid []string + Mids []string + func (*GroupsMid) Descriptor() ([]byte, []int) + func (*GroupsMid) ProtoMessage() + func (x *GroupsMid) GetAppId() string + func (x *GroupsMid) GetGid() []string + func (x *GroupsMid) GetMids() []string + func (x *GroupsMid) ProtoReflect() protoreflect.Message + func (x *GroupsMid) Reset() + func (x *GroupsMid) String() string + type HeartbeatReq struct + Key string + Server string + func (*HeartbeatReq) Descriptor() ([]byte, []int) + func (*HeartbeatReq) ProtoMessage() + func (x *HeartbeatReq) GetKey() string + func (x *HeartbeatReq) GetServer() string + func (x *HeartbeatReq) ProtoReflect() protoreflect.Message + func (x *HeartbeatReq) Reset() + func (x *HeartbeatReq) String() string + type KeysMsg struct + AppId string + Msg []byte + Op int32 + ToKeys []string + Type Type + func (*KeysMsg) Descriptor() ([]byte, []int) + func (*KeysMsg) ProtoMessage() + func (x *KeysMsg) GetAppId() string + func (x *KeysMsg) GetMsg() []byte + func (x *KeysMsg) GetOp() int32 + func (x *KeysMsg) GetToKeys() []string + func (x *KeysMsg) GetType() Type + func (x *KeysMsg) ProtoReflect() protoreflect.Message + func (x *KeysMsg) Reset() + func (x *KeysMsg) String() string + type LogicClient interface + Connect func(ctx context.Context, in *ConnectReq, opts ...grpc.CallOption) (*ConnectReply, error) + DelGroups func(ctx context.Context, in *DelGroupsReq, opts ...grpc.CallOption) (*Reply, error) + Disconnect func(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*Reply, error) + Heartbeat func(ctx context.Context, in *HeartbeatReq, opts ...grpc.CallOption) (*Reply, error) + JoinGroupsByKeys func(ctx context.Context, in *GroupsKey, opts ...grpc.CallOption) (*Reply, error) + JoinGroupsByMids func(ctx context.Context, in *GroupsMid, opts ...grpc.CallOption) (*Reply, error) + LeaveGroupsByKeys func(ctx context.Context, in *GroupsKey, opts ...grpc.CallOption) (*Reply, error) + LeaveGroupsByMids func(ctx context.Context, in *GroupsMid, opts ...grpc.CallOption) (*Reply, error) + PushByKeys func(ctx context.Context, in *KeysMsg, opts ...grpc.CallOption) (*Reply, error) + PushByMids func(ctx context.Context, in *MidsMsg, opts ...grpc.CallOption) (*Reply, error) + PushGroup func(ctx context.Context, in *GroupMsg, opts ...grpc.CallOption) (*Reply, error) + Receive func(ctx context.Context, in *ReceiveReq, opts ...grpc.CallOption) (*Reply, error) + func NewLogicClient(cc grpc.ClientConnInterface) LogicClient + type LogicServer interface + Connect func(context.Context, *ConnectReq) (*ConnectReply, error) + DelGroups func(context.Context, *DelGroupsReq) (*Reply, error) + Disconnect func(context.Context, *DisconnectReq) (*Reply, error) + Heartbeat func(context.Context, *HeartbeatReq) (*Reply, error) + JoinGroupsByKeys func(context.Context, *GroupsKey) (*Reply, error) + JoinGroupsByMids func(context.Context, *GroupsMid) (*Reply, error) + LeaveGroupsByKeys func(context.Context, *GroupsKey) (*Reply, error) + LeaveGroupsByMids func(context.Context, *GroupsMid) (*Reply, error) + PushByKeys func(context.Context, *KeysMsg) (*Reply, error) + PushByMids func(context.Context, *MidsMsg) (*Reply, error) + PushGroup func(context.Context, *GroupMsg) (*Reply, error) + Receive func(context.Context, *ReceiveReq) (*Reply, error) + type MidsMsg struct + AppId string + Msg []byte + Op int32 + ToIds []string + Type Type + func (*MidsMsg) Descriptor() ([]byte, []int) + func (*MidsMsg) ProtoMessage() + func (x *MidsMsg) GetAppId() string + func (x *MidsMsg) GetMsg() []byte + func (x *MidsMsg) GetOp() int32 + func (x *MidsMsg) GetToIds() []string + func (x *MidsMsg) GetType() Type + func (x *MidsMsg) ProtoReflect() protoreflect.Message + func (x *MidsMsg) Reset() + func (x *MidsMsg) String() string + type ReceiveReq struct + Key string + Proto *protocol.Proto + func (*ReceiveReq) Descriptor() ([]byte, []int) + func (*ReceiveReq) ProtoMessage() + func (x *ReceiveReq) GetKey() string + func (x *ReceiveReq) GetProto() *protocol.Proto + func (x *ReceiveReq) ProtoReflect() protoreflect.Message + func (x *ReceiveReq) Reset() + func (x *ReceiveReq) String() string + type Reply struct + IsOk bool + Msg []byte + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + func (x *Reply) GetIsOk() bool + func (x *Reply) GetMsg() []byte + func (x *Reply) ProtoReflect() protoreflect.Message + func (x *Reply) Reset() + func (x *Reply) String() string + type Type int32 + const Type_BROADCAST + const Type_PUSH + const Type_ROOM + func (Type) Descriptor() protoreflect.EnumDescriptor + func (Type) EnumDescriptor() ([]byte, []int) + func (Type) Type() protoreflect.EnumType + func (x Type) Enum() *Type + func (x Type) Number() protoreflect.EnumNumber + func (x Type) String() string + type UnimplementedLogicServer struct + func (UnimplementedLogicServer) Connect(context.Context, *ConnectReq) (*ConnectReply, error) + func (UnimplementedLogicServer) DelGroups(context.Context, *DelGroupsReq) (*Reply, error) + func (UnimplementedLogicServer) Disconnect(context.Context, *DisconnectReq) (*Reply, error) + func (UnimplementedLogicServer) Heartbeat(context.Context, *HeartbeatReq) (*Reply, error) + func (UnimplementedLogicServer) JoinGroupsByKeys(context.Context, *GroupsKey) (*Reply, error) + func (UnimplementedLogicServer) JoinGroupsByMids(context.Context, *GroupsMid) (*Reply, error) + func (UnimplementedLogicServer) LeaveGroupsByKeys(context.Context, *GroupsKey) (*Reply, error) + func (UnimplementedLogicServer) LeaveGroupsByMids(context.Context, *GroupsMid) (*Reply, error) + func (UnimplementedLogicServer) PushByKeys(context.Context, *KeysMsg) (*Reply, error) + func (UnimplementedLogicServer) PushByMids(context.Context, *MidsMsg) (*Reply, error) + func (UnimplementedLogicServer) PushGroup(context.Context, *GroupMsg) (*Reply, error) + func (UnimplementedLogicServer) Receive(context.Context, *ReceiveReq) (*Reply, error) + type UnsafeLogicServer interface v0.0.3 Aug 18, 2022 v0.0.2 Jun 9, 2022 v0.0.1 Mar 23, 2022
Go to main page