api

Jul 5, 2017

Changes in this version

+ type CMDBroker struct

+ func NewCMDBroker(cmds []string, cmdRunner CMDRunner, timeout time.Duration, logger log.Modular, ...) *CMDBroker

+ func (b *CMDBroker) Close(time.Duration)

+ func (b *CMDBroker) NewEmitter(username, uuid string, e Emitter)

+ type CMDRunner interface

+ CMDRun func(cmd string) (stdout, stderr []byte, err error)

Jun 21, 2017

Changes in this version

+ type CuratorSession struct

+ func NewCuratorSession(username, uuid string, emitter Emitter, cur curator.Type, ...) *CuratorSession

+ type Emitter interface

+ OnClose func(eventHandler EventHandler)

+ OnReceive func(reqType string, handler RequestHandler)

+ OnSend func(resType string, handler ResponseHandler)

+ Send func(resType string, body interface{}) error

+ type EventHandler func()

+ type GlobalMetadataBroker struct

+ func NewGlobalMetadataBroker(timeout time.Duration, logger log.Modular, stats metrics.Aggregator) *GlobalMetadataBroker

+ func (b *GlobalMetadataBroker) NewEmitter(username, uuid string, e Emitter)

+ type RequestHandler func(body []byte) events.TypedError

+ type ResponseHandler func(body interface{}) bool