logic

package
v0.0.0-...-1800484 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2022 License: MIT Imports: 8 Imported by: 3

Documentation

Index

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

func (*Backoff) ProtoMessage()

func (*Backoff) Reset 

func (m *Backoff) Reset()

func (*Backoff) String 

func (m *Backoff) String() string

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

func (*NodesReq) GetClientIP 

func (m *NodesReq) GetClientIP() string

func (*NodesReq) GetPlatform 

func (m *NodesReq) GetPlatform() string

func (*NodesReq) ProtoMessage 

func (*NodesReq) ProtoMessage()

func (*NodesReq) Reset 

func (m *NodesReq) Reset()

func (*NodesReq) String 

func (m *NodesReq) String() string

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

func (*OnlineReq) GetRoomCount 

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

func (*OnlineReq) GetServer 

func (m *OnlineReq) GetServer() string

func (*OnlineReq) ProtoMessage 

func (*OnlineReq) ProtoMessage()

func (*OnlineReq) Reset 

func (m *OnlineReq) Reset()

func (*OnlineReq) String 

func (m *OnlineReq) String() string

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 (m *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 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) 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) ProtoMessage 

func (*PushMsg) ProtoMessage()

func (*PushMsg) Reset 

func (m *PushMsg) Reset()

func (*PushMsg) String 

func (m *PushMsg) String() string

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 (m *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) 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)

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.