Documentation ¶
Index ¶
- Variables
- func RegisterLogicServer(s *grpc.Server, srv LogicServer)
- type Backoff
- func (*Backoff) Descriptor() ([]byte, []int)
- func (m *Backoff) GetBaseDelay() int32
- func (m *Backoff) GetFactor() float32
- func (m *Backoff) GetJitter() float32
- func (m *Backoff) GetMaxDelay() int32
- func (*Backoff) ProtoMessage()
- func (m *Backoff) Reset()
- func (m *Backoff) String() string
- func (m *Backoff) XXX_DiscardUnknown()
- func (m *Backoff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Backoff) XXX_Merge(src proto.Message)
- func (m *Backoff) XXX_Size() int
- func (m *Backoff) XXX_Unmarshal(b []byte) error
- type ConnectReply
- func (*ConnectReply) Descriptor() ([]byte, []int)
- func (m *ConnectReply) GetAccepts() []int32
- func (m *ConnectReply) GetHeartbeat() int64
- func (m *ConnectReply) GetKey() string
- func (m *ConnectReply) GetMid() int64
- func (m *ConnectReply) GetRoomID() string
- func (*ConnectReply) ProtoMessage()
- func (m *ConnectReply) Reset()
- func (m *ConnectReply) String() string
- func (m *ConnectReply) XXX_DiscardUnknown()
- func (m *ConnectReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectReply) XXX_Merge(src proto.Message)
- func (m *ConnectReply) XXX_Size() int
- func (m *ConnectReply) XXX_Unmarshal(b []byte) error
- type ConnectReq
- func (*ConnectReq) Descriptor() ([]byte, []int)
- func (m *ConnectReq) GetCookie() string
- func (m *ConnectReq) GetServer() string
- func (m *ConnectReq) GetToken() []byte
- func (*ConnectReq) ProtoMessage()
- func (m *ConnectReq) Reset()
- func (m *ConnectReq) String() string
- func (m *ConnectReq) XXX_DiscardUnknown()
- func (m *ConnectReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectReq) XXX_Merge(src proto.Message)
- func (m *ConnectReq) XXX_Size() int
- func (m *ConnectReq) XXX_Unmarshal(b []byte) error
- type DisconnectReply
- func (*DisconnectReply) Descriptor() ([]byte, []int)
- func (m *DisconnectReply) GetHas() bool
- func (*DisconnectReply) ProtoMessage()
- func (m *DisconnectReply) Reset()
- func (m *DisconnectReply) String() string
- func (m *DisconnectReply) XXX_DiscardUnknown()
- func (m *DisconnectReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DisconnectReply) XXX_Merge(src proto.Message)
- func (m *DisconnectReply) XXX_Size() int
- func (m *DisconnectReply) XXX_Unmarshal(b []byte) error
- type DisconnectReq
- func (*DisconnectReq) Descriptor() ([]byte, []int)
- func (m *DisconnectReq) GetKey() string
- func (m *DisconnectReq) GetMid() int64
- func (m *DisconnectReq) GetServer() string
- func (*DisconnectReq) ProtoMessage()
- func (m *DisconnectReq) Reset()
- func (m *DisconnectReq) String() string
- func (m *DisconnectReq) XXX_DiscardUnknown()
- func (m *DisconnectReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DisconnectReq) XXX_Merge(src proto.Message)
- func (m *DisconnectReq) XXX_Size() int
- func (m *DisconnectReq) XXX_Unmarshal(b []byte) error
- type HeartbeatReply
- func (*HeartbeatReply) Descriptor() ([]byte, []int)
- func (*HeartbeatReply) ProtoMessage()
- func (m *HeartbeatReply) Reset()
- func (m *HeartbeatReply) String() string
- func (m *HeartbeatReply) XXX_DiscardUnknown()
- func (m *HeartbeatReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatReply) XXX_Merge(src proto.Message)
- func (m *HeartbeatReply) XXX_Size() int
- func (m *HeartbeatReply) XXX_Unmarshal(b []byte) error
- type HeartbeatReq
- func (*HeartbeatReq) Descriptor() ([]byte, []int)
- func (m *HeartbeatReq) GetKey() string
- func (m *HeartbeatReq) GetMid() int64
- func (m *HeartbeatReq) GetServer() string
- func (*HeartbeatReq) ProtoMessage()
- func (m *HeartbeatReq) Reset()
- func (m *HeartbeatReq) String() string
- func (m *HeartbeatReq) XXX_DiscardUnknown()
- func (m *HeartbeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatReq) XXX_Merge(src proto.Message)
- func (m *HeartbeatReq) XXX_Size() int
- func (m *HeartbeatReq) XXX_Unmarshal(b []byte) error
- type LogicClient
- type LogicServer
- type NodesReply
- func (*NodesReply) Descriptor() ([]byte, []int)
- func (m *NodesReply) GetBackoff() *Backoff
- func (m *NodesReply) GetDomain() string
- func (m *NodesReply) GetHeartbeat() int32
- func (m *NodesReply) GetHeartbeatMax() int32
- func (m *NodesReply) GetNodes() []string
- func (m *NodesReply) GetTcpPort() int32
- func (m *NodesReply) GetWsPort() int32
- func (m *NodesReply) GetWssPort() int32
- func (*NodesReply) ProtoMessage()
- func (m *NodesReply) Reset()
- func (m *NodesReply) String() string
- func (m *NodesReply) XXX_DiscardUnknown()
- func (m *NodesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodesReply) XXX_Merge(src proto.Message)
- func (m *NodesReply) XXX_Size() int
- func (m *NodesReply) XXX_Unmarshal(b []byte) error
- type NodesReq
- func (*NodesReq) Descriptor() ([]byte, []int)
- func (m *NodesReq) GetClientIP() string
- func (m *NodesReq) GetPlatform() string
- func (*NodesReq) ProtoMessage()
- func (m *NodesReq) Reset()
- func (m *NodesReq) String() string
- func (m *NodesReq) XXX_DiscardUnknown()
- func (m *NodesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodesReq) XXX_Merge(src proto.Message)
- func (m *NodesReq) XXX_Size() int
- func (m *NodesReq) XXX_Unmarshal(b []byte) error
- type OnlineReply
- func (*OnlineReply) Descriptor() ([]byte, []int)
- func (m *OnlineReply) GetAllRoomCount() map[string]int32
- func (*OnlineReply) ProtoMessage()
- func (m *OnlineReply) Reset()
- func (m *OnlineReply) String() string
- func (m *OnlineReply) XXX_DiscardUnknown()
- func (m *OnlineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OnlineReply) XXX_Merge(src proto.Message)
- func (m *OnlineReply) XXX_Size() int
- func (m *OnlineReply) XXX_Unmarshal(b []byte) error
- type OnlineReq
- func (*OnlineReq) Descriptor() ([]byte, []int)
- func (m *OnlineReq) GetRoomCount() map[string]int32
- func (m *OnlineReq) GetServer() string
- func (*OnlineReq) ProtoMessage()
- func (m *OnlineReq) Reset()
- func (m *OnlineReq) String() string
- func (m *OnlineReq) XXX_DiscardUnknown()
- func (m *OnlineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OnlineReq) XXX_Merge(src proto.Message)
- func (m *OnlineReq) XXX_Size() int
- func (m *OnlineReq) XXX_Unmarshal(b []byte) error
- type PushMsg
- func (*PushMsg) Descriptor() ([]byte, []int)
- func (m *PushMsg) GetKeys() []string
- func (m *PushMsg) GetMsg() []byte
- func (m *PushMsg) GetOperation() int32
- func (m *PushMsg) GetRoom() string
- func (m *PushMsg) GetServer() string
- func (m *PushMsg) GetSpeed() int32
- func (m *PushMsg) GetType() PushMsg_Type
- func (*PushMsg) ProtoMessage()
- func (m *PushMsg) Reset()
- func (m *PushMsg) String() string
- func (m *PushMsg) XXX_DiscardUnknown()
- func (m *PushMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushMsg) XXX_Merge(src proto.Message)
- func (m *PushMsg) XXX_Size() int
- func (m *PushMsg) XXX_Unmarshal(b []byte) error
- type PushMsg_Type
- type ReceiveReply
- func (*ReceiveReply) Descriptor() ([]byte, []int)
- func (*ReceiveReply) ProtoMessage()
- func (m *ReceiveReply) Reset()
- func (m *ReceiveReply) String() string
- func (m *ReceiveReply) XXX_DiscardUnknown()
- func (m *ReceiveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReceiveReply) XXX_Merge(src proto.Message)
- func (m *ReceiveReply) XXX_Size() int
- func (m *ReceiveReply) XXX_Unmarshal(b []byte) error
- type ReceiveReq
- func (*ReceiveReq) Descriptor() ([]byte, []int)
- func (m *ReceiveReq) GetMid() int64
- func (m *ReceiveReq) GetProto() *protocol.Proto
- func (*ReceiveReq) ProtoMessage()
- func (m *ReceiveReq) Reset()
- func (m *ReceiveReq) String() string
- func (m *ReceiveReq) XXX_DiscardUnknown()
- func (m *ReceiveReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReceiveReq) XXX_Merge(src proto.Message)
- func (m *ReceiveReq) XXX_Size() int
- func (m *ReceiveReq) XXX_Unmarshal(b []byte) error
- type UnimplementedLogicServer
- func (*UnimplementedLogicServer) Connect(ctx context.Context, req *ConnectReq) (*ConnectReply, error)
- func (*UnimplementedLogicServer) Disconnect(ctx context.Context, req *DisconnectReq) (*DisconnectReply, error)
- func (*UnimplementedLogicServer) Heartbeat(ctx context.Context, req *HeartbeatReq) (*HeartbeatReply, error)
- func (*UnimplementedLogicServer) Nodes(ctx context.Context, req *NodesReq) (*NodesReply, error)
- func (*UnimplementedLogicServer) Receive(ctx context.Context, req *ReceiveReq) (*ReceiveReply, error)
- func (*UnimplementedLogicServer) RenewOnline(ctx context.Context, req *OnlineReq) (*OnlineReply, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var PushMsg_Type_name = map[int32]string{
0: "PUSH",
1: "ROOM",
2: "BROADCAST",
}
View Source
var PushMsg_Type_value = map[string]int32{
"PUSH": 0,
"ROOM": 1,
"BROADCAST": 2,
}
Functions ¶
func RegisterLogicServer ¶
func RegisterLogicServer(s *grpc.Server, srv LogicServer)
Types ¶
type Backoff ¶
type Backoff struct { MaxDelay int32 `protobuf:"varint,1,opt,name=max_delay,json=maxDelay,proto3" json:"max_delay,omitempty"` BaseDelay int32 `protobuf:"varint,2,opt,name=base_delay,json=baseDelay,proto3" json:"base_delay,omitempty"` Factor float32 `protobuf:"fixed32,3,opt,name=factor,proto3" json:"factor,omitempty"` Jitter float32 `protobuf:"fixed32,4,opt,name=jitter,proto3" json:"jitter,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Backoff) Descriptor ¶
func (*Backoff) GetBaseDelay ¶
func (*Backoff) GetMaxDelay ¶
func (*Backoff) ProtoMessage ¶
func (*Backoff) ProtoMessage()
func (*Backoff) XXX_DiscardUnknown ¶
func (m *Backoff) XXX_DiscardUnknown()
func (*Backoff) XXX_Marshal ¶
func (*Backoff) XXX_Unmarshal ¶
type ConnectReply ¶
type ConnectReply struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` RoomID string `protobuf:"bytes,3,opt,name=roomID,proto3" json:"roomID,omitempty"` Accepts []int32 `protobuf:"varint,4,rep,packed,name=accepts,proto3" json:"accepts,omitempty"` Heartbeat int64 `protobuf:"varint,5,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectReply) Descriptor ¶
func (*ConnectReply) Descriptor() ([]byte, []int)
func (*ConnectReply) GetAccepts ¶
func (m *ConnectReply) GetAccepts() []int32
func (*ConnectReply) GetHeartbeat ¶
func (m *ConnectReply) GetHeartbeat() int64
func (*ConnectReply) GetKey ¶
func (m *ConnectReply) GetKey() string
func (*ConnectReply) GetMid ¶
func (m *ConnectReply) GetMid() int64
func (*ConnectReply) GetRoomID ¶
func (m *ConnectReply) GetRoomID() string
func (*ConnectReply) ProtoMessage ¶
func (*ConnectReply) ProtoMessage()
func (*ConnectReply) Reset ¶
func (m *ConnectReply) Reset()
func (*ConnectReply) String ¶
func (m *ConnectReply) String() string
func (*ConnectReply) XXX_DiscardUnknown ¶
func (m *ConnectReply) XXX_DiscardUnknown()
func (*ConnectReply) XXX_Marshal ¶
func (m *ConnectReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectReply) XXX_Merge ¶
func (m *ConnectReply) XXX_Merge(src proto.Message)
func (*ConnectReply) XXX_Size ¶
func (m *ConnectReply) XXX_Size() int
func (*ConnectReply) XXX_Unmarshal ¶
func (m *ConnectReply) XXX_Unmarshal(b []byte) error
type ConnectReq ¶
type ConnectReq struct { Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Cookie string `protobuf:"bytes,2,opt,name=cookie,proto3" json:"cookie,omitempty"` Token []byte `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnectReq) Descriptor ¶
func (*ConnectReq) Descriptor() ([]byte, []int)
func (*ConnectReq) GetCookie ¶
func (m *ConnectReq) GetCookie() string
func (*ConnectReq) GetServer ¶
func (m *ConnectReq) GetServer() string
func (*ConnectReq) GetToken ¶
func (m *ConnectReq) GetToken() []byte
func (*ConnectReq) ProtoMessage ¶
func (*ConnectReq) ProtoMessage()
func (*ConnectReq) Reset ¶
func (m *ConnectReq) Reset()
func (*ConnectReq) String ¶
func (m *ConnectReq) String() string
func (*ConnectReq) XXX_DiscardUnknown ¶
func (m *ConnectReq) XXX_DiscardUnknown()
func (*ConnectReq) XXX_Marshal ¶
func (m *ConnectReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectReq) XXX_Merge ¶
func (m *ConnectReq) XXX_Merge(src proto.Message)
func (*ConnectReq) XXX_Size ¶
func (m *ConnectReq) XXX_Size() int
func (*ConnectReq) XXX_Unmarshal ¶
func (m *ConnectReq) XXX_Unmarshal(b []byte) error
type DisconnectReply ¶
type DisconnectReply struct { Has bool `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DisconnectReply) Descriptor ¶
func (*DisconnectReply) Descriptor() ([]byte, []int)
func (*DisconnectReply) GetHas ¶
func (m *DisconnectReply) GetHas() bool
func (*DisconnectReply) ProtoMessage ¶
func (*DisconnectReply) ProtoMessage()
func (*DisconnectReply) Reset ¶
func (m *DisconnectReply) Reset()
func (*DisconnectReply) String ¶
func (m *DisconnectReply) String() string
func (*DisconnectReply) XXX_DiscardUnknown ¶
func (m *DisconnectReply) XXX_DiscardUnknown()
func (*DisconnectReply) XXX_Marshal ¶
func (m *DisconnectReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisconnectReply) XXX_Merge ¶
func (m *DisconnectReply) XXX_Merge(src proto.Message)
func (*DisconnectReply) XXX_Size ¶
func (m *DisconnectReply) XXX_Size() int
func (*DisconnectReply) XXX_Unmarshal ¶
func (m *DisconnectReply) XXX_Unmarshal(b []byte) error
type DisconnectReq ¶
type DisconnectReq struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Server string `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DisconnectReq) Descriptor ¶
func (*DisconnectReq) Descriptor() ([]byte, []int)
func (*DisconnectReq) GetKey ¶
func (m *DisconnectReq) GetKey() string
func (*DisconnectReq) GetMid ¶
func (m *DisconnectReq) GetMid() int64
func (*DisconnectReq) GetServer ¶
func (m *DisconnectReq) GetServer() string
func (*DisconnectReq) ProtoMessage ¶
func (*DisconnectReq) ProtoMessage()
func (*DisconnectReq) Reset ¶
func (m *DisconnectReq) Reset()
func (*DisconnectReq) String ¶
func (m *DisconnectReq) String() string
func (*DisconnectReq) XXX_DiscardUnknown ¶
func (m *DisconnectReq) XXX_DiscardUnknown()
func (*DisconnectReq) XXX_Marshal ¶
func (m *DisconnectReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisconnectReq) XXX_Merge ¶
func (m *DisconnectReq) XXX_Merge(src proto.Message)
func (*DisconnectReq) XXX_Size ¶
func (m *DisconnectReq) XXX_Size() int
func (*DisconnectReq) XXX_Unmarshal ¶
func (m *DisconnectReq) XXX_Unmarshal(b []byte) error
type HeartbeatReply ¶
type HeartbeatReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatReply) Descriptor ¶
func (*HeartbeatReply) Descriptor() ([]byte, []int)
func (*HeartbeatReply) ProtoMessage ¶
func (*HeartbeatReply) ProtoMessage()
func (*HeartbeatReply) Reset ¶
func (m *HeartbeatReply) Reset()
func (*HeartbeatReply) String ¶
func (m *HeartbeatReply) String() string
func (*HeartbeatReply) XXX_DiscardUnknown ¶
func (m *HeartbeatReply) XXX_DiscardUnknown()
func (*HeartbeatReply) XXX_Marshal ¶
func (m *HeartbeatReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatReply) XXX_Merge ¶
func (m *HeartbeatReply) XXX_Merge(src proto.Message)
func (*HeartbeatReply) XXX_Size ¶
func (m *HeartbeatReply) XXX_Size() int
func (*HeartbeatReply) XXX_Unmarshal ¶
func (m *HeartbeatReply) XXX_Unmarshal(b []byte) error
type HeartbeatReq ¶
type HeartbeatReq struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Server string `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HeartbeatReq) Descriptor ¶
func (*HeartbeatReq) Descriptor() ([]byte, []int)
func (*HeartbeatReq) GetKey ¶
func (m *HeartbeatReq) GetKey() string
func (*HeartbeatReq) GetMid ¶
func (m *HeartbeatReq) GetMid() int64
func (*HeartbeatReq) GetServer ¶
func (m *HeartbeatReq) GetServer() string
func (*HeartbeatReq) ProtoMessage ¶
func (*HeartbeatReq) ProtoMessage()
func (*HeartbeatReq) Reset ¶
func (m *HeartbeatReq) Reset()
func (*HeartbeatReq) String ¶
func (m *HeartbeatReq) String() string
func (*HeartbeatReq) XXX_DiscardUnknown ¶
func (m *HeartbeatReq) XXX_DiscardUnknown()
func (*HeartbeatReq) XXX_Marshal ¶
func (m *HeartbeatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatReq) XXX_Merge ¶
func (m *HeartbeatReq) XXX_Merge(src proto.Message)
func (*HeartbeatReq) XXX_Size ¶
func (m *HeartbeatReq) XXX_Size() int
func (*HeartbeatReq) XXX_Unmarshal ¶
func (m *HeartbeatReq) XXX_Unmarshal(b []byte) error
type LogicClient ¶
type LogicClient interface { // Connect Connect(ctx context.Context, in *ConnectReq, opts ...grpc.CallOption) (*ConnectReply, error) // Disconnect Disconnect(ctx context.Context, in *DisconnectReq, opts ...grpc.CallOption) (*DisconnectReply, error) // Heartbeat Heartbeat(ctx context.Context, in *HeartbeatReq, opts ...grpc.CallOption) (*HeartbeatReply, error) // RenewOnline RenewOnline(ctx context.Context, in *OnlineReq, opts ...grpc.CallOption) (*OnlineReply, error) // Receive Receive(ctx context.Context, in *ReceiveReq, opts ...grpc.CallOption) (*ReceiveReply, error) //ServerList Nodes(ctx context.Context, in *NodesReq, opts ...grpc.CallOption) (*NodesReply, error) }
LogicClient is the client API for Logic service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogicClient ¶
func NewLogicClient(cc *grpc.ClientConn) LogicClient
type LogicServer ¶
type LogicServer interface { // Connect Connect(context.Context, *ConnectReq) (*ConnectReply, error) // Disconnect Disconnect(context.Context, *DisconnectReq) (*DisconnectReply, error) // Heartbeat Heartbeat(context.Context, *HeartbeatReq) (*HeartbeatReply, error) // RenewOnline RenewOnline(context.Context, *OnlineReq) (*OnlineReply, error) // Receive Receive(context.Context, *ReceiveReq) (*ReceiveReply, error) //ServerList Nodes(context.Context, *NodesReq) (*NodesReply, error) }
LogicServer is the server API for Logic service.
type NodesReply ¶
type NodesReply struct { Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` TcpPort int32 `protobuf:"varint,2,opt,name=tcp_port,json=tcpPort,proto3" json:"tcp_port,omitempty"` WsPort int32 `protobuf:"varint,3,opt,name=ws_port,json=wsPort,proto3" json:"ws_port,omitempty"` WssPort int32 `protobuf:"varint,4,opt,name=wss_port,json=wssPort,proto3" json:"wss_port,omitempty"` Heartbeat int32 `protobuf:"varint,5,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"` Nodes []string `protobuf:"bytes,6,rep,name=nodes,proto3" json:"nodes,omitempty"` Backoff *Backoff `protobuf:"bytes,7,opt,name=backoff,proto3" json:"backoff,omitempty"` HeartbeatMax int32 `protobuf:"varint,8,opt,name=heartbeat_max,json=heartbeatMax,proto3" json:"heartbeat_max,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodesReply) Descriptor ¶
func (*NodesReply) Descriptor() ([]byte, []int)
func (*NodesReply) GetBackoff ¶
func (m *NodesReply) GetBackoff() *Backoff
func (*NodesReply) GetDomain ¶
func (m *NodesReply) GetDomain() string
func (*NodesReply) GetHeartbeat ¶
func (m *NodesReply) GetHeartbeat() int32
func (*NodesReply) GetHeartbeatMax ¶
func (m *NodesReply) GetHeartbeatMax() int32
func (*NodesReply) GetNodes ¶
func (m *NodesReply) GetNodes() []string
func (*NodesReply) GetTcpPort ¶
func (m *NodesReply) GetTcpPort() int32
func (*NodesReply) GetWsPort ¶
func (m *NodesReply) GetWsPort() int32
func (*NodesReply) GetWssPort ¶
func (m *NodesReply) GetWssPort() int32
func (*NodesReply) ProtoMessage ¶
func (*NodesReply) ProtoMessage()
func (*NodesReply) Reset ¶
func (m *NodesReply) Reset()
func (*NodesReply) String ¶
func (m *NodesReply) String() string
func (*NodesReply) XXX_DiscardUnknown ¶
func (m *NodesReply) XXX_DiscardUnknown()
func (*NodesReply) XXX_Marshal ¶
func (m *NodesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodesReply) XXX_Merge ¶
func (m *NodesReply) XXX_Merge(src proto.Message)
func (*NodesReply) XXX_Size ¶
func (m *NodesReply) XXX_Size() int
func (*NodesReply) XXX_Unmarshal ¶
func (m *NodesReply) XXX_Unmarshal(b []byte) error
type NodesReq ¶
type NodesReq struct { Platform string `protobuf:"bytes,1,opt,name=platform,proto3" json:"platform,omitempty"` ClientIP string `protobuf:"bytes,2,opt,name=clientIP,proto3" json:"clientIP,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodesReq) Descriptor ¶
func (*NodesReq) GetClientIP ¶
func (*NodesReq) GetPlatform ¶
func (*NodesReq) ProtoMessage ¶
func (*NodesReq) ProtoMessage()
func (*NodesReq) XXX_DiscardUnknown ¶
func (m *NodesReq) XXX_DiscardUnknown()
func (*NodesReq) XXX_Marshal ¶
func (*NodesReq) XXX_Unmarshal ¶
type OnlineReply ¶
type OnlineReply struct { AllRoomCount map[string]int32 `` /* 166-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OnlineReply) Descriptor ¶
func (*OnlineReply) Descriptor() ([]byte, []int)
func (*OnlineReply) GetAllRoomCount ¶
func (m *OnlineReply) GetAllRoomCount() map[string]int32
func (*OnlineReply) ProtoMessage ¶
func (*OnlineReply) ProtoMessage()
func (*OnlineReply) Reset ¶
func (m *OnlineReply) Reset()
func (*OnlineReply) String ¶
func (m *OnlineReply) String() string
func (*OnlineReply) XXX_DiscardUnknown ¶
func (m *OnlineReply) XXX_DiscardUnknown()
func (*OnlineReply) XXX_Marshal ¶
func (m *OnlineReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OnlineReply) XXX_Merge ¶
func (m *OnlineReply) XXX_Merge(src proto.Message)
func (*OnlineReply) XXX_Size ¶
func (m *OnlineReply) XXX_Size() int
func (*OnlineReply) XXX_Unmarshal ¶
func (m *OnlineReply) XXX_Unmarshal(b []byte) error
type OnlineReq ¶
type OnlineReq struct { Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` RoomCount map[string]int32 `` /* 160-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OnlineReq) Descriptor ¶
func (*OnlineReq) GetRoomCount ¶
func (*OnlineReq) ProtoMessage ¶
func (*OnlineReq) ProtoMessage()
func (*OnlineReq) XXX_DiscardUnknown ¶
func (m *OnlineReq) XXX_DiscardUnknown()
func (*OnlineReq) XXX_Marshal ¶
func (*OnlineReq) XXX_Unmarshal ¶
type PushMsg ¶
type PushMsg struct { Type PushMsg_Type `protobuf:"varint,1,opt,name=type,proto3,enum=goim.logic.PushMsg_Type" json:"type,omitempty"` Operation int32 `protobuf:"varint,2,opt,name=operation,proto3" json:"operation,omitempty"` Speed int32 `protobuf:"varint,3,opt,name=speed,proto3" json:"speed,omitempty"` Server string `protobuf:"bytes,4,opt,name=server,proto3" json:"server,omitempty"` Room string `protobuf:"bytes,5,opt,name=room,proto3" json:"room,omitempty"` Keys []string `protobuf:"bytes,6,rep,name=keys,proto3" json:"keys,omitempty"` Msg []byte `protobuf:"bytes,7,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushMsg) Descriptor ¶
func (*PushMsg) GetOperation ¶
func (*PushMsg) GetType ¶
func (m *PushMsg) GetType() PushMsg_Type
func (*PushMsg) ProtoMessage ¶
func (*PushMsg) ProtoMessage()
func (*PushMsg) XXX_DiscardUnknown ¶
func (m *PushMsg) XXX_DiscardUnknown()
func (*PushMsg) XXX_Marshal ¶
func (*PushMsg) XXX_Unmarshal ¶
type PushMsg_Type ¶
type PushMsg_Type int32
const ( PushMsg_PUSH PushMsg_Type = 0 PushMsg_ROOM PushMsg_Type = 1 PushMsg_BROADCAST PushMsg_Type = 2 )
func (PushMsg_Type) EnumDescriptor ¶
func (PushMsg_Type) EnumDescriptor() ([]byte, []int)
func (PushMsg_Type) String ¶
func (x PushMsg_Type) String() string
type ReceiveReply ¶
type ReceiveReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReceiveReply) Descriptor ¶
func (*ReceiveReply) Descriptor() ([]byte, []int)
func (*ReceiveReply) ProtoMessage ¶
func (*ReceiveReply) ProtoMessage()
func (*ReceiveReply) Reset ¶
func (m *ReceiveReply) Reset()
func (*ReceiveReply) String ¶
func (m *ReceiveReply) String() string
func (*ReceiveReply) XXX_DiscardUnknown ¶
func (m *ReceiveReply) XXX_DiscardUnknown()
func (*ReceiveReply) XXX_Marshal ¶
func (m *ReceiveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReceiveReply) XXX_Merge ¶
func (m *ReceiveReply) XXX_Merge(src proto.Message)
func (*ReceiveReply) XXX_Size ¶
func (m *ReceiveReply) XXX_Size() int
func (*ReceiveReply) XXX_Unmarshal ¶
func (m *ReceiveReply) XXX_Unmarshal(b []byte) error
type ReceiveReq ¶
type ReceiveReq struct { Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"` Proto *protocol.Proto `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReceiveReq) Descriptor ¶
func (*ReceiveReq) Descriptor() ([]byte, []int)
func (*ReceiveReq) GetMid ¶
func (m *ReceiveReq) GetMid() int64
func (*ReceiveReq) GetProto ¶
func (m *ReceiveReq) GetProto() *protocol.Proto
func (*ReceiveReq) ProtoMessage ¶
func (*ReceiveReq) ProtoMessage()
func (*ReceiveReq) Reset ¶
func (m *ReceiveReq) Reset()
func (*ReceiveReq) String ¶
func (m *ReceiveReq) String() string
func (*ReceiveReq) XXX_DiscardUnknown ¶
func (m *ReceiveReq) XXX_DiscardUnknown()
func (*ReceiveReq) XXX_Marshal ¶
func (m *ReceiveReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReceiveReq) XXX_Merge ¶
func (m *ReceiveReq) XXX_Merge(src proto.Message)
func (*ReceiveReq) XXX_Size ¶
func (m *ReceiveReq) XXX_Size() int
func (*ReceiveReq) XXX_Unmarshal ¶
func (m *ReceiveReq) XXX_Unmarshal(b []byte) error
type UnimplementedLogicServer ¶
type UnimplementedLogicServer struct { }
UnimplementedLogicServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogicServer) Connect ¶
func (*UnimplementedLogicServer) Connect(ctx context.Context, req *ConnectReq) (*ConnectReply, error)
func (*UnimplementedLogicServer) Disconnect ¶
func (*UnimplementedLogicServer) Disconnect(ctx context.Context, req *DisconnectReq) (*DisconnectReply, error)
func (*UnimplementedLogicServer) Heartbeat ¶
func (*UnimplementedLogicServer) Heartbeat(ctx context.Context, req *HeartbeatReq) (*HeartbeatReply, error)
func (*UnimplementedLogicServer) Nodes ¶
func (*UnimplementedLogicServer) Nodes(ctx context.Context, req *NodesReq) (*NodesReply, error)
func (*UnimplementedLogicServer) Receive ¶
func (*UnimplementedLogicServer) Receive(ctx context.Context, req *ReceiveReq) (*ReceiveReply, error)
func (*UnimplementedLogicServer) RenewOnline ¶
func (*UnimplementedLogicServer) RenewOnline(ctx context.Context, req *OnlineReq) (*OnlineReply, error)
Click to show internal directories.
Click to hide internal directories.