purge

Documentation

Index

• type Job
  • func (j *Job) MaxCurrency() uint
  • func (j *Job) MaxFails() uint
  • func (j *Job) Run(ctx job.Context, params job.Parameters) error
  • func (j *Job) ShouldRetry() bool
  • func (j *Job) Validate(_ job.Parameters) error

Types

type Job

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

Job defines the purge job

func (*Job) MaxCurrency

func (j *Job) MaxCurrency() uint

MaxCurrency is implementation of same method in Interface.

func (*Job) MaxFails

func (j *Job) MaxFails() uint

MaxFails is implementation of same method in Interface.

func (*Job) Run

func (j *Job) Run(ctx job.Context, params job.Parameters) error

Run the purge logic here.

func (*Job) ShouldRetry

func (j *Job) ShouldRetry() bool

ShouldRetry ...

func (*Job) Validate

func (j *Job) Validate(_ job.Parameters) error

Validate is implementation of same method in Interface.