logic

package
v0.0.0-...-99399ff Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2018 License: Apache-2.0 Imports: 14 Imported by: 0

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 Logger

type Logger struct {
	*log.Logger
	io.ReadWriteCloser
}

func NewLogger

func NewLogger(path, prefix string) (*Logger, error)

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

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(confpath string) (*Server, error)

func (*Server) Run

func (this *Server) Run() error

func (*Server) Stop

func (this *Server) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL