logic

package
v0.2.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 12, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_logic_logic_proto protoreflect.FileDescriptor
View Source 
var Logic_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "im.logic.Logic",
	HandlerType: (*LogicServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Connect",
			Handler:    _Logic_Connect_Handler,
		},
		{
			MethodName: "Disconnect",
			Handler:    _Logic_Disconnect_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Logic_Heartbeat_Handler,
		},
		{
			MethodName: "Receive",
			Handler:    _Logic_Receive_Handler,
		},
		{
			MethodName: "SendByUID",
			Handler:    _Logic_SendByUID_Handler,
		},
		{
			MethodName: "PushByUID",
			Handler:    _Logic_PushByUID_Handler,
		},
		{
			MethodName: "PushByKey",
			Handler:    _Logic_PushByKey_Handler,
		},
		{
			MethodName: "PushGroup",
			Handler:    _Logic_PushGroup_Handler,
		},
		{
			MethodName: "JoinGroupByKey",
			Handler:    _Logic_JoinGroupByKey_Handler,
		},
		{
			MethodName: "JoinGroupByUID",
			Handler:    _Logic_JoinGroupByUID_Handler,
		},
		{
			MethodName: "LeaveGroupByKey",
			Handler:    _Logic_LeaveGroupByKey_Handler,
		},
		{
			MethodName: "LeaveGroupByUID",
			Handler:    _Logic_LeaveGroupByUID_Handler,
		},
		{
			MethodName: "DelGroup",
			Handler:    _Logic_DelGroup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "logic/logic.proto",
}

Logic_ServiceDesc is the grpc.ServiceDesc for Logic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLogicServer 

func RegisterLogicServer(s grpc.ServiceRegistrar, srv LogicServer)

Types

type ConnectReply 

type ConnectReply struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	AppId     string `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
	Uid       string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	Heartbeat int64  `protobuf:"varint,4,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectReply) Descriptor deprecated 

func (*ConnectReply) Descriptor() ([]byte, []int)

Deprecated: Use ConnectReply.ProtoReflect.Descriptor instead.

func (*ConnectReply) GetAppId 

func (x *ConnectReply) GetAppId() string

func (*ConnectReply) GetHeartbeat 

func (x *ConnectReply) GetHeartbeat() int64

func (*ConnectReply) GetKey 

func (x *ConnectReply) GetKey() string

func (*ConnectReply) GetUid 

func (x *ConnectReply) GetUid() string

func (*ConnectReply) ProtoMessage 

func (*ConnectReply) ProtoMessage()

func (*ConnectReply) ProtoReflect 

func (x *ConnectReply) ProtoReflect() protoreflect.Message

func (*ConnectReply) Reset 

func (x *ConnectReply) Reset()

func (*ConnectReply) String 

func (x *ConnectReply) String() string

type ConnectReq 

type ConnectReq struct {
	Server string          `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` // 客户端连接的是哪个 comet
	Proto  *protocol.Proto `protobuf:"bytes,3,opt,name=proto,proto3" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectReq) Descriptor deprecated 

func (*ConnectReq) Descriptor() ([]byte, []int)

Deprecated: Use ConnectReq.ProtoReflect.Descriptor instead.

func (*ConnectReq) GetProto 

func (x *ConnectReq) GetProto() *protocol.Proto

func (*ConnectReq) GetServer 

func (x *ConnectReq) GetServer() string

func (*ConnectReq) ProtoMessage 

func (*ConnectReq) ProtoMessage()

func (*ConnectReq) ProtoReflect 

func (x *ConnectReq) ProtoReflect() protoreflect.Message

func (*ConnectReq) Reset 

func (x *ConnectReq) Reset()

func (*ConnectReq) String 

func (x *ConnectReq) String() string

type DelGroupReq 

type DelGroupReq struct {
	AppId string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Gid   []string `protobuf:"bytes,2,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*DelGroupReq) Descriptor deprecated 

func (*DelGroupReq) Descriptor() ([]byte, []int)

Deprecated: Use DelGroupReq.ProtoReflect.Descriptor instead.

func (*DelGroupReq) GetAppId 

func (x *DelGroupReq) GetAppId() string

func (*DelGroupReq) GetGid 

func (x *DelGroupReq) GetGid() []string

func (*DelGroupReq) ProtoMessage 

func (*DelGroupReq) ProtoMessage()

func (*DelGroupReq) ProtoReflect 

func (x *DelGroupReq) ProtoReflect() protoreflect.Message

func (*DelGroupReq) Reset 

func (x *DelGroupReq) Reset()

func (*DelGroupReq) String 

func (x *DelGroupReq) String() string

type DisconnectReq 

type DisconnectReq struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Server string `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectReq) Descriptor deprecated 

func (*DisconnectReq) Descriptor() ([]byte, []int)

Deprecated: Use DisconnectReq.ProtoReflect.Descriptor instead.

func (*DisconnectReq) GetKey 

func (x *DisconnectReq) GetKey() string

func (*DisconnectReq) GetServer 

func (x *DisconnectReq) GetServer() string

func (*DisconnectReq) ProtoMessage 

func (*DisconnectReq) ProtoMessage()

func (*DisconnectReq) ProtoReflect 

func (x *DisconnectReq) ProtoReflect() protoreflect.Message

func (*DisconnectReq) Reset 

func (x *DisconnectReq) Reset()

func (*DisconnectReq) String 

func (x *DisconnectReq) String() string

type HeartbeatReq 

type HeartbeatReq struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Server string `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatReq) Descriptor deprecated 

func (*HeartbeatReq) Descriptor() ([]byte, []int)

Deprecated: Use HeartbeatReq.ProtoReflect.Descriptor instead.

func (*HeartbeatReq) GetKey 

func (x *HeartbeatReq) GetKey() string

func (*HeartbeatReq) GetServer 

func (x *HeartbeatReq) GetServer() string

func (*HeartbeatReq) ProtoMessage 

func (*HeartbeatReq) ProtoMessage()

func (*HeartbeatReq) ProtoReflect 

func (x *HeartbeatReq) ProtoReflect() protoreflect.Message

func (*HeartbeatReq) Reset 

func (x *HeartbeatReq) Reset()

func (*HeartbeatReq) String 

func (x *HeartbeatReq) String() string

type JoinGroupByKeyReq 

type JoinGroupByKeyReq struct {
	AppId string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Key   []string `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	Gid   []string `protobuf:"bytes,3,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*JoinGroupByKeyReq) Descriptor deprecated 

func (*JoinGroupByKeyReq) Descriptor() ([]byte, []int)

Deprecated: Use JoinGroupByKeyReq.ProtoReflect.Descriptor instead.

func (*JoinGroupByKeyReq) GetAppId 

func (x *JoinGroupByKeyReq) GetAppId() string

func (*JoinGroupByKeyReq) GetGid 

func (x *JoinGroupByKeyReq) GetGid() []string

func (*JoinGroupByKeyReq) GetKey 

func (x *JoinGroupByKeyReq) GetKey() []string

func (*JoinGroupByKeyReq) ProtoMessage 

func (*JoinGroupByKeyReq) ProtoMessage()

func (*JoinGroupByKeyReq) ProtoReflect 

func (x *JoinGroupByKeyReq) ProtoReflect() protoreflect.Message

func (*JoinGroupByKeyReq) Reset 

func (x *JoinGroupByKeyReq) Reset()

func (*JoinGroupByKeyReq) String 

func (x *JoinGroupByKeyReq) String() string

type JoinGroupByUIDReq 

type JoinGroupByUIDReq struct {
	AppId string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Uid   []string `protobuf:"bytes,2,rep,name=uid,proto3" json:"uid,omitempty"`
	Gid   []string `protobuf:"bytes,3,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*JoinGroupByUIDReq) Descriptor deprecated 

func (*JoinGroupByUIDReq) Descriptor() ([]byte, []int)

Deprecated: Use JoinGroupByUIDReq.ProtoReflect.Descriptor instead.

func (*JoinGroupByUIDReq) GetAppId 

func (x *JoinGroupByUIDReq) GetAppId() string

func (*JoinGroupByUIDReq) GetGid 

func (x *JoinGroupByUIDReq) GetGid() []string

func (*JoinGroupByUIDReq) GetUid 

func (x *JoinGroupByUIDReq) GetUid() []string

func (*JoinGroupByUIDReq) ProtoMessage 

func (*JoinGroupByUIDReq) ProtoMessage()

func (*JoinGroupByUIDReq) ProtoReflect 

func (x *JoinGroupByUIDReq) ProtoReflect() protoreflect.Message

func (*JoinGroupByUIDReq) Reset 

func (x *JoinGroupByUIDReq) Reset()

func (*JoinGroupByUIDReq) String 

func (x *JoinGroupByUIDReq) String() string

type LeaveGroupByKeyReq 

type LeaveGroupByKeyReq struct {
	AppId string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Key   []string `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	Gid   []string `protobuf:"bytes,3,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveGroupByKeyReq) Descriptor deprecated 

func (*LeaveGroupByKeyReq) Descriptor() ([]byte, []int)

Deprecated: Use LeaveGroupByKeyReq.ProtoReflect.Descriptor instead.

func (*LeaveGroupByKeyReq) GetAppId 

func (x *LeaveGroupByKeyReq) GetAppId() string

func (*LeaveGroupByKeyReq) GetGid 

func (x *LeaveGroupByKeyReq) GetGid() []string

func (*LeaveGroupByKeyReq) GetKey 

func (x *LeaveGroupByKeyReq) GetKey() []string

func (*LeaveGroupByKeyReq) ProtoMessage 

func (*LeaveGroupByKeyReq) ProtoMessage()

func (*LeaveGroupByKeyReq) ProtoReflect 

func (x *LeaveGroupByKeyReq) ProtoReflect() protoreflect.Message

func (*LeaveGroupByKeyReq) Reset 

func (x *LeaveGroupByKeyReq) Reset()

func (*LeaveGroupByKeyReq) String 

func (x *LeaveGroupByKeyReq) String() string

type LeaveGroupByUIDReq 

type LeaveGroupByUIDReq struct {
	AppId string   `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Uid   []string `protobuf:"bytes,2,rep,name=uid,proto3" json:"uid,omitempty"`
	Gid   []string `protobuf:"bytes,3,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveGroupByUIDReq) Descriptor deprecated 

func (*LeaveGroupByUIDReq) Descriptor() ([]byte, []int)

Deprecated: Use LeaveGroupByUIDReq.ProtoReflect.Descriptor instead.

func (*LeaveGroupByUIDReq) GetAppId 

func (x *LeaveGroupByUIDReq) GetAppId() string

func (*LeaveGroupByUIDReq) GetGid 

func (x *LeaveGroupByUIDReq) GetGid() []string

func (*LeaveGroupByUIDReq) GetUid 

func (x *LeaveGroupByUIDReq) GetUid() []string

func (*LeaveGroupByUIDReq) ProtoMessage 

func (*LeaveGroupByUIDReq) ProtoMessage()

func (*LeaveGroupByUIDReq) ProtoReflect 

func (x *LeaveGroupByUIDReq) ProtoReflect() protoreflect.Message

func (*LeaveGroupByUIDReq) Reset 

func (x *LeaveGroupByUIDReq) Reset()

func (*LeaveGroupByUIDReq) String 

func (x *LeaveGroupByUIDReq) String() string

type LogicClient 

type LogicClient interface {
	Connect(ctx context.Context, in *ConnectReq, opts ...grpc.CallOption) (*ConnectReply, error)
	Disconnect(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*Reply, error)
	Heartbeat(ctx context.Context, in *HeartbeatReq, opts ...grpc.CallOption) (*Reply, error)
	Receive(ctx context.Context, in *ReceiveReq, opts ...grpc.CallOption) (*Reply, error)
	SendByUID(ctx context.Context, in *SendByUIDReq, opts ...grpc.CallOption) (*Reply, error)
	PushByUID(ctx context.Context, in *PushByUIDReq, opts ...grpc.CallOption) (*Reply, error)
	PushByKey(ctx context.Context, in *PushByKeyReq, opts ...grpc.CallOption) (*Reply, error)
	PushGroup(ctx context.Context, in *PushGroupReq, opts ...grpc.CallOption) (*Reply, error)
	JoinGroupByKey(ctx context.Context, in *JoinGroupByKeyReq, opts ...grpc.CallOption) (*Reply, error)
	JoinGroupByUID(ctx context.Context, in *JoinGroupByUIDReq, opts ...grpc.CallOption) (*Reply, error)
	LeaveGroupByKey(ctx context.Context, in *LeaveGroupByKeyReq, opts ...grpc.CallOption) (*Reply, error)
	LeaveGroupByUID(ctx context.Context, in *LeaveGroupByUIDReq, opts ...grpc.CallOption) (*Reply, error)
	DelGroup(ctx context.Context, in *DelGroupReq, opts ...grpc.CallOption) (*Reply, error)
}

LogicClient is the client API for Logic service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLogicClient 

func NewLogicClient(cc grpc.ClientConnInterface) LogicClient

type LogicServer 

type LogicServer interface {
	Connect(context.Context, *ConnectReq) (*ConnectReply, error)
	Disconnect(context.Context, *DisconnectReq) (*Reply, error)
	Heartbeat(context.Context, *HeartbeatReq) (*Reply, error)
	Receive(context.Context, *ReceiveReq) (*Reply, error)
	SendByUID(context.Context, *SendByUIDReq) (*Reply, error)
	PushByUID(context.Context, *PushByUIDReq) (*Reply, error)
	PushByKey(context.Context, *PushByKeyReq) (*Reply, error)
	PushGroup(context.Context, *PushGroupReq) (*Reply, error)
	JoinGroupByKey(context.Context, *JoinGroupByKeyReq) (*Reply, error)
	JoinGroupByUID(context.Context, *JoinGroupByUIDReq) (*Reply, error)
	LeaveGroupByKey(context.Context, *LeaveGroupByKeyReq) (*Reply, error)
	LeaveGroupByUID(context.Context, *LeaveGroupByUIDReq) (*Reply, error)
	DelGroup(context.Context, *DelGroupReq) (*Reply, error)
	// contains filtered or unexported methods
}

LogicServer is the server API for Logic service. All implementations must embed UnimplementedLogicServer for forward compatibility

type PushByKeyReq 

type PushByKeyReq struct {
	AppId string      `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	ToKey []string    `protobuf:"bytes,2,rep,name=toKey,proto3" json:"toKey,omitempty"`
	Op    protocol.Op `protobuf:"varint,3,opt,name=op,proto3,enum=im.protocol.Op" json:"op,omitempty"`
	Body  []byte      `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*PushByKeyReq) Descriptor deprecated 

func (*PushByKeyReq) Descriptor() ([]byte, []int)

Deprecated: Use PushByKeyReq.ProtoReflect.Descriptor instead.

func (*PushByKeyReq) GetAppId 

func (x *PushByKeyReq) GetAppId() string

func (*PushByKeyReq) GetBody 

func (x *PushByKeyReq) GetBody() []byte

func (*PushByKeyReq) GetOp 

func (x *PushByKeyReq) GetOp() protocol.Op

func (*PushByKeyReq) GetToKey 

func (x *PushByKeyReq) GetToKey() []string

func (*PushByKeyReq) ProtoMessage 

func (*PushByKeyReq) ProtoMessage()

func (*PushByKeyReq) ProtoReflect 

func (x *PushByKeyReq) ProtoReflect() protoreflect.Message

func (*PushByKeyReq) Reset 

func (x *PushByKeyReq) Reset()

func (*PushByKeyReq) String 

func (x *PushByKeyReq) String() string

type PushByUIDReq 

type PushByUIDReq struct {
	AppId string      `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	ToId  []string    `protobuf:"bytes,2,rep,name=toId,proto3" json:"toId,omitempty"`
	Op    protocol.Op `protobuf:"varint,3,opt,name=op,proto3,enum=im.protocol.Op" json:"op,omitempty"`
	Body  []byte      `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*PushByUIDReq) Descriptor deprecated 

func (*PushByUIDReq) Descriptor() ([]byte, []int)

Deprecated: Use PushByUIDReq.ProtoReflect.Descriptor instead.

func (*PushByUIDReq) GetAppId 

func (x *PushByUIDReq) GetAppId() string

func (*PushByUIDReq) GetBody 

func (x *PushByUIDReq) GetBody() []byte

func (*PushByUIDReq) GetOp 

func (x *PushByUIDReq) GetOp() protocol.Op

func (*PushByUIDReq) GetToId 

func (x *PushByUIDReq) GetToId() []string

func (*PushByUIDReq) ProtoMessage 

func (*PushByUIDReq) ProtoMessage()

func (*PushByUIDReq) ProtoReflect 

func (x *PushByUIDReq) ProtoReflect() protoreflect.Message

func (*PushByUIDReq) Reset 

func (x *PushByUIDReq) Reset()

func (*PushByUIDReq) String 

func (x *PushByUIDReq) String() string

type PushGroupReq 

type PushGroupReq struct {
	AppId string      `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Group string      `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Op    protocol.Op `protobuf:"varint,3,opt,name=op,proto3,enum=im.protocol.Op" json:"op,omitempty"`
	Body  []byte      `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*PushGroupReq) Descriptor deprecated 

func (*PushGroupReq) Descriptor() ([]byte, []int)

Deprecated: Use PushGroupReq.ProtoReflect.Descriptor instead.

func (*PushGroupReq) GetAppId 

func (x *PushGroupReq) GetAppId() string

func (*PushGroupReq) GetBody 

func (x *PushGroupReq) GetBody() []byte

func (*PushGroupReq) GetGroup 

func (x *PushGroupReq) GetGroup() string

func (*PushGroupReq) GetOp 

func (x *PushGroupReq) GetOp() protocol.Op

func (*PushGroupReq) ProtoMessage 

func (*PushGroupReq) ProtoMessage()

func (*PushGroupReq) ProtoReflect 

func (x *PushGroupReq) ProtoReflect() protoreflect.Message

func (*PushGroupReq) Reset 

func (x *PushGroupReq) Reset()

func (*PushGroupReq) String 

func (x *PushGroupReq) String() string

type ReceiveReq 

type ReceiveReq struct {
	Key   string          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Proto *protocol.Proto `protobuf:"bytes,3,opt,name=proto,proto3" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveReq) Descriptor deprecated 

func (*ReceiveReq) Descriptor() ([]byte, []int)

Deprecated: Use ReceiveReq.ProtoReflect.Descriptor instead.

func (*ReceiveReq) GetKey 

func (x *ReceiveReq) GetKey() string

func (*ReceiveReq) GetProto 

func (x *ReceiveReq) GetProto() *protocol.Proto

func (*ReceiveReq) ProtoMessage 

func (*ReceiveReq) ProtoMessage()

func (*ReceiveReq) ProtoReflect 

func (x *ReceiveReq) ProtoReflect() protoreflect.Message

func (*ReceiveReq) Reset 

func (x *ReceiveReq) Reset()

func (*ReceiveReq) String 

func (x *ReceiveReq) String() string

type ReceivedMessage 

type ReceivedMessage struct {
	AppId string      `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Key   string      `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	From  string      `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	Op    protocol.Op `protobuf:"varint,4,opt,name=op,proto3,enum=im.protocol.Op" json:"op,omitempty"`
	Body  []byte      `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

received from A publish to MQ

func (*ReceivedMessage) Descriptor deprecated 

func (*ReceivedMessage) Descriptor() ([]byte, []int)

Deprecated: Use ReceivedMessage.ProtoReflect.Descriptor instead.

func (*ReceivedMessage) GetAppId 

func (x *ReceivedMessage) GetAppId() string

func (*ReceivedMessage) GetBody 

func (x *ReceivedMessage) GetBody() []byte

func (*ReceivedMessage) GetFrom 

func (x *ReceivedMessage) GetFrom() string

func (*ReceivedMessage) GetKey 

func (x *ReceivedMessage) GetKey() string

func (*ReceivedMessage) GetOp 

func (x *ReceivedMessage) GetOp() protocol.Op

func (*ReceivedMessage) ProtoMessage 

func (*ReceivedMessage) ProtoMessage()

func (*ReceivedMessage) ProtoReflect 

func (x *ReceivedMessage) ProtoReflect() protoreflect.Message

func (*ReceivedMessage) Reset 

func (x *ReceivedMessage) Reset()

func (*ReceivedMessage) String 

func (x *ReceivedMessage) String() string

type Reply 

type Reply struct {
	IsOk bool   `protobuf:"varint,1,opt,name=isOk,proto3" json:"isOk,omitempty"`
	Msg  []byte `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

func (*Reply) Descriptor() ([]byte, []int)

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetIsOk 

func (x *Reply) GetIsOk() bool

func (*Reply) GetMsg 

func (x *Reply) GetMsg() []byte

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

func (x *Reply) ProtoReflect() protoreflect.Message

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type SendByUIDReq 

type SendByUIDReq struct {
	AppId string      `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
	Uid   string      `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Op    protocol.Op `protobuf:"varint,3,opt,name=op,proto3,enum=im.protocol.Op" json:"op,omitempty"`
	Body  []byte      `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

biz --> logic

func (*SendByUIDReq) Descriptor deprecated 

func (*SendByUIDReq) Descriptor() ([]byte, []int)

Deprecated: Use SendByUIDReq.ProtoReflect.Descriptor instead.

func (*SendByUIDReq) GetAppId 

func (x *SendByUIDReq) GetAppId() string

func (*SendByUIDReq) GetBody 

func (x *SendByUIDReq) GetBody() []byte

func (*SendByUIDReq) GetOp 

func (x *SendByUIDReq) GetOp() protocol.Op

func (*SendByUIDReq) GetUid 

func (x *SendByUIDReq) GetUid() string

func (*SendByUIDReq) ProtoMessage 

func (*SendByUIDReq) ProtoMessage()

func (*SendByUIDReq) ProtoReflect 

func (x *SendByUIDReq) ProtoReflect() protoreflect.Message

func (*SendByUIDReq) Reset 

func (x *SendByUIDReq) Reset()

func (*SendByUIDReq) String 

func (x *SendByUIDReq) String() string

type UnimplementedLogicServer 

type UnimplementedLogicServer struct {
}

UnimplementedLogicServer must be embedded to have forward compatible implementations.

func (UnimplementedLogicServer) Connect 

func (UnimplementedLogicServer) Connect(context.Context, *ConnectReq) (*ConnectReply, error)

func (UnimplementedLogicServer) DelGroup 

func (UnimplementedLogicServer) DelGroup(context.Context, *DelGroupReq) (*Reply, error)

func (UnimplementedLogicServer) Disconnect 

func (UnimplementedLogicServer) Disconnect(context.Context, *DisconnectReq) (*Reply, error)

func (UnimplementedLogicServer) Heartbeat 

func (UnimplementedLogicServer) Heartbeat(context.Context, *HeartbeatReq) (*Reply, error)

func (UnimplementedLogicServer) JoinGroupByKey 

func (UnimplementedLogicServer) JoinGroupByKey(context.Context, *JoinGroupByKeyReq) (*Reply, error)

func (UnimplementedLogicServer) JoinGroupByUID 

func (UnimplementedLogicServer) JoinGroupByUID(context.Context, *JoinGroupByUIDReq) (*Reply, error)

func (UnimplementedLogicServer) LeaveGroupByKey 

func (UnimplementedLogicServer) LeaveGroupByKey(context.Context, *LeaveGroupByKeyReq) (*Reply, error)

func (UnimplementedLogicServer) LeaveGroupByUID 

func (UnimplementedLogicServer) LeaveGroupByUID(context.Context, *LeaveGroupByUIDReq) (*Reply, error)

func (UnimplementedLogicServer) PushByKey 

func (UnimplementedLogicServer) PushByKey(context.Context, *PushByKeyReq) (*Reply, error)

func (UnimplementedLogicServer) PushByUID 

func (UnimplementedLogicServer) PushByUID(context.Context, *PushByUIDReq) (*Reply, error)

func (UnimplementedLogicServer) PushGroup 

func (UnimplementedLogicServer) PushGroup(context.Context, *PushGroupReq) (*Reply, error)

func (UnimplementedLogicServer) Receive 

func (UnimplementedLogicServer) Receive(context.Context, *ReceiveReq) (*Reply, error)

func (UnimplementedLogicServer) SendByUID 

func (UnimplementedLogicServer) SendByUID(context.Context, *SendByUIDReq) (*Reply, error)

type UnsafeLogicServer 

type UnsafeLogicServer interface {
	// contains filtered or unexported methods
}

UnsafeLogicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogicServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.