publish

package
v0.0.0-...-057d967 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 2016 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Pub

func Pub(cfg *Config)

Pub 执行Publish操作

Types

type Config

type Config struct {
	ExecNum                int    // 执行次数
	Interval               int    // 发布间隔
	UserInterval           int    // 组成员发包间隔(单位毫秒)
	UserGroupInterval      int    // 组成员针对组的发包间隔(单位毫秒)
	AutoReconnect          bool   // 自动重连
	DisconnectScale        int    // 发送完成之后,断开客户端的比例
	IsStore                bool   // 是否执行持久化存储
	SendPacketStoreNum     int    // 发包一次性写入数据量
	SendPacketBucketNum    int    // 发包临时存储使用容器的数量
	ReceivePacketStoreNum  int    // 接包一次性写入数据量
	ReceivePacketBucketNum int    // 接包临时存储使用容器的数量
	MongoUrl               string // MongoDB连接
	Network                string
	Address                string
	Qos                    byte
	UserName               string
	Password               string
	CleanSession           bool
	KeepAlive              int
}

type HandleConnect

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

func NewHandleConnect

func NewHandleConnect(clientID string, pub *Publish) *HandleConnect

func (*HandleConnect) ErrorHandle

func (hc *HandleConnect) ErrorHandle(err error)

func (*HandleConnect) Subscribe

func (hc *HandleConnect) Subscribe(topicName, message []byte)

type Publish

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

func (*Publish) DB

func (p *Publish) DB() *mgo.Database

func (*Publish) ExecPublish

func (p *Publish) ExecPublish()

func (*Publish) Init

func (p *Publish) Init() error

Jump to

Keyboard shortcuts

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