worker

Documentation

Index

• func InitWorkerServer()
• func InvokeObjectMethod(object interface{}, methodName string) interface{}
• func Invoker(conn *net.TCPConn, req_obj *protocol.ReqRoot) interface{}
• func WorkerServer(host string, port int)
• type WorkerConfigType

Functions

func InitWorkerServer

func InitWorkerServer()

初始化worker服务

func InvokeObjectMethod

func InvokeObjectMethod(object interface{}, methodName string) interface{}

func Invoker

func Invoker(conn *net.TCPConn, req_obj *protocol.ReqRoot) interface{}

func WorkerServer

func WorkerServer(host string, port int)

*

• 监听客户端连接

Types

type WorkerConfigType

type WorkerConfigType struct {
	Loglevel   string     `toml:"loglevel"`
	SingleMode bool       `toml:"single_mode"`
	Servers    [][]string `toml:"servers"`
	ToHub      []string   `toml:"connect_to_hub"`
}

var WorkerConfig WorkerConfigType