comag

package
v1.1.45 Latest Latest
Warning

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

Go to latest
Published: Feb 18, 2024 License: GPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v1.1.44

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

func (*StopNotifyWorker) Stop added in v1.1.44

func (w *StopNotifyWorker) Stop()

func (*StopNotifyWorker) StopNotify added in v1.1.44

func (w *StopNotifyWorker) StopNotify() chan bool

type StopWorker

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

func (*StopWorker) Start added in v1.1.44

func (w *StopWorker) Start()

func (*StopWorker) Stop

func (w *StopWorker) Stop()

func (*StopWorker) Stopped

func (w *StopWorker) Stopped() bool

Jump to

Keyboard shortcuts

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