br

Documentation

Index

• Constants
• func StartJobGCer[T JobObject](mgr manager.Manager, actor *GCActor[T], obj T) error
• type BackupActor
  • func NewBackupActor(image string) *BackupActor
  • func (c *BackupActor) Finalize(ctx *recon.Context[*v1alpha1.BackupJob]) (bool, error)
  • func (c *BackupActor) Observe(ctx *recon.Context[*v1alpha1.BackupJob]) (recon.Action[*v1alpha1.BackupJob], error)
  • func (c *BackupActor) Reconcile(mgr manager.Manager) error
• type BackupCommand
  • func (b *BackupCommand) String() string
• type GCActor
  • func (r *GCActor[T]) Observe(c *recon.Context[T]) error
• type JobObject
• type RestoreActor
  • func NewRestoreActor(image string) *RestoreActor
  • func (c *RestoreActor) Finalize(ctx *recon.Context[*v1alpha1.RestoreJob]) (bool, error)
  • func (c *RestoreActor) Observe(ctx *recon.Context[*v1alpha1.RestoreJob]) (recon.Action[*v1alpha1.RestoreJob], error)
  • func (c *RestoreActor) Reconcile(mgr manager.Manager) error
• type RestoreCommand
  • func (c *RestoreCommand) String() string
• type S3

Constants

const (
	MOUserEnvKey     = "MO_USER"
	MOPasswordEnvKey = "MO_PASSWORD"

	RestoreAccessEnvKey = "RESTORE_ACCESS_KEY_ID"
	RestoreSecretEnvKey = "RESTORE_SECRET_ACCESS_KEY"

	MetaDelimiter = "META_DELIMITER"
	RawMetaEnv    = "RAW_META"
)

Functions

func StartJobGCer

func StartJobGCer[T JobObject](mgr manager.Manager, actor *GCActor[T], obj T) error

Types

type BackupActor

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

func NewBackupActor

func NewBackupActor(image string) *BackupActor

func (*BackupActor) Finalize

func (c *BackupActor) Finalize(ctx *recon.Context[*v1alpha1.BackupJob]) (bool, error)

func (*BackupActor) Observe

func (c *BackupActor) Observe(ctx *recon.Context[*v1alpha1.BackupJob]) (recon.Action[*v1alpha1.BackupJob], error)

func (*BackupActor) Reconcile

func (c *BackupActor) Reconcile(mgr manager.Manager) error

type BackupCommand

type BackupCommand struct {
	Host string
	Port int
	S3   S3
}

func (*BackupCommand) String

func (b *BackupCommand) String() string

type GCActor

type GCActor[T JobObject] struct {
	ConditionType recon.ConditionType
}

func (*GCActor[T]) Observe

func (r *GCActor[T]) Observe(c *recon.Context[T]) error

type JobObject

type JobObject interface {
	recon.Conditional
	client.Object

	GetTTL() time.Duration
	GetOverlay() *v1alpha1.Overlay
}

type RestoreActor

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

func NewRestoreActor

func NewRestoreActor(image string) *RestoreActor

func (*RestoreActor) Finalize

func (c *RestoreActor) Finalize(ctx *recon.Context[*v1alpha1.RestoreJob]) (bool, error)

func (*RestoreActor) Observe

func (c *RestoreActor) Observe(ctx *recon.Context[*v1alpha1.RestoreJob]) (recon.Action[*v1alpha1.RestoreJob], error)

func (*RestoreActor) Reconcile

func (c *RestoreActor) Reconcile(mgr manager.Manager) error

type RestoreCommand

type RestoreCommand struct {
	BackupID string
	Target   S3
	RawMeta  string

	ReadSourceEnvSecret bool
}

func (*RestoreCommand) String

func (c *RestoreCommand) String() string

type S3

type S3 struct {
	Endpoint      string
	Bucket        string
	Path          string
	Type          string
	ReadEnvSecret bool
}