replication

Documentation

Index

• type Replication
  • func (r *Replication) MaxFails() uint
  • func (r *Replication) Run(ctx job.Context, params job.Parameters) error
  • func (r *Replication) ShouldRetry() bool
  • func (r *Replication) Validate(params job.Parameters) error
• type Scheduler
  • func (s *Scheduler) MaxFails() uint
  • func (s *Scheduler) Run(ctx job.Context, params job.Parameters) error
  • func (s *Scheduler) ShouldRetry() bool
  • func (s *Scheduler) Validate(params job.Parameters) error

Types

type Replication

type Replication struct{}

Replication implements the job interface

func (*Replication) MaxFails

func (r *Replication) MaxFails() uint

MaxFails returns that how many times this job can fail

func (*Replication) Run

func (r *Replication) Run(ctx job.Context, params job.Parameters) error

Run gets the corresponding transfer according to the resource type and calls its function to do the real work

func (*Replication) ShouldRetry

func (r *Replication) ShouldRetry() bool

ShouldRetry always returns true which means the job is needed to be restarted when fails

func (*Replication) Validate

func (r *Replication) Validate(params job.Parameters) error

Validate does nothing

type Scheduler

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

Scheduler is a job running in Jobservice which can be used as a scheduler when submitting it as a scheduled job. It receives a URL and data, and post the data to the URL when it is running

func (*Scheduler) MaxFails

func (s *Scheduler) MaxFails() uint

MaxFails ...

func (*Scheduler) Run

func (s *Scheduler) Run(ctx job.Context, params job.Parameters) error

Run ...

func (*Scheduler) ShouldRetry

func (s *Scheduler) ShouldRetry() bool

ShouldRetry ...

func (*Scheduler) Validate

func (s *Scheduler) Validate(params job.Parameters) error

Validate ....