controllers

Documentation

Index

• Constants
• Variables
• func RunRcloneDestReconciler(ctx context.Context, instance *scribev1alpha1.ReplicationDestination, ...) (ctrl.Result, error)
• func RunRcloneSrcReconciler(ctx context.Context, instance *scribev1alpha1.ReplicationSource, ...) (ctrl.Result, error)
• func RunResticDestReconciler(ctx context.Context, instance *scribev1alpha1.ReplicationDestination, ...) (ctrl.Result, error)
• func RunResticSrcReconciler(ctx context.Context, instance *scribev1alpha1.ReplicationSource, ...) (ctrl.Result, error)
• func RunRsyncDestReconciler(ctx context.Context, instance *scribev1alpha1.ReplicationDestination, ...) (ctrl.Result, error)
• func RunRsyncSrcReconciler(ctx context.Context, instance *scribev1alpha1.ReplicationSource, ...) (ctrl.Result, error)
• type ReplicationDestinationReconciler
  • func (r *ReplicationDestinationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ReplicationDestinationReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ReplicationSourceReconciler
  • func (r *ReplicationSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ReplicationSourceReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	// DefaultRsyncContainerImage is the default container image name of the rsync data mover
	DefaultRsyncContainerImage = "quay.io/backube/scribe-mover-rsync:latest"
	// DefaultRcloneContainerImage is the default container image name of the rclone data mover
	DefaultRcloneContainerImage = "quay.io/backube/scribe-mover-rclone:latest"
	// DefaultResticContainerImage is the default container image name of the restic data mover
	DefaultResticContainerImage = "quay.io/backube/scribe-mover-restic:latest"
	// DefaultSCCName is the default name of the scribe security context constraint
	DefaultSCCName = "scribe-mover"
)

Variables

var (
	// RsyncContainerImage is the container image name of the rsync data mover
	RsyncContainerImage string
	// RcloneContainerImage is the container image name of the rclone data mover
	RcloneContainerImage string
	// ResticContainerImage is the container image name of the restic data mover
	ResticContainerImage string
	// SCCName is the name of the scribe security context constraint
	SCCName string
)

Functions

func RunRcloneDestReconciler

func RunRcloneDestReconciler(
	ctx context.Context,
	instance *scribev1alpha1.ReplicationDestination,
	dr *ReplicationDestinationReconciler,
	logger logr.Logger,
) (ctrl.Result, error)

RunRcloneDestReconciler reconciles rclone mover related objects.

func RunRcloneSrcReconciler

func RunRcloneSrcReconciler(
	ctx context.Context,
	instance *scribev1alpha1.ReplicationSource,
	sr *ReplicationSourceReconciler,
	logger logr.Logger,
) (ctrl.Result, error)

RunRcloneSrcReconciler is invoked when ReplicationSource.Spec.Rclone != nil

func RunResticDestReconciler

func RunResticDestReconciler(
	ctx context.Context,
	instance *scribev1alpha1.ReplicationDestination,
	dr *ReplicationDestinationReconciler,
	logger logr.Logger,
) (ctrl.Result, error)

RunResticDestReconciler is invokded when ReplicationDestination.Spec>Restic != nil

func RunResticSrcReconciler

func RunResticSrcReconciler(
	ctx context.Context,
	instance *scribev1alpha1.ReplicationSource,
	sr *ReplicationSourceReconciler,
	logger logr.Logger,
) (ctrl.Result, error)

RunResticSrcReconciler is invokded when ReplicationSource.Spec>Restic != nil

func RunRsyncDestReconciler

func RunRsyncDestReconciler(
	ctx context.Context,
	instance *scribev1alpha1.ReplicationDestination,
	dr *ReplicationDestinationReconciler,
	logger logr.Logger,
) (ctrl.Result, error)

func RunRsyncSrcReconciler

func RunRsyncSrcReconciler(
	ctx context.Context,
	instance *scribev1alpha1.ReplicationSource,
	sr *ReplicationSourceReconciler,
	logger logr.Logger,
) (ctrl.Result, error)

Types

type ReplicationDestinationReconciler

type ReplicationDestinationReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

ReplicationDestinationReconciler reconciles a ReplicationDestination object

func (*ReplicationDestinationReconciler) Reconcile

func (r *ReplicationDestinationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ReplicationDestinationReconciler) SetupWithManager

func (r *ReplicationDestinationReconciler) SetupWithManager(mgr ctrl.Manager) error

type ReplicationSourceReconciler

type ReplicationSourceReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

ReplicationSourceReconciler reconciles a ReplicationSource object

func (*ReplicationSourceReconciler) Reconcile

func (r *ReplicationSourceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ReplicationSourceReconciler) SetupWithManager

func (r *ReplicationSourceReconciler) SetupWithManager(mgr ctrl.Manager) error