Documentation ¶
Overview ¶
Package logic is a generated protocol buffer package.
It is generated from these files:
logic.proto
It has these top-level messages:
MessageRequest ReceiveReply
Index ¶
Constants ¶
View Source
const ( MaxRedisConnIdle = 1000 MaxRedisConnActive = 0 RedisConnIdleTimeout = time.Minute * 10 RedisConnectTimeout = time.Second * 10 RedisReadTimeout = time.Second * 10 RedisWriteTimeout = time.Second * 10 )
View Source
const (
LOGIC_USERAGENT = "klein logic v0.0.1"
)
Variables ¶
This section is empty.
Functions ¶
func RegisterLogicServer ¶
func RegisterLogicServer(s *grpc.Server, srv LogicServer)
Types ¶
type LogicClient ¶
type LogicClient interface {
ReceiveMessage(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*ReceiveReply, error)
}
func NewLogicClient ¶
func NewLogicClient(cc *grpc.ClientConn) LogicClient
type LogicServer ¶
type LogicServer interface {
ReceiveMessage(context.Context, *MessageRequest) (*ReceiveReply, error)
}
type LogicServerSide ¶
type LogicServerSide struct {
// contains filtered or unexported fields
}
func (*LogicServerSide) ReceiveMessage ¶
func (this *LogicServerSide) ReceiveMessage(ctx context.Context, req *MessageRequest) (*ReceiveReply, error)
type MessageRequest ¶
type MessageRequest struct { MsgType int32 `protobuf:"varint,1,opt,name=MsgType,json=msgType" json:"MsgType,omitempty"` SequenceId string `protobuf:"bytes,2,opt,name=SequenceId,json=sequenceId" json:"SequenceId,omitempty"` ConnId string `protobuf:"bytes,3,opt,name=ConnId,json=connId" json:"ConnId,omitempty"` Sender string `protobuf:"bytes,4,opt,name=Sender,json=sender" json:"Sender,omitempty"` Receiver string `protobuf:"bytes,5,opt,name=Receiver,json=receiver" json:"Receiver,omitempty"` Body string `protobuf:"bytes,6,opt,name=Body,json=body" json:"Body,omitempty"` }
func (*MessageRequest) Descriptor ¶
func (*MessageRequest) Descriptor() ([]byte, []int)
func (*MessageRequest) ProtoMessage ¶
func (*MessageRequest) ProtoMessage()
func (*MessageRequest) Reset ¶
func (m *MessageRequest) Reset()
func (*MessageRequest) String ¶
func (m *MessageRequest) String() string
type OfflineStore ¶
type OfflineStore struct {
// contains filtered or unexported fields
}
func NewOfflineStore ¶
func NewOfflineStore(ctx *Server) *OfflineStore
func (*OfflineStore) Get ¶
func (this *OfflineStore) Get(key string) ([]*MessageRequest, error)
func (*OfflineStore) Put ¶
func (this *OfflineStore) Put(key string, m *MessageRequest) error
func (*OfflineStore) Remove ¶
func (this *OfflineStore) Remove(key string) error
func (*OfflineStore) Stop ¶
func (this *OfflineStore) Stop()
type ReceiveReply ¶
type ReceiveReply struct { Status bool `protobuf:"varint,1,opt,name=Status,json=status" json:"Status,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,json=message" json:"Message,omitempty"` }
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
Click to show internal directories.
Click to hide internal directories.