distribution

Documentation

Index

• Variables
• func GetDistInst(e *types.EventInst) []types.DistInst
• func SaveEventDone(event *types.EventInstCtx) (err error)
• func SendCallback(receiver *types.Subscription, event string) (err error)
• func Start() error
• func StartDistribute() (err error)
• func StartHandleInsts() (err error)
• func SubscribeChannel(config map[string]string) (err error)

Variables

var (
	ERR_WAIT_TIMEOUT   = fmt.Errorf("wait timeout")
	ERR_PROCESS_EXISTS = fmt.Errorf("process exists")
)

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)