handlertask

Documentation

Index

• type MetricsReporter
• type Options
• type Task
  • func New(opts Options) *Task
  • func (t *Task) Name() string
  • func (t *Task) Run(ctx context.Context, acquireLock func()) error

Types

type MetricsReporter

type MetricsReporter interface {
	handlerattempt.MetricsReporter
}

type Options

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

	// Name of modified file
	Name string

	// Interface for reporting metrics.
	Metrics MetricsReporter
}

type Task

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

func New

func New(opts Options) *Task

func (*Task) Name

func (t *Task) Name() string

func (*Task) Run

func (t *Task) Run(ctx context.Context, acquireLock func()) error