watcherjob

package
v0.0.0-...-5c79d48 Latest Latest
Warning

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

Go to latest
Published: Feb 15, 2024 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultMaxConcurrency   = 128
	DefaultEventFuncTimeout = time.Second * 5
)

Variables

This section is empty.

Functions

func NewJob

func NewJob(client teleport.Client, config Config, fn EventFunc) (lib.ServiceJob, error)

func NewJobWithEvents

func NewJobWithEvents(events types.Events, config Config, fn EventFunc) (lib.ServiceJob, error)

Types

type Config

type Config struct {
	Watch            types.Watch
	MaxConcurrency   int
	EventFuncTimeout time.Duration
	FailFast         bool
}

type EventFunc

type EventFunc func(context.Context, types.Event) error

Jump to

Keyboard shortcuts

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