lib

Documentation

Index

• func Update(request sub.UpdateRequest, rootDirectoryName string, objectsDir string, ...) (bool, time.Duration, error)
• func UpdateWithOptions(request sub.UpdateRequest, options UpdateOptions) (bool, time.Duration, error)
• type DisruptionCancelor
• type DisruptionRequestor
• type TriggersRunner
• type UpdateOptions

Functions

func Update

func Update(request sub.UpdateRequest, rootDirectoryName string,
	objectsDir string, oldTriggers *triggers.Triggers,
	skipFilter *filter.Filter, triggersRunner TriggersRunner,
	logger log.Logger) (
	bool, time.Duration, error)

func UpdateWithOptions

func UpdateWithOptions(request sub.UpdateRequest, options UpdateOptions) (
	bool, time.Duration, error)

Types

type DisruptionCancelor

type DisruptionCancelor func()

type DisruptionRequestor

type DisruptionRequestor func() sub.DisruptionState

type TriggersRunner

type TriggersRunner func(triggers []*triggers.Trigger, action string,
	logger log.Logger) bool

type UpdateOptions

type UpdateOptions struct {
	DisruptionCancel  DisruptionCancelor
	DisruptionRequest DisruptionRequestor
	Logger            log.Logger
	ObjectsDir        string
	OldTriggers       *triggers.Triggers
	RootDirectoryName string
	RunTriggers       TriggersRunner
	SkipFilter        *filter.Filter
}