gate

Documentation

Overview

Package gate is a generated protocol buffer package.

It is generated from these files:

gate.proto

It has these top-level messages:

AllResponse

Index

• Variables
• type AllResponse
  • func (*AllResponse) Descriptor() ([]byte, []int)
  • func (m *AllResponse) GetMsg() string
  • func (m *AllResponse) GetResult() []byte
  • func (m *AllResponse) GetState() int32
  • func (*AllResponse) ProtoMessage()
  • func (m *AllResponse) Reset()
  • func (m *AllResponse) String() string
• type Gate
  • func (m *Gate) GetExecuting() int64
  • func (m *Gate) GetType() string
  • func (m *Gate) KickOut(userId string)
  • func (m *Gate) OnConnect(sess *sessions.Session)
  • func (m *Gate) OnDestroy()
  • func (m *Gate) OnDisConnect(sess *sessions.Session)
  • func (m *Gate) OnInit(app module.App, settings *conf.ModuleSettings)
  • func (m *Gate) OnNewMessage(msg *message.PublishMessage, sess *sessions.Session) bool
  • func (m *Gate) PushMessage(userId string, item *base.PushItem)
  • func (m *Gate) PushMessagef(userId string, item *base.PushItem)
  • func (m *Gate) Run(closeSig chan bool)
  • func (m *Gate) SetOnConnectCallBack(callback module.ConnectEventCallBack)
  • func (m *Gate) SetOnDisConnectCallBack(callback module.ConnectEventCallBack)
  • func (m *Gate) Version() string
  • func (m *Gate) WriteMsg(topic []byte, body []byte, packetId uint16, sess *sessions.Session) error
• type MsgFormat

Variables

var Module = func() module.Module {
	newGate := new(Gate)
	return newGate
}

var RPC_PARAM_SESSION_TYPE = "SESSION"

Types

type AllResponse

type AllResponse struct {
	// 结果
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// 错误结果 如果为nil表示请求正确
	Msg string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
	// 错误代码 0 means right
	State int32 `protobuf:"varint,3,opt,name=state" json:"state,omitempty"`
}

func (*AllResponse) Descriptor

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

func (*AllResponse) GetMsg

func (m *AllResponse) GetMsg() string

func (*AllResponse) GetResult

func (m *AllResponse) GetResult() []byte

func (*AllResponse) GetState

func (m *AllResponse) GetState() int32

func (*AllResponse) ProtoMessage

func (*AllResponse) ProtoMessage()

func (*AllResponse) Reset

func (m *AllResponse) Reset()

func (*AllResponse) String

func (m *AllResponse) String() string

type Gate

type Gate struct {
	basemodule.BaseModule
	// contains filtered or unexported fields
}

func (*Gate) GetExecuting

func (m *Gate) GetExecuting() int64

func (*Gate) GetType

func (m *Gate) GetType() string

func (*Gate) KickOut

func (m *Gate) KickOut(userId string)

func (*Gate) OnConnect

func (m *Gate) OnConnect(sess *sessions.Session)

func (*Gate) OnDestroy

func (m *Gate) OnDestroy()

func (*Gate) OnDisConnect

func (m *Gate) OnDisConnect(sess *sessions.Session)

func (*Gate) OnInit

func (m *Gate) OnInit(app module.App, settings *conf.ModuleSettings)

func (*Gate) OnNewMessage

func (m *Gate) OnNewMessage(msg *message.PublishMessage, sess *sessions.Session) bool

func (*Gate) PushMessage

func (m *Gate) PushMessage(userId string, item *base.PushItem)

func (*Gate) PushMessagef

func (m *Gate) PushMessagef(userId string, item *base.PushItem)

func (*Gate) Run

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

func (*Gate) SetOnConnectCallBack

func (m *Gate) SetOnConnectCallBack(callback module.ConnectEventCallBack)

func (*Gate) SetOnDisConnectCallBack

func (m *Gate) SetOnDisConnectCallBack(callback module.ConnectEventCallBack)

func (*Gate) Version

func (m *Gate) Version() string

func (*Gate) WriteMsg

func (m *Gate) WriteMsg(topic []byte, body []byte, packetId uint16, sess *sessions.Session) error

type MsgFormat

type MsgFormat struct {
	Module string      `json:"module"`
	Func   string      `json:"func"`
	Params interface{} `json:"params"`
}