rclone

Documentation

Index

• func LogLineFilterSuccess(line string) *string
• func Register() error
• type Builder
  • func (rb *Builder) FromDestination(client client.Client, logger logr.Logger, eventRecorder events.EventRecorder, ...) (mover.Mover, error)
  • func (rb *Builder) FromSource(client client.Client, logger logr.Logger, eventRecorder events.EventRecorder, ...) (mover.Mover, error)
  • func (rb *Builder) VersionInfo() string
• type Mover
  • func (m *Mover) Cleanup(ctx context.Context) (mover.Result, error)
  • func (m *Mover) Name() string
  • func (m *Mover) Synchronize(ctx context.Context) (mover.Result, error)

Functions

func LogLineFilterSuccess

func LogLineFilterSuccess(line string) *string

Filter rclone log lines for a successful mover job

func Register

func Register() error

Types

type Builder

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

func (*Builder) FromDestination

func (rb *Builder) FromDestination(client client.Client, logger logr.Logger,
	eventRecorder events.EventRecorder,
	destination *volsyncv1alpha1.ReplicationDestination, privileged bool) (mover.Mover, error)

func (*Builder) FromSource

func (rb *Builder) FromSource(client client.Client, logger logr.Logger,
	eventRecorder events.EventRecorder,
	source *volsyncv1alpha1.ReplicationSource, privileged bool) (mover.Mover, error)

func (*Builder) VersionInfo

func (rb *Builder) VersionInfo() string

type Mover

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

Mover is the reconciliation logic for the Rclone-based data mover.

func (*Mover) Cleanup

func (m *Mover) Cleanup(ctx context.Context) (mover.Result, error)

func (*Mover) Name

func (m *Mover) Name() string

func (*Mover) Synchronize

func (m *Mover) Synchronize(ctx context.Context) (mover.Result, error)