watcherjob

Documentation

Index

• Constants
• func NewJob(client teleport.Client, config Config, fn EventFunc) (lib.ServiceJob, error)
• func NewJobWithEvents(events types.Events, config Config, fn EventFunc) (lib.ServiceJob, error)
• type Config
• type EventFunc

Constants

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

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