comag

May 12, 2023

Changes in this version

+ type StopNotifyWorker struct

+ func (w *StopNotifyWorker) Stop()

+ func (w *StopNotifyWorker) StopNotify() chan bool

type StopWorker

+ func (w *StopWorker) Start()

Apr 10, 2023

Changes in this version

+ func DemoCoA(ctx context.Context)

+ func DemoCoB(ctx context.Context)

+ type CoFunc func(context.Context)

+ type CtlRater struct

+ Do func()

+ Rate int64

+ func (ctl *CtlRater) Start()

+ type FailAllFailCoMag struct

+ func NewFailAllFailCoMag() *FailAllFailCoMag

+ func (mg *FailAllFailCoMag) Add(f CoFunc)

+ func (mg *FailAllFailCoMag) Run()

+ type StopWorker struct

+ func (w *StopWorker) Stop()

+ func (w *StopWorker) StopNotify() chan bool

+ func (w *StopWorker) Stopped() bool