comag

Documentation

Index

• func DemoCoA(ctx context.Context)
• func DemoCoB(ctx context.Context)
• type CoFunc
• type CtlRater
  • func (ctl *CtlRater) Start()
• type FailAllFailCoMag
  • func NewFailAllFailCoMag() *FailAllFailCoMag
  • func (mg *FailAllFailCoMag) Add(f CoFunc)
  • func (mg *FailAllFailCoMag) Run()
• type StopNotifyWorker
  • func (w *StopNotifyWorker) Stop()
  • func (w *StopNotifyWorker) StopNotify() chan bool
• type StopWorker
  • func (w *StopWorker) Start()
  • func (w *StopWorker) Stop()
  • func (w *StopWorker) Stopped() bool

Functions

func DemoCoA

func DemoCoA(ctx context.Context)

func DemoCoB

func DemoCoB(ctx context.Context)

Types

type CoFunc

type CoFunc func(context.Context)

type CtlRater

type CtlRater struct {
	StopNotifyWorker

	Do   func()
	Rate int64

	v1log.InvokeLog
	// contains filtered or unexported fields
}

func (*CtlRater) Start

func (ctl *CtlRater) Start()

type FailAllFailCoMag

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

FailAllFailCoMag 一次失败全部失败的CoMag

func NewFailAllFailCoMag

func NewFailAllFailCoMag() *FailAllFailCoMag

func (*FailAllFailCoMag) Add

func (mg *FailAllFailCoMag) Add(f CoFunc)

func (*FailAllFailCoMag) Run

func (mg *FailAllFailCoMag) Run()

type StopNotifyWorker

type StopNotifyWorker struct {
	StopWorker
	// contains filtered or unexported fields
}

func (*StopNotifyWorker) Stop

func (w *StopNotifyWorker) Stop()

func (*StopNotifyWorker) StopNotify

func (w *StopNotifyWorker) StopNotify() chan bool

type StopWorker

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

func (*StopWorker) Start

func (w *StopWorker) Start()

func (*StopWorker) Stop

func (w *StopWorker) Stop()

func (*StopWorker) Stopped

func (w *StopWorker) Stopped() bool