delayedwork

Documentation

Index

• type DelayedWorkFunc
• type DelayedWorkManager
  • func NewDelayedWorkManager() *DelayedWorkManager
  • func (dwm *DelayedWorkManager) Start(ctx context.Context)
  • func (dwm *DelayedWorkManager) Submit(ctx context.Context, req DelayedWorkRequest)
• type DelayedWorkRequest

Types

type DelayedWorkFunc

type DelayedWorkFunc func(context.Context)

type DelayedWorkManager

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

func NewDelayedWorkManager

func NewDelayedWorkManager() *DelayedWorkManager

func (*DelayedWorkManager) Start

func (dwm *DelayedWorkManager) Start(ctx context.Context)

func (*DelayedWorkManager) Submit

func (dwm *DelayedWorkManager) Submit(ctx context.Context, req DelayedWorkRequest)

type DelayedWorkRequest

type DelayedWorkRequest struct {
	ID        string
	SoftDelay time.Duration
	HardDelay time.Duration
	Func      DelayedWorkFunc
}

DelayedWorkRequest serves as an argument to DelayedWorkManager.Submit

ID should be unique among works managed here

Every submit of the same work as identified by ID will be delayed for at most SoftDelay time

Func will be called after either SoftDelay since each submit, or HardDelay since first submit, whichever comes first