runner

package

Go to main page

Versions in this module

v1

v1.1.0

Mar 18, 2025 GO-2026-4447

GO-2026-4447: OpenCloud Affected by Public Link Exploit in github.com/opencloud-eu/opencloud

v1.1.0-alpha.4

Mar 18, 2025 GO-2026-4447

GO-2026-4447: OpenCloud Affected by Public Link Exploit in github.com/opencloud-eu/opencloud

v1.1.0-alpha.3

Mar 18, 2025 GO-2026-4447

GO-2026-4447: OpenCloud Affected by Public Link Exploit in github.com/opencloud-eu/opencloud

v1.1.0-alpha.2

Mar 18, 2025 GO-2026-4447

GO-2026-4447: OpenCloud Affected by Public Link Exploit in github.com/opencloud-eu/opencloud

v1.1.0-alpha.1

Mar 14, 2025 GO-2026-4447

GO-2026-4447: OpenCloud Affected by Public Link Exploit in github.com/opencloud-eu/opencloud

v1.0.0

Feb 24, 2025 GO-2026-4447

GO-2026-4447: OpenCloud Affected by Public Link Exploit in github.com/opencloud-eu/opencloud

Changes in this version

+ var DefaultGroupInterruptDuration = 15 * time.Second

+ var DefaultInterruptDuration = 10 * time.Second

+ type GroupRunner struct

+ func NewGroup(opts ...Option) *GroupRunner

+ func (gr *GroupRunner) Add(r *Runner)

+ func (gr *GroupRunner) Interrupt()

+ func (gr *GroupRunner) Run(ctx context.Context) []*Result

+ func (gr *GroupRunner) RunAsync(ch chan<- *Result)

+ type Option func(o *Options)

+ func WithInterruptDuration(val time.Duration) Option

+ type Options struct

+ InterruptDuration time.Duration

+ type Result struct

+ RunnerError error

+ RunnerID string

+ type Runable func() error

+ type Runner struct

+ ID string

+ func New(id string, fn Runable, interrupt Stopper, opts ...Option) *Runner

+ func (r *Runner) Finished() <-chan struct{}

+ func (r *Runner) Interrupt()

+ func (r *Runner) Run(ctx context.Context) *Result

+ func (r *Runner) RunAsync(ch chan<- *Result)

+ type Stopper func()

+ type TimeoutError struct

+ Duration time.Duration

+ RunnerID string

+ func NewGroupTimeoutError(duration time.Duration) *TimeoutError

+ func NewTimeoutError(runnerID string, duration time.Duration) *TimeoutError

+ func (te *TimeoutError) Error() string

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