src

Documentation

Index

• type Cnf
  • func (cnf *Cnf) Build(conf interface{})
  • func (cnf *Cnf) DoRunDiscover()
  • func (cnf *Cnf) GetPublicChanel() (string, map[string]chan map[string]interface{})
  • func (cnf *Cnf) Run(signal chan bool)
  • func (cnf *Cnf) RunWithPublicChanel(nodeChanels map[string]interface{}, signal chan bool)

Types

type Cnf

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

Cnf 整体对象

func (*Cnf) Build

func (cnf *Cnf) Build(conf interface{})

Build 主程序配置入口

func (*Cnf) DoRunDiscover

func (cnf *Cnf) DoRunDiscover()

DoRunDiscover 反射

func (*Cnf) GetPublicChanel

func (cnf *Cnf) GetPublicChanel() (string, map[string]chan map[string]interface{})

GetPublicChanel 获取公共消息chanel @return nodeID 节点唯一标识 @return publicChanel 节点的公共频道

func (*Cnf) Run

func (cnf *Cnf) Run(signal chan bool)

Run 主程序入口, 无公共Chanel的实现

func (*Cnf) RunWithPublicChanel

func (cnf *Cnf) RunWithPublicChanel(nodeChanels map[string]interface{}, signal chan bool)

RunWithPublicChanel 主程序入口, 有公共chanel实现的, 用于端口多路复用