Documentation
¶
Overview ¶
Copyright 2014 mqant Author. All Rights Reserved.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2014 mqant Author. All Rights Reserved.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2014 mqant Author. All Rights Reserved.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2014 mqant Author. All Rights Reserved.
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Package gate is a generated protocol buffer package.
It is generated from these files:
session/session.proto
It has these top-level messages:
Session
Index ¶
- Variables
- func Get_uuid() string
- func NewGateHandler(gate *Gate) *handler
- func NewSession(app module.App, data []byte) (gate.Session, error)
- func NewSessionByMap(app module.App, data map[string]interface{}) (gate.Session, error)
- func RandInt64(min, max int64) int64
- func TimeNow() time.Time
- func TransNumToString(num int64) (string, error)
- func TransStringToNum(str string) (int64, error)
- type Gate
- func (this *Gate) Deserialize(ptype string, b []byte) (param interface{}, err error)
- func (this *Gate) GetStorageHandler() (storage gate.StorageHandler)
- func (this *Gate) GetTypes() []string
- func (this *Gate) OnAppConfigurationLoaded(app module.App)
- func (this *Gate) OnConfChanged(settings *conf.ModuleSettings)
- func (this *Gate) OnDestroy()
- func (this *Gate) OnInit(subclass module.RPCModule, app module.App, settings *conf.ModuleSettings)
- func (this *Gate) Run(closeSig chan bool)
- func (this *Gate) Serialize(param interface{}) (ptype string, p []byte, err error)
- func (this *Gate) SetSessionLearner(sessionLearner gate.SessionLearner) error
- func (this *Gate) SetStorageHandler(storage gate.StorageHandler) error
- func (this *Gate) SetTracingHandler(tracing gate.TracingHandler) error
Constants ¶
This section is empty.
Variables ¶
var RPC_PARAM_SESSION_TYPE = "SESSION"
Functions ¶
func NewGateHandler ¶
func NewGateHandler(gate *Gate) *handler
func NewSessionByMap ¶
func TransNumToString ¶
func TransStringToNum ¶
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) Deserialize ¶
func (*Gate) GetStorageHandler ¶
func (this *Gate) GetStorageHandler() (storage gate.StorageHandler)
func (*Gate) OnAppConfigurationLoaded ¶
func (*Gate) OnConfChanged ¶
func (this *Gate) OnConfChanged(settings *conf.ModuleSettings)
func (*Gate) SetSessionLearner ¶
func (this *Gate) SetSessionLearner(sessionLearner gate.SessionLearner) error
* 设置客户端连接和断开的监听器
func (*Gate) SetStorageHandler ¶
func (this *Gate) SetStorageHandler(storage gate.StorageHandler) error
* 设置Session信息持久化接口
func (*Gate) SetTracingHandler ¶
func (this *Gate) SetTracingHandler(tracing gate.TracingHandler) error
* 设置Session信息持久化接口
Source Files
Directories