scheduler

package module

Go to main page

Versions in this module

v0

v0.3.0

Jun 24, 2021

Changes in this version

+ type DescriptorFunc func(ctx context.Context, pc chan<- Process) error

+ func (d DescriptorFunc) Run(ctx context.Context, pc chan<- Process) error

+ type RestartableDescriptor struct

+ func NewRestartableDescriptor(delegate Descriptor) (*RestartableDescriptor, func())

+ func (rd *RestartableDescriptor) Run(ctx context.Context, pc chan<- Process) error

v0.2.1

Feb 24, 2021

v0.2.0

Jan 6, 2021

Changes in this version

+ var DefaultRecoveryDescriptorBackoffFactory = backoff.Build(backoff.ResetAfter(...), backoff.MaxBound(10 * time.Second), ...)

+ type DescriptorError struct

+ Cause error

+ Descriptor Descriptor

+ func (e *DescriptorError) Error() string

+ type PanicError struct

+ Cause error

+ func (e *PanicError) Error() string

+ type ProcessError struct

+ Cause error

+ Process Process

+ Request *request.Request

+ func (e *ProcessError) Error() string

+ type RecoveryDescriptorOption interface

+ ApplyToRecoveryDescriptorOptions func(target *RecoveryDescriptorOptions)

+ func RecoveryDescriptorWithBackoffFactory(bf *backoff.Factory) RecoveryDescriptorOption

+ func RecoveryDescriptorWithClock(c clock.Clock) RecoveryDescriptorOption

+ type RecoveryDescriptorOptionFunc func(target *RecoveryDescriptorOptions)

+ func (rdof RecoveryDescriptorOptionFunc) ApplyToRecoveryDescriptorOptions(target *RecoveryDescriptorOptions)

type RecoveryDescriptorOptions

+ BackoffFactory *backoff.Factory

+ Clock clock.Clock

+ func (o *RecoveryDescriptorOptions) ApplyOptions(opts []RecoveryDescriptorOption)

v0.1.5

Dec 5, 2020

v0.1.4

Dec 5, 2020

v0.1.3

Dec 5, 2020

v0.1.2

Dec 5, 2020

v0.1.1

Dec 5, 2020

v0.1.0

Dec 4, 2020

Changes in this version

+ func CloseWaitContext(ctx context.Context, lc StartedLifecycle) error

+ func NewAdhocDescriptor() (*AdhocDescriptor, *AdhocSubmitter)

+ func WaitContext(ctx context.Context, lc StartedLifecycle) error

+ type AdhocDescriptor struct

+ func (ad *AdhocDescriptor) Run(ctx context.Context, pc chan<- Process) error

+ type AdhocSubmitter struct

+ func (as *AdhocSubmitter) QueueLen() int

+ func (as *AdhocSubmitter) Submit(p Process) <-chan error

+ type Descriptor interface

+ Run func(ctx context.Context, pc chan<- Process) error

+ type ErrorBehavior interface

+ NewHandler func() ErrorHandler

+ var ErrorBehaviorCollect ErrorBehavior = &errorBehaviorCollect{}

+ var ErrorBehaviorDrop ErrorBehavior = &errorBehaviorDrop{}

+ var ErrorBehaviorTerminate ErrorBehavior = &errorBehaviorTerminate{}

+ type ErrorHandler interface

+ Done func() <-chan struct{}

+ Errs func() []error

+ type ErrorReporter interface

+ Put func(err error)

+ type ImmediateDescriptor struct

+ func NewImmediateDescriptor(process Process) *ImmediateDescriptor

+ func (id *ImmediateDescriptor) Run(ctx context.Context, pc chan<- Process) error

+ type IntervalDescriptor struct

+ func NewIntervalDescriptor(interval time.Duration, process Process) *IntervalDescriptor

+ func (id *IntervalDescriptor) Run(ctx context.Context, pc chan<- Process) error

+ type Lifecycle interface

+ Start func(opts LifecycleStartOptions) StartedLifecycle

+ type LifecycleStartOptions struct

+ Capturer trackers.Capturer

+ type ManySchedulable interface

+ Len func() int

+ Run func(ctx context.Context, i int, er ErrorReporter)

+ func ManySchedulableDescriptor(ds []Descriptor, pc chan<- Process) ManySchedulable

+ func NManySchedulable(size int, delegate Schedulable) ManySchedulable

+ func OneSchedulable(s Schedulable) ManySchedulable

+ type ManySchedulableSlice []Schedulable

+ func (mss ManySchedulableSlice) Len() int

+ func (mss ManySchedulableSlice) Run(ctx context.Context, i int, er ErrorReporter)

+ type Parent struct

+ func NewParent(delegates ...Lifecycle) *Parent

+ func (p *Parent) Start(opts LifecycleStartOptions) StartedLifecycle

+ func (p *Parent) WithErrorBehavior(errorBehavior ErrorBehavior) *Parent

+ type Process interface

+ Description func() string

+ Run func(ctx context.Context) error

+ func DescribeProcessFunc(desc string, fn ProcessFunc) Process

+ type ProcessFunc func(ctx context.Context) error

+ func (ProcessFunc) Description() string

+ func (p ProcessFunc) Run(ctx context.Context) error

+ type RecoveryDescriptor struct

+ func NewRecoveryDescriptor(delegate Descriptor) *RecoveryDescriptor

+ func NewRecoveryDescriptorWithOptions(delegate Descriptor, opts RecoveryDescriptorOptions) *RecoveryDescriptor

+ func (rd *RecoveryDescriptor) Run(ctx context.Context, pc chan<- Process) error

+ type RecoveryDescriptorOptions struct

+ BackoffMultiplier time.Duration

+ MaxRetries int

+ ResetRetriesAfter time.Duration

+ type RepeatingDescriptor struct

+ func NewRepeatingDescriptor(process Process) *RepeatingDescriptor

+ func (rd *RepeatingDescriptor) Run(ctx context.Context, pc chan<- Process) error

+ type Schedulable interface

+ Run func(ctx context.Context, er ErrorReporter)

+ func SchedulableDescriptor(d Descriptor, pc chan<- Process) Schedulable

+ func SchedulableLifecycle(l Lifecycle, opts LifecycleStartOptions) Schedulable

+ func SchedulableProcess(p Process) Schedulable

+ type SchedulableFunc func(ctx context.Context, er ErrorReporter)

+ func (sf SchedulableFunc) Run(ctx context.Context, er ErrorReporter)

+ type Scheduler struct

+ func NewScheduler(children ManySchedulable) *Scheduler

+ func (s *Scheduler) Start(opts LifecycleStartOptions) StartedLifecycle

+ func (s *Scheduler) WithErrorBehavior(behavior ErrorBehavior) *Scheduler

+ func (s *Scheduler) WithEventHandler(handler SchedulerEventHandler) *Scheduler

+ type SchedulerEventHandler interface

+ OnDone func()

+ type SchedulerEventHandlerFuncs struct

+ OnDoneFunc func()

+ func (sehf *SchedulerEventHandlerFuncs) OnDone()

+ type Segment struct

+ func NewSegment(concurrency int, descriptors []Descriptor) *Segment

+ func (s *Segment) Start(opts LifecycleStartOptions) StartedLifecycle

+ func (s *Segment) WithDescriptorErrorBehavior(behavior ErrorBehavior) *Segment

+ func (s *Segment) WithErrorBehavior(behavior ErrorBehavior) *Segment

+ func (s *Segment) WithProcessErrorBehavior(behavior ErrorBehavior) *Segment

+ type StartedLifecycle interface

+ Close func()

+ Done func() <-chan struct{}

+ Errs func() []error

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