replication

package
v1.8.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 15, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 ....

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL