netapp

Documentation

Index

• func BackupVaultObservedState_FromProto(mapCtx *direct.MapContext, in *pb.BackupVault) *krm.BackupVaultObservedState
• func BackupVaultObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BackupVaultObservedState) *pb.BackupVault
• func BackupVault_FromProto(mapCtx *direct.MapContext, in *pb.BackupVault) *krm.BackupVaultSpec
• func BackupVault_ToProto(mapCtx *direct.MapContext, in *krm.BackupVaultSpec) *pb.BackupVault
• func NetAppBackupPolicyObservedState_FromProto(mapCtx *direct.MapContext, in *pb.BackupPolicy) *krm.NetAppBackupPolicyObservedState
• func NetAppBackupPolicyObservedState_ToProto(mapCtx *direct.MapContext, in *krm.NetAppBackupPolicyObservedState) *pb.BackupPolicy
• func NetAppBackupPolicySpec_FromProto(mapCtx *direct.MapContext, in *pb.BackupPolicy) *krm.NetAppBackupPolicySpec
• func NetAppBackupPolicySpec_ToProto(mapCtx *direct.MapContext, in *krm.NetAppBackupPolicySpec) *pb.BackupPolicy
• func NewBackupPolicyModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
• type BackupPolicyAdapter
  • func (a *BackupPolicyAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
  • func (a *BackupPolicyAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
  • func (a *BackupPolicyAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
  • func (a *BackupPolicyAdapter) Find(ctx context.Context) (bool, error)
  • func (a *BackupPolicyAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Functions

func BackupVaultObservedState_FromProto

func BackupVaultObservedState_FromProto(mapCtx *direct.MapContext, in *pb.BackupVault) *krm.BackupVaultObservedState

func BackupVaultObservedState_ToProto

func BackupVaultObservedState_ToProto(mapCtx *direct.MapContext, in *krm.BackupVaultObservedState) *pb.BackupVault

func BackupVault_FromProto

func BackupVault_FromProto(mapCtx *direct.MapContext, in *pb.BackupVault) *krm.BackupVaultSpec

func BackupVault_ToProto

func BackupVault_ToProto(mapCtx *direct.MapContext, in *krm.BackupVaultSpec) *pb.BackupVault

func NetAppBackupPolicyObservedState_FromProto

func NetAppBackupPolicyObservedState_FromProto(mapCtx *direct.MapContext, in *pb.BackupPolicy) *krm.NetAppBackupPolicyObservedState

func NetAppBackupPolicyObservedState_ToProto

func NetAppBackupPolicyObservedState_ToProto(mapCtx *direct.MapContext, in *krm.NetAppBackupPolicyObservedState) *pb.BackupPolicy

func NetAppBackupPolicySpec_FromProto

func NetAppBackupPolicySpec_FromProto(mapCtx *direct.MapContext, in *pb.BackupPolicy) *krm.NetAppBackupPolicySpec

func NetAppBackupPolicySpec_ToProto

func NetAppBackupPolicySpec_ToProto(mapCtx *direct.MapContext, in *krm.NetAppBackupPolicySpec) *pb.BackupPolicy

func NewBackupPolicyModel

func NewBackupPolicyModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

Types

type BackupPolicyAdapter

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

func (*BackupPolicyAdapter) Create

func (a *BackupPolicyAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error

Create creates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.

func (*BackupPolicyAdapter) Delete

func (a *BackupPolicyAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)

Delete the resource from GCP service when the corresponding Config Connector resource is deleted.

func (*BackupPolicyAdapter) Export

func (a *BackupPolicyAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)

Export maps the GCP object to a Config Connector resource `spec`.

func (*BackupPolicyAdapter) Find

func (a *BackupPolicyAdapter) Find(ctx context.Context) (bool, error)

Find retrieves the GCP resource. Return true means the object is found. This triggers Adapter `Update` call. Return false means the object is not found. This triggers Adapter `Create` call. Return a non-nil error requeues the requests.

func (*BackupPolicyAdapter) Update

func (a *BackupPolicyAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error

Update updates the resource in GCP based on `spec` and update the Config Connector object `status` based on the GCP response.