workflowsupport

Documentation

Index

• func ProcessAsync[T any, U any](inputs []U, block func(u U) (T, error)) []T
• type WorkFinder
• type WorkScheduler
  • func NewScheduler(finder interface{}, workers []Worker, delay int64) WorkScheduler
  • func (ws *WorkScheduler) Start()
  • func (ws *WorkScheduler) Stop()
• type Worker

Functions

func ProcessAsync

func ProcessAsync[T any, U any](inputs []U, block func(u U) (T, error)) []T

Types

type WorkFinder

type WorkFinder interface {
	FindRequested() []interface{}
	MarkCompleted()
	MarkErroneous()
	Stop()
}

type WorkScheduler

type WorkScheduler struct {
	Finder  interface{}
	Workers []Worker
	Delay   int64
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(finder interface{}, workers []Worker, delay int64) WorkScheduler

func (*WorkScheduler) Start

func (ws *WorkScheduler) Start()

func (*WorkScheduler) Stop

func (ws *WorkScheduler) Stop()

type Worker

type Worker interface {
	Run(interface{}) error
}