grpc

package
v0.0.0-...-9b43e00 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)
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=MaxDelay,proto3" json:"max_delay"`
	BaseDelay            int32    `protobuf:"varint,2,opt,name=BaseDelay,proto3" json:"base_delay"`
	Factor               float32  `protobuf:"fixed32,3,opt,name=Factor,proto3" json:"factor"`
	Jitter               float32  `protobuf:"fixed32,4,opt,name=Jitter,proto3" json:"jitter"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Backoff) Descriptor 

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

func (*Backoff) GetBaseDelay 

func (m *Backoff) GetBaseDelay() int32

func (*Backoff) GetFactor 

func (m *Backoff) GetFactor() float32

func (*Backoff) GetJitter 

func (m *Backoff) GetJitter() float32

func (*Backoff) GetMaxDelay 

func (m *Backoff) GetMaxDelay() int32

func (*Backoff) Marshal 

func (m *Backoff) Marshal() (dAtA []byte, err error)

func (*Backoff) MarshalTo 

func (m *Backoff) MarshalTo(dAtA []byte) (int, error)

func (*Backoff) ProtoMessage 

func (*Backoff) ProtoMessage()

func (*Backoff) Reset 

func (m *Backoff) Reset()

func (*Backoff) Size 

func (m *Backoff) Size() (n int)

func (*Backoff) String 

func (m *Backoff) String() string

func (*Backoff) Unmarshal 

func (m *Backoff) Unmarshal(dAtA []byte) error

func (*Backoff) XXX_DiscardUnknown 

func (m *Backoff) XXX_DiscardUnknown()

func (*Backoff) XXX_Marshal 

func (m *Backoff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Backoff) XXX_Merge 

func (dst *Backoff) XXX_Merge(src proto.Message)

func (*Backoff) XXX_Size 

func (m *Backoff) XXX_Size() int

func (*Backoff) XXX_Unmarshal 

func (m *Backoff) XXX_Unmarshal(b []byte) error

type CloseReply 

type CloseReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseReply) Descriptor 

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

func (*CloseReply) Marshal 

func (m *CloseReply) Marshal() (dAtA []byte, err error)

func (*CloseReply) MarshalTo 

func (m *CloseReply) MarshalTo(dAtA []byte) (int, error)

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) Reset 

func (m *CloseReply) Reset()

func (*CloseReply) Size 

func (m *CloseReply) Size() (n int)

func (*CloseReply) String 

func (m *CloseReply) String() string

func (*CloseReply) Unmarshal 

func (m *CloseReply) Unmarshal(dAtA []byte) error

func (*CloseReply) XXX_DiscardUnknown 

func (m *CloseReply) XXX_DiscardUnknown()

func (*CloseReply) XXX_Marshal 

func (m *CloseReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseReply) XXX_Merge 

func (dst *CloseReply) XXX_Merge(src proto.Message)

func (*CloseReply) XXX_Size 

func (m *CloseReply) XXX_Size() int

func (*CloseReply) XXX_Unmarshal 

func (m *CloseReply) XXX_Unmarshal(b []byte) error

type CloseReq 

type CloseReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseReq) Descriptor 

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

func (*CloseReq) Marshal 

func (m *CloseReq) Marshal() (dAtA []byte, err error)

func (*CloseReq) MarshalTo 

func (m *CloseReq) MarshalTo(dAtA []byte) (int, error)

func (*CloseReq) ProtoMessage 

func (*CloseReq) ProtoMessage()

func (*CloseReq) Reset 

func (m *CloseReq) Reset()

func (*CloseReq) Size 

func (m *CloseReq) Size() (n int)

func (*CloseReq) String 

func (m *CloseReq) String() string

func (*CloseReq) Unmarshal 

func (m *CloseReq) Unmarshal(dAtA []byte) error

func (*CloseReq) XXX_DiscardUnknown 

func (m *CloseReq) XXX_DiscardUnknown()

func (*CloseReq) XXX_Marshal 

func (m *CloseReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseReq) XXX_Merge 

func (dst *CloseReq) XXX_Merge(src proto.Message)

func (*CloseReq) XXX_Size 

func (m *CloseReq) XXX_Size() int

func (*CloseReq) XXX_Unmarshal 

func (m *CloseReq) XXX_Unmarshal(b []byte) error

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" 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) Marshal 

func (m *ConnectReply) Marshal() (dAtA []byte, err error)

func (*ConnectReply) MarshalTo 

func (m *ConnectReply) MarshalTo(dAtA []byte) (int, error)

func (*ConnectReply) ProtoMessage 

func (*ConnectReply) ProtoMessage()

func (*ConnectReply) Reset 

func (m *ConnectReply) Reset()

func (*ConnectReply) Size 

func (m *ConnectReply) Size() (n int)

func (*ConnectReply) String 

func (m *ConnectReply) String() string

func (*ConnectReply) Unmarshal 

func (m *ConnectReply) Unmarshal(dAtA []byte) error

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 (dst *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) Marshal 

func (m *ConnectReq) Marshal() (dAtA []byte, err error)

func (*ConnectReq) MarshalTo 

func (m *ConnectReq) MarshalTo(dAtA []byte) (int, error)

func (*ConnectReq) ProtoMessage 

func (*ConnectReq) ProtoMessage()

func (*ConnectReq) Reset 

func (m *ConnectReq) Reset()

func (*ConnectReq) Size 

func (m *ConnectReq) Size() (n int)

func (*ConnectReq) String 

func (m *ConnectReq) String() string

func (*ConnectReq) Unmarshal 

func (m *ConnectReq) Unmarshal(dAtA []byte) error

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 (dst *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) Marshal 

func (m *DisconnectReply) Marshal() (dAtA []byte, err error)

func (*DisconnectReply) MarshalTo 

func (m *DisconnectReply) MarshalTo(dAtA []byte) (int, error)

func (*DisconnectReply) ProtoMessage 

func (*DisconnectReply) ProtoMessage()

func (*DisconnectReply) Reset 

func (m *DisconnectReply) Reset()

func (*DisconnectReply) Size 

func (m *DisconnectReply) Size() (n int)

func (*DisconnectReply) String 

func (m *DisconnectReply) String() string

func (*DisconnectReply) Unmarshal 

func (m *DisconnectReply) Unmarshal(dAtA []byte) error

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 (dst *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) Marshal 

func (m *DisconnectReq) Marshal() (dAtA []byte, err error)

func (*DisconnectReq) MarshalTo 

func (m *DisconnectReq) MarshalTo(dAtA []byte) (int, error)

func (*DisconnectReq) ProtoMessage 

func (*DisconnectReq) ProtoMessage()

func (*DisconnectReq) Reset 

func (m *DisconnectReq) Reset()

func (*DisconnectReq) Size 

func (m *DisconnectReq) Size() (n int)

func (*DisconnectReq) String 

func (m *DisconnectReq) String() string

func (*DisconnectReq) Unmarshal 

func (m *DisconnectReq) Unmarshal(dAtA []byte) error

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 (dst *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) Marshal 

func (m *HeartbeatReply) Marshal() (dAtA []byte, err error)

func (*HeartbeatReply) MarshalTo 

func (m *HeartbeatReply) MarshalTo(dAtA []byte) (int, error)

func (*HeartbeatReply) ProtoMessage 

func (*HeartbeatReply) ProtoMessage()

func (*HeartbeatReply) Reset 

func (m *HeartbeatReply) Reset()

func (*HeartbeatReply) Size 

func (m *HeartbeatReply) Size() (n int)

func (*HeartbeatReply) String 

func (m *HeartbeatReply) String() string

func (*HeartbeatReply) Unmarshal 

func (m *HeartbeatReply) Unmarshal(dAtA []byte) error

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 (dst *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) Marshal 

func (m *HeartbeatReq) Marshal() (dAtA []byte, err error)

func (*HeartbeatReq) MarshalTo 

func (m *HeartbeatReq) MarshalTo(dAtA []byte) (int, error)

func (*HeartbeatReq) ProtoMessage 

func (*HeartbeatReq) ProtoMessage()

func (*HeartbeatReq) Reset 

func (m *HeartbeatReq) Reset()

func (*HeartbeatReq) Size 

func (m *HeartbeatReq) Size() (n int)

func (*HeartbeatReq) String 

func (m *HeartbeatReq) String() string

func (*HeartbeatReq) Unmarshal 

func (m *HeartbeatReq) Unmarshal(dAtA []byte) error

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 (dst *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 {
	// Ping Service
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingReply, error)
	// Close Service
	Close(ctx context.Context, in *CloseReq, opts ...grpc.CallOption) (*CloseReply, error)
	// 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)
}

func NewLogicClient 

func NewLogicClient(cc *grpc.ClientConn) LogicClient

type LogicServer 

type LogicServer interface {
	// Ping Service
	Ping(context.Context, *PingReq) (*PingReply, error)
	// Close Service
	Close(context.Context, *CloseReq) (*CloseReply, error)
	// 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)
}

type NodesReply 

type NodesReply struct {
	Domain               string   `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain"`
	TcpPort              int32    `protobuf:"varint,2,opt,name=tcpPort,proto3" json:"tcp_port"`
	WsPort               int32    `protobuf:"varint,3,opt,name=wsPort,proto3" json:"ws_port"`
	WssPort              int32    `protobuf:"varint,4,opt,name=wssPort,proto3" json:"wss_port"`
	Heartbeat            int32    `protobuf:"varint,5,opt,name=heartbeat,proto3" json:"heartbeat"`
	Nodes                []string `protobuf:"bytes,6,rep,name=nodes" json:"nodes"`
	Backoff              *Backoff `protobuf:"bytes,7,opt,name=backoff" json:"backoff"`
	HeartbeatMax         int32    `protobuf:"varint,8,opt,name=heartbeatMax,proto3" json:"heartbeat_max"`
	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) Marshal 

func (m *NodesReply) Marshal() (dAtA []byte, err error)

func (*NodesReply) MarshalTo 

func (m *NodesReply) MarshalTo(dAtA []byte) (int, error)

func (*NodesReply) ProtoMessage 

func (*NodesReply) ProtoMessage()

func (*NodesReply) Reset 

func (m *NodesReply) Reset()

func (*NodesReply) Size 

func (m *NodesReply) Size() (n int)

func (*NodesReply) String 

func (m *NodesReply) String() string

func (*NodesReply) Unmarshal 

func (m *NodesReply) Unmarshal(dAtA []byte) error

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 (dst *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) Descriptor() ([]byte, []int)

func (*NodesReq) GetClientIP 

func (m *NodesReq) GetClientIP() string

func (*NodesReq) GetPlatform 

func (m *NodesReq) GetPlatform() string

func (*NodesReq) Marshal 

func (m *NodesReq) Marshal() (dAtA []byte, err error)

func (*NodesReq) MarshalTo 

func (m *NodesReq) MarshalTo(dAtA []byte) (int, error)

func (*NodesReq) ProtoMessage 

func (*NodesReq) ProtoMessage()

func (*NodesReq) Reset 

func (m *NodesReq) Reset()

func (*NodesReq) Size 

func (m *NodesReq) Size() (n int)

func (*NodesReq) String 

func (m *NodesReq) String() string

func (*NodesReq) Unmarshal 

func (m *NodesReq) Unmarshal(dAtA []byte) error

func (*NodesReq) XXX_DiscardUnknown 

func (m *NodesReq) XXX_DiscardUnknown()

func (*NodesReq) XXX_Marshal 

func (m *NodesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodesReq) XXX_Merge 

func (dst *NodesReq) XXX_Merge(src proto.Message)

func (*NodesReq) XXX_Size 

func (m *NodesReq) XXX_Size() int

func (*NodesReq) XXX_Unmarshal 

func (m *NodesReq) XXX_Unmarshal(b []byte) error

type OnlineReply 

type OnlineReply struct {
	AllRoomCount         map[string]int32 `` /* 159-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) Marshal 

func (m *OnlineReply) Marshal() (dAtA []byte, err error)

func (*OnlineReply) MarshalTo 

func (m *OnlineReply) MarshalTo(dAtA []byte) (int, error)

func (*OnlineReply) ProtoMessage 

func (*OnlineReply) ProtoMessage()

func (*OnlineReply) Reset 

func (m *OnlineReply) Reset()

func (*OnlineReply) Size 

func (m *OnlineReply) Size() (n int)

func (*OnlineReply) String 

func (m *OnlineReply) String() string

func (*OnlineReply) Unmarshal 

func (m *OnlineReply) Unmarshal(dAtA []byte) error

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 (dst *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 `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*OnlineReq) Descriptor 

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

func (*OnlineReq) GetRoomCount 

func (m *OnlineReq) GetRoomCount() map[string]int32

func (*OnlineReq) GetServer 

func (m *OnlineReq) GetServer() string

func (*OnlineReq) Marshal 

func (m *OnlineReq) Marshal() (dAtA []byte, err error)

func (*OnlineReq) MarshalTo 

func (m *OnlineReq) MarshalTo(dAtA []byte) (int, error)

func (*OnlineReq) ProtoMessage 

func (*OnlineReq) ProtoMessage()

func (*OnlineReq) Reset 

func (m *OnlineReq) Reset()

func (*OnlineReq) Size 

func (m *OnlineReq) Size() (n int)

func (*OnlineReq) String 

func (m *OnlineReq) String() string

func (*OnlineReq) Unmarshal 

func (m *OnlineReq) Unmarshal(dAtA []byte) error

func (*OnlineReq) XXX_DiscardUnknown 

func (m *OnlineReq) XXX_DiscardUnknown()

func (*OnlineReq) XXX_Marshal 

func (m *OnlineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OnlineReq) XXX_Merge 

func (dst *OnlineReq) XXX_Merge(src proto.Message)

func (*OnlineReq) XXX_Size 

func (m *OnlineReq) XXX_Size() int

func (*OnlineReq) XXX_Unmarshal 

func (m *OnlineReq) XXX_Unmarshal(b []byte) error

type PingReply 

type PingReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingReply) Descriptor 

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

func (*PingReply) Marshal 

func (m *PingReply) Marshal() (dAtA []byte, err error)

func (*PingReply) MarshalTo 

func (m *PingReply) MarshalTo(dAtA []byte) (int, error)

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) Reset 

func (m *PingReply) Reset()

func (*PingReply) Size 

func (m *PingReply) Size() (n int)

func (*PingReply) String 

func (m *PingReply) String() string

func (*PingReply) Unmarshal 

func (m *PingReply) Unmarshal(dAtA []byte) error

func (*PingReply) XXX_DiscardUnknown 

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal 

func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReply) XXX_Merge 

func (dst *PingReply) XXX_Merge(src proto.Message)

func (*PingReply) XXX_Size 

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal 

func (m *PingReply) XXX_Unmarshal(b []byte) error

type PingReq 

type PingReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingReq) Descriptor 

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

func (*PingReq) Marshal 

func (m *PingReq) Marshal() (dAtA []byte, err error)

func (*PingReq) MarshalTo 

func (m *PingReq) MarshalTo(dAtA []byte) (int, error)

func (*PingReq) ProtoMessage 

func (*PingReq) ProtoMessage()

func (*PingReq) Reset 

func (m *PingReq) Reset()

func (*PingReq) Size 

func (m *PingReq) Size() (n int)

func (*PingReq) String 

func (m *PingReq) String() string

func (*PingReq) Unmarshal 

func (m *PingReq) Unmarshal(dAtA []byte) error

func (*PingReq) XXX_DiscardUnknown 

func (m *PingReq) XXX_DiscardUnknown()

func (*PingReq) XXX_Marshal 

func (m *PingReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReq) XXX_Merge 

func (dst *PingReq) XXX_Merge(src proto.Message)

func (*PingReq) XXX_Size 

func (m *PingReq) XXX_Size() int

func (*PingReq) XXX_Unmarshal 

func (m *PingReq) XXX_Unmarshal(b []byte) error

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" 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) Descriptor() ([]byte, []int)

func (*PushMsg) GetKeys 

func (m *PushMsg) GetKeys() []string

func (*PushMsg) GetMsg 

func (m *PushMsg) GetMsg() []byte

func (*PushMsg) GetOperation 

func (m *PushMsg) GetOperation() int32

func (*PushMsg) GetRoom 

func (m *PushMsg) GetRoom() string

func (*PushMsg) GetServer 

func (m *PushMsg) GetServer() string

func (*PushMsg) GetSpeed 

func (m *PushMsg) GetSpeed() int32

func (*PushMsg) GetType 

func (m *PushMsg) GetType() PushMsg_Type

func (*PushMsg) Marshal 

func (m *PushMsg) Marshal() (dAtA []byte, err error)

func (*PushMsg) MarshalTo 

func (m *PushMsg) MarshalTo(dAtA []byte) (int, error)

func (*PushMsg) ProtoMessage 

func (*PushMsg) ProtoMessage()

func (*PushMsg) Reset 

func (m *PushMsg) Reset()

func (*PushMsg) Size 

func (m *PushMsg) Size() (n int)

func (*PushMsg) String 

func (m *PushMsg) String() string

func (*PushMsg) Unmarshal 

func (m *PushMsg) Unmarshal(dAtA []byte) error

func (*PushMsg) XXX_DiscardUnknown 

func (m *PushMsg) XXX_DiscardUnknown()

func (*PushMsg) XXX_Marshal 

func (m *PushMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushMsg) XXX_Merge 

func (dst *PushMsg) XXX_Merge(src proto.Message)

func (*PushMsg) XXX_Size 

func (m *PushMsg) XXX_Size() int

func (*PushMsg) XXX_Unmarshal 

func (m *PushMsg) XXX_Unmarshal(b []byte) error

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) Marshal 

func (m *ReceiveReply) Marshal() (dAtA []byte, err error)

func (*ReceiveReply) MarshalTo 

func (m *ReceiveReply) MarshalTo(dAtA []byte) (int, error)

func (*ReceiveReply) ProtoMessage 

func (*ReceiveReply) ProtoMessage()

func (*ReceiveReply) Reset 

func (m *ReceiveReply) Reset()

func (*ReceiveReply) Size 

func (m *ReceiveReply) Size() (n int)

func (*ReceiveReply) String 

func (m *ReceiveReply) String() string

func (*ReceiveReply) Unmarshal 

func (m *ReceiveReply) Unmarshal(dAtA []byte) error

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 (dst *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                *grpc1.Proto `protobuf:"bytes,2,opt,name=proto" 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() *grpc1.Proto

func (*ReceiveReq) Marshal 

func (m *ReceiveReq) Marshal() (dAtA []byte, err error)

func (*ReceiveReq) MarshalTo 

func (m *ReceiveReq) MarshalTo(dAtA []byte) (int, error)

func (*ReceiveReq) ProtoMessage 

func (*ReceiveReq) ProtoMessage()

func (*ReceiveReq) Reset 

func (m *ReceiveReq) Reset()

func (*ReceiveReq) Size 

func (m *ReceiveReq) Size() (n int)

func (*ReceiveReq) String 

func (m *ReceiveReq) String() string

func (*ReceiveReq) Unmarshal 

func (m *ReceiveReq) Unmarshal(dAtA []byte) error

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 (dst *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

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.