replication

May 2, 2018

Changes in this version

+ type Deleter struct

+ func (d *Deleter) MaxFails() uint

+ func (d *Deleter) Run(ctx env.JobContext, params map[string]interface{}) error

+ func (d *Deleter) ShouldRetry() bool

+ func (d *Deleter) Validate(params map[string]interface{}) error

+ type Replicator struct

+ func (r *Replicator) MaxFails() uint

+ func (r *Replicator) Run(ctx env.JobContext, params map[string]interface{}) error

+ func (r *Replicator) ShouldRetry() bool

+ func (r *Replicator) Validate(params map[string]interface{}) error

+ type Transfer struct

+ func (t *Transfer) MaxFails() uint

+ func (t *Transfer) Run(ctx env.JobContext, params map[string]interface{}) error

+ func (t *Transfer) ShouldRetry() bool

+ func (t *Transfer) Validate(params map[string]interface{}) error