distribution

package
v3.0.8-rc.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 12, 2018 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ERR_WAIT_TIMEOUT   = fmt.Errorf("wait timeout")
	ERR_PROCESS_EXISTS = fmt.Errorf("process exists")
)
View Source
var MsgChan = make(chan string, 3)

Functions

func GetDistInst

func GetDistInst(e *types.EventInst) []types.DistInst

func SaveEventDone

func SaveEventDone(event *types.EventInstCtx) (err error)

func SendCallback

func SendCallback(receiver *types.Subscription, event string) (err error)

func Start

func Start() error

func StartDistribute

func StartDistribute() (err error)

func StartHandleInsts

func StartHandleInsts() (err error)

StartHandleInsts distribute events to distribute queue

func SubscribeChannel

func SubscribeChannel(config map[string]string) (err error)

Types

This section is empty.

Jump to

Keyboard shortcuts

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