distribution

Documentation

Index

• Variables
• func Start(cache *redis.Client, db storage.DI) error
• func SubscribeChannel(redisCli *redis.Client) (err error)
• type DistHandler
  • func (dh *DistHandler) SendCallback(receiver *metadata.Subscription, event string) (err error)
  • func (dh *DistHandler) StartDistribute() (err error)
• type EventHandler
  • func (eh *EventHandler) GetDistInst(e *metadata.EventInst) []metadata.DistInst
  • func (eh *EventHandler) SaveEventDone(event *metadata.EventInstCtx) (err error)
  • func (eh *EventHandler) StartHandleInsts() (err error)

Variables

var (
	ErrWaitTimeout   = fmt.Errorf("wait timeout")
	ErrProcessExists = fmt.Errorf("process exists")
)

Err define

var MsgChan = make(chan string, 3)

Functions

func Start

func Start(cache *redis.Client, db storage.DI) error

func SubscribeChannel

func SubscribeChannel(redisCli *redis.Client) (err error)

Types

type DistHandler

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

func (*DistHandler) SendCallback

func (dh *DistHandler) SendCallback(receiver *metadata.Subscription, event string) (err error)

func (*DistHandler) StartDistribute

func (dh *DistHandler) StartDistribute() (err error)

type EventHandler

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

func (*EventHandler) GetDistInst

func (eh *EventHandler) GetDistInst(e *metadata.EventInst) []metadata.DistInst

func (*EventHandler) SaveEventDone

func (eh *EventHandler) SaveEventDone(event *metadata.EventInstCtx) (err error)

func (*EventHandler) StartHandleInsts

func (eh *EventHandler) StartHandleInsts() (err error)