Documentation ¶
Index ¶
- Constants
- Variables
- type CmdMsg
- func (*CmdMsg) Descriptor() ([]byte, []int)
- func (m *CmdMsg) GetData() []byte
- func (m *CmdMsg) GetRunRoutineNum() int64
- func (*CmdMsg) ProtoMessage()
- func (m *CmdMsg) Reset()
- func (m *CmdMsg) String() string
- func (m *CmdMsg) XXX_DiscardUnknown()
- func (m *CmdMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CmdMsg) XXX_Merge(src proto.Message)
- func (m *CmdMsg) XXX_Size() int
- func (m *CmdMsg) XXX_Unmarshal(b []byte) error
- type Config
- type ConnectorConfig
- type LogConfig
- type MasterConfig
- type Natsconfig
- type ServersConfig
- type TSession
- func (*TSession) Descriptor() ([]byte, []int)
- func (m *TSession) GetBody() []byte
- func (m *TSession) GetCid() string
- func (m *TSession) GetDstSubRouter() string
- func (m *TSession) GetLogicBindId() string
- func (m *TSession) GetReplyToken() string
- func (m *TSession) GetRouter() string
- func (m *TSession) GetRpcRespCode() int32
- func (m *TSession) GetSrcSubRouter() string
- func (m *TSession) GetSt() TSessionSessionType
- func (*TSession) ProtoMessage()
- func (m *TSession) Reset()
- func (m *TSession) String() string
- func (m *TSession) XXX_DiscardUnknown()
- func (m *TSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TSession) XXX_Merge(src proto.Message)
- func (m *TSession) XXX_Size() int
- func (m *TSession) XXX_Unmarshal(b []byte) error
- type TSessionSessionType
Constants ¶
View Source
const ( CMD_PING string = "ping" CMD_MEM string = "mem" )
Variables ¶
View Source
var TSessionSessionType_name = map[int32]string{
0: "CONNECTOR",
1: "LOGIC",
2: "CMD",
}
View Source
var TSessionSessionType_value = map[string]int32{
"CONNECTOR": 0,
"LOGIC": 1,
"CMD": 2,
}
Functions ¶
This section is empty.
Types ¶
type CmdMsg ¶
type CmdMsg struct { RunRoutineNum int64 `protobuf:"varint,1,opt,name=runRoutineNum,proto3" json:"runRoutineNum,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CmdMsg) Descriptor ¶
func (*CmdMsg) GetRunRoutineNum ¶
func (*CmdMsg) ProtoMessage ¶
func (*CmdMsg) ProtoMessage()
func (*CmdMsg) XXX_DiscardUnknown ¶
func (m *CmdMsg) XXX_DiscardUnknown()
func (*CmdMsg) XXX_Marshal ¶
func (*CmdMsg) XXX_Unmarshal ¶
type Config ¶
type Config struct { Natsconf Natsconfig `json:"natsconfig"` MasterConf MasterConfig `json:"master"` LogConf LogConfig `json:"log"` Connector []*ConnectorConfig `json:"connector"` Servers []*ServersConfig `json:"servers"` // contains filtered or unexported fields }
func (*Config) GetConConfByServerId ¶
func (c *Config) GetConConfByServerId(serverId string) *ConnectorConfig
func (*Config) GetMasterConf ¶
func (c *Config) GetMasterConf() *MasterConfig
func (*Config) GetServerByType ¶
func (c *Config) GetServerByType(serverType string) []*ServersConfig
func (*Config) GetServerConfByServerId ¶
func (c *Config) GetServerConfByServerId(serverId string) *ServersConfig
type ConnectorConfig ¶
type MasterConfig ¶
type Natsconfig ¶
type ServersConfig ¶
type TSession ¶
type TSession struct { Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` SrcSubRouter string `protobuf:"bytes,2,opt,name=srcSubRouter,proto3" json:"srcSubRouter,omitempty"` DstSubRouter string `protobuf:"bytes,3,opt,name=dstSubRouter,proto3" json:"dstSubRouter,omitempty"` Body []byte `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"` St TSessionSessionType `protobuf:"varint,5,opt,name=st,proto3,enum=config.TSessionSessionType" json:"st,omitempty"` ReplyToken string `protobuf:"bytes,6,opt,name=replyToken,proto3" json:"replyToken,omitempty"` Router string `protobuf:"bytes,7,opt,name=router,proto3" json:"router,omitempty"` LogicBindId string `protobuf:"bytes,8,opt,name=logicBindId,proto3" json:"logicBindId,omitempty"` RpcRespCode int32 `protobuf:"varint,9,opt,name=rpcRespCode,proto3" json:"rpcRespCode,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TSession) Descriptor ¶
func (*TSession) GetDstSubRouter ¶
func (*TSession) GetLogicBindId ¶
func (*TSession) GetReplyToken ¶
func (*TSession) GetRpcRespCode ¶
func (*TSession) GetSrcSubRouter ¶
func (*TSession) GetSt ¶
func (m *TSession) GetSt() TSessionSessionType
func (*TSession) ProtoMessage ¶
func (*TSession) ProtoMessage()
func (*TSession) XXX_DiscardUnknown ¶
func (m *TSession) XXX_DiscardUnknown()
func (*TSession) XXX_Marshal ¶
func (*TSession) XXX_Unmarshal ¶
type TSessionSessionType ¶
type TSessionSessionType int32
const ( TSession_CONNECTOR TSessionSessionType = 0 TSession_LOGIC TSessionSessionType = 1 TSession_CMD TSessionSessionType = 2 )
func (TSessionSessionType) EnumDescriptor ¶
func (TSessionSessionType) EnumDescriptor() ([]byte, []int)
func (TSessionSessionType) String ¶
func (x TSessionSessionType) String() string
Click to show internal directories.
Click to hide internal directories.