replication

Documentation

Index

• type Replication
  • func (r *Replication) MaxCurrency() uint
  • 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(_ job.Parameters) error

Types

type Replication

type Replication struct{}

Replication implements the job interface

func (*Replication) MaxCurrency

func (r *Replication) MaxCurrency() uint

MaxCurrency is implementation of same method in 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(_ job.Parameters) error

Validate does nothing