factory

Documentation

Index

• Variables
• func FetchRBAAggregate(ctx context.Context, cf CachedFetcher, c client.Client, logger *logrus.Entry, ...) (*domain.RequestedBackupActionAggregate, ctrl.Result, error)
• func FetchSBAggregate(ctx context.Context, cf CachedFetcher, c client.Client, logger *logrus.Entry, ...) (*domain.ScheduledBackupAggregate, error)
• type CachedFetcher
  • func (r *CachedFetcher) FetchRequestedBackupAction(ctx context.Context, req ctrl.Request) (*riotkitorgv1alpha1.RequestedBackupAction, error)
  • func (r *CachedFetcher) FetchScheduledBackup(ctx context.Context, req ctrl.Request) (*riotkitorgv1alpha1.ScheduledBackup, error)
• type Factory
  • func NewFactory(client client.Client, fetcher CachedFetcher, logger *logrus.Entry) *Factory
  • func (c *Factory) CreateRequestedBackupActionAggregate(ctx context.Context, action *v1alpha1.RequestedBackupAction, ...) (*domain.RequestedBackupActionAggregate, error, error)
  • func (c *Factory) CreateScheduledBackupAggregate(ctx context.Context, backup *v1alpha1.ScheduledBackup, operation string) (*domain.ScheduledBackupAggregate, error, error)

Variables

var ErrorActionRequeue = errors.New("REQUEUE")

Functions

func FetchRBAAggregate

func FetchRBAAggregate(ctx context.Context, cf CachedFetcher, c client.Client, logger *logrus.Entry, req ctrl.Request) (*domain.RequestedBackupActionAggregate, ctrl.Result, error)

FetchRBAAggregate fetches RequestedBackupAction aggregate with all of its dependencies

func FetchSBAggregate

func FetchSBAggregate(ctx context.Context, cf CachedFetcher, c client.Client, logger *logrus.Entry, req ctrl.Request) (*domain.ScheduledBackupAggregate, error)

Types

type CachedFetcher

type CachedFetcher struct {
	Cache  cache.Cache
	Client v1alpha1.RiotkitV1alpha1Interface
}

CachedFetcher is fetching objects collected by the controller-runtime

func (*CachedFetcher) FetchRequestedBackupAction

func (r *CachedFetcher) FetchRequestedBackupAction(ctx context.Context, req ctrl.Request) (*riotkitorgv1alpha1.RequestedBackupAction, error)

FetchRequestedBackupAction is fetching ScheduledBackup object from the cache

func (*CachedFetcher) FetchScheduledBackup

func (r *CachedFetcher) FetchScheduledBackup(ctx context.Context, req ctrl.Request) (*riotkitorgv1alpha1.ScheduledBackup, error)

FetchScheduledBackup is fetching ScheduledBackup object from the cache

type Factory

type Factory struct {
	client.Client
	// contains filtered or unexported fields
}

func NewFactory

func NewFactory(client client.Client, fetcher CachedFetcher, logger *logrus.Entry) *Factory

func (*Factory) CreateRequestedBackupActionAggregate

func (c *Factory) CreateRequestedBackupActionAggregate(ctx context.Context, action *v1alpha1.RequestedBackupAction, scheduledBackup *v1alpha1.ScheduledBackup) (*domain.RequestedBackupActionAggregate, error, error)

CreateRequestedBackupActionAggregate is creating a fully hydrated object (aggregate) with all dependencies inside

func (*Factory) CreateScheduledBackupAggregate

func (c *Factory) CreateScheduledBackupAggregate(ctx context.Context, backup *v1alpha1.ScheduledBackup, operation string) (*domain.ScheduledBackupAggregate, error, error)

CreateScheduledBackupAggregate is creating a fully hydrated object (aggregate) with all dependencies inside