sample

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(params job.Parameters) error

Types

type Job

type Job struct{}

Job is a sample to show how to implement a 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 replication logic here.

func (*Job) ShouldRetry

func (j *Job) ShouldRetry() bool

ShouldRetry ...

func (*Job) Validate

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

Validate is implementation of same method in Interface.