handlerattempt

Documentation

Index

• type Attempt
  • func New(opts Options) (*Attempt, error)
  • func (o *Attempt) Run(ctx context.Context) (bool, error)
• type MetricsReporter
• type Options

Types

type Attempt

type Attempt struct {
	// contains filtered or unexported fields
}

func New

func New(opts Options) (*Attempt, error)

func (*Attempt) Run

func (o *Attempt) Run(ctx context.Context) (bool, error)

type MetricsReporter

type MetricsReporter interface {
	handlercommand.MetricsReporter
}

type Options

type Options struct {
	Logger  *zap.Logger
	Config  *config.Handler
	Journal *journal.Journal

	// Path to the changed file.
	ChangedFile string

	// Directory for storing execution-related files.
	BaseDir string

	// Whether the attempt is the last one before giving up.
	Final bool

	// Function to acquire a lock preventing concurrent file changes by handler
	// logic.
	AcquireLock func()

	// Interface for reporting metrics.
	Metrics MetricsReporter
}