basegate

package
v0.0.0-...-6c6cd66 Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2018 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package basegate is a generated protocol buffer package.

It is generated from these files: 

session.proto

It has these top-level messages: 

Sessionpb

Index

Constants

This section is empty.

Variables

View Source 
var RPC_PARAM_ProtocolMarshal_TYPE = "ProtocolMarshal"
View Source 
var RPC_PARAM_SESSION_TYPE = "SESSION"

Functions

func Get_uuid 

func Get_uuid() string

func NewGateHandler 

func NewGateHandler(gate *Gate) gate.GateHandler

func NewMqttAgent 

func NewMqttAgent(module module.FullModule) *agent

func NewSession 

func NewSession(app module.AppInterface, data []byte) (gate.Session, error)

func NewSessionByMap 

func NewSessionByMap(app module.AppInterface, data map[string]interface{}) (gate.Session, error)

func RandInt64 

func RandInt64(min, max int64) int64

函　数：生成随机数 概　要： 参　数： 

min: 最小值
max: 最大值

返回值： 

int64: 生成的随机数

func TimeNow 

func TimeNow() time.Time

func TransNumToString 

func TransNumToString(num int64) (string, error)

func TransStringToNum 

func TransStringToNum(str string) (int64, error)

Types

type Gate 

type Gate struct {
	//module.RPCSerialize
	basemodule.BaseModule
	MaxConnNum          int
	MaxMsgLen           uint32
	MinStorageHeartbeat int64 //Session持久化最短心跳包

	// websocket
	WSAddr      string
	HTTPTimeout time.Duration

	// tcp
	TCPAddr string

	//tls
	Tls      bool
	CertFile string
	KeyFile  string
	// contains filtered or unexported fields
}

func (*Gate) DefaultCreateAgent 

func (this *Gate) DefaultCreateAgent() gate.Agent

func (*Gate) Deserialize 

func (this *Gate) Deserialize(ptype string, b []byte) (param interface{}, err error)

func (*Gate) GetAgentLearner 

func (this *Gate) GetAgentLearner() gate.AgentLearner

func (*Gate) GetGateHandler 

func (this *Gate) GetGateHandler() gate.GateHandler

func (*Gate) GetMinStorageHeartbeat 

func (this *Gate) GetMinStorageHeartbeat() int64

func (*Gate) GetSessionLearner 

func (this *Gate) GetSessionLearner() gate.SessionLearner

func (*Gate) GetStorageHandler 

func (this *Gate) GetStorageHandler() gate.StorageHandler

func (*Gate) GetTracingHandler 

func (this *Gate) GetTracingHandler() gate.TracingHandler

func (*Gate) GetType 

func (gate *Gate) GetType() string

func (*Gate) GetTypes 

func (this *Gate) GetTypes() []string

func (*Gate) NewSession 

func (this *Gate) NewSession(data []byte) (gate.Session, error)

func (*Gate) NewSessionByMap 

func (this *Gate) NewSessionByMap(data map[string]interface{}) (gate.Session, error)

func (*Gate) OnDestroy 

func (this *Gate) OnDestroy()

func (*Gate) OnInit 

func (this *Gate) OnInit(app module.AppInterface, module module.FullModule, settings *conf.ModuleSettings)

func (*Gate) Run 

func (this *Gate) Run(closeSig chan bool)

func (*Gate) Serialize 

func (this *Gate) Serialize(param interface{}) (ptype string, p []byte, err error)

* 自定义rpc参数序列化反序列化 Session

func (*Gate) SetAgentLearner 

func (this *Gate) SetAgentLearner(agentLearner gate.AgentLearner) error

func (*Gate) SetCreateAgent 

func (this *Gate) SetCreateAgent(cfunc func() gate.Agent) error

* 设置创建客户端Agent的函数

func (*Gate) SetGateHandler 

func (this *Gate) SetGateHandler(gateHandler gate.GateHandler) error

func (*Gate) SetSessionLearner 

func (this *Gate) SetSessionLearner(sessionLearner gate.SessionLearner) error

* 设置客户端连接和断开的监听器

func (*Gate) SetStorageHandler 

func (this *Gate) SetStorageHandler(storageHandler gate.StorageHandler) error

* 设置Session信息持久化接口

func (*Gate) SetTracingHandler 

func (this *Gate) SetTracingHandler(tracingHandler gate.TracingHandler) error

func (*Gate) Version 

func (gate *Gate) Version() string

type Sessionpb 

type Sessionpb struct {
	IP        string            `protobuf:"bytes,1,opt,name=IP" json:"IP,omitempty"`
	Network   string            `protobuf:"bytes,2,opt,name=Network" json:"Network,omitempty"`
	Userid    string            `protobuf:"bytes,3,opt,name=Userid" json:"Userid,omitempty"`
	Sessionid string            `protobuf:"bytes,4,opt,name=Sessionid" json:"Sessionid,omitempty"`
	Serverid  string            `protobuf:"bytes,5,opt,name=Serverid" json:"Serverid,omitempty"`
	Settings  map[string]string `` /* 136-byte string literal not displayed */
	Carrier   map[string]string `` /* 134-byte string literal not displayed */
	Token     string            `protobuf:"bytes,8,opt,name=Token" json:"Token,omitempty"`
}

func (*Sessionpb) Descriptor 

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

func (*Sessionpb) GetCarrier 

func (m *Sessionpb) GetCarrier() map[string]string

func (*Sessionpb) GetIP 

func (m *Sessionpb) GetIP() string

func (*Sessionpb) GetNetwork 

func (m *Sessionpb) GetNetwork() string

func (*Sessionpb) GetServerid 

func (m *Sessionpb) GetServerid() string

func (*Sessionpb) GetSessionid 

func (m *Sessionpb) GetSessionid() string

func (*Sessionpb) GetSettings 

func (m *Sessionpb) GetSettings() map[string]string

func (*Sessionpb) GetToken 

func (m *Sessionpb) GetToken() string

func (*Sessionpb) GetUserid 

func (m *Sessionpb) GetUserid() string

func (*Sessionpb) ProtoMessage 

func (*Sessionpb) ProtoMessage()

func (*Sessionpb) Reset 

func (m *Sessionpb) Reset()

func (*Sessionpb) String 

func (m *Sessionpb) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.