backupdr

package
v1.154.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 15, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BackupDRBackupPlanAssociationObservedState_v1beta1_FromProto added in v1.134.0 

func BackupDRBackupPlanAssociationObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupPlanAssociation) *krm.BackupDRBackupPlanAssociationObservedState

func BackupDRBackupPlanAssociationObservedState_v1beta1_ToProto added in v1.134.0 

func BackupDRBackupPlanAssociationObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupPlanAssociationObservedState) *pb.BackupPlanAssociation

func BackupDRBackupPlanAssociationSpec_Resource_v1beta1_FromProto added in v1.134.0 

func BackupDRBackupPlanAssociationSpec_Resource_v1beta1_FromProto(mapCtx *direct.MapContext, resource string, resourceType string) *krm.Resource

func BackupDRBackupPlanAssociationSpec_Resource_v1beta1_ToProto added in v1.134.0 

func BackupDRBackupPlanAssociationSpec_Resource_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Resource) string

func BackupDRBackupPlanAssociationSpec_v1beta1_FromProto added in v1.134.0 

func BackupDRBackupPlanAssociationSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupPlanAssociation) *krm.BackupDRBackupPlanAssociationSpec

func BackupDRBackupPlanAssociationSpec_v1beta1_ToProto added in v1.134.0 

func BackupDRBackupPlanAssociationSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupPlanAssociationSpec) *pb.BackupPlanAssociation

func BackupDRBackupPlanObservedState_v1beta1_FromProto added in v1.137.0 

func BackupDRBackupPlanObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupPlan) *krm.BackupDRBackupPlanObservedState

found existing non-generated mapping function "BackupDRBackupPlanAssociationSpec_v1beta1_ToProto", skipping 

func BackupDRBackupPlanAssociationSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupPlanAssociationSpec) *pb.BackupPlanAssociation {
	if in == nil {
		return nil
	}
	out := &pb.BackupPlanAssociation{}
	// MISSING: Name
	out.ResourceType = direct.ValueOf(in.ResourceType)
	out.Resource = BackupDRBackupPlanAssociationSpec_Resource_ToProto(mapCtx, in.Resource)
	if in.BackupPlanRef != nil {
		out.BackupPlan = in.BackupPlanRef.External
	}
	// MISSING: CloudSQLInstanceBackupPlanAssociationProperties
	// MISSING: BackupPlanRevisionID
	// MISSING: BackupPlanRevisionName
	return out
}

func BackupDRBackupPlanObservedState_v1beta1_ToProto added in v1.137.0 

func BackupDRBackupPlanObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupPlanObservedState) *pb.BackupPlan

func BackupDRBackupPlanSpec_v1beta1_FromProto added in v1.137.0 

func BackupDRBackupPlanSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupPlan) *krm.BackupDRBackupPlanSpec

func BackupDRBackupPlanSpec_v1beta1_ToProto added in v1.137.0 

func BackupDRBackupPlanSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupPlanSpec) *pb.BackupPlan

func BackupDRBackupVaultObservedState_v1beta1_FromProto added in v1.138.0 

func BackupDRBackupVaultObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupVault) *krm.BackupDRBackupVaultObservedState

func BackupDRBackupVaultObservedState_v1beta1_ToProto added in v1.138.0 

func BackupDRBackupVaultObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupVaultObservedState) *pb.BackupVault

func BackupDRBackupVaultSpec_v1beta1_FromProto added in v1.138.0 

func BackupDRBackupVaultSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupVault) *krm.BackupDRBackupVaultSpec

found existing non-generated mapping function "BackupDRBackupVaultObservedState_v1beta1_ToProto", skipping 

func BackupDRBackupVaultObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupVaultObservedState) *pb.BackupVault {
	if in == nil {
		return nil
	}
	out := &pb.BackupVault{}
	// MISSING: Name
	// MISSING: Labels
	out.CreateTime = direct.StringTimestamp_ToProto(mapCtx, in.CreateTime)
	out.UpdateTime = direct.StringTimestamp_ToProto(mapCtx, in.UpdateTime)
	out.Deletable = in.Deletable
	out.Etag = in.Etag
	out.State = direct.Enum_ToProto[pb.BackupVault_State](mapCtx, in.State)
	out.BackupCount = direct.ValueOf(in.BackupCount)
	out.ServiceAccount = direct.ValueOf(in.ServiceAccount)
	out.TotalStoredBytes = direct.ValueOf(in.TotalStoredBytes)
	// MISSING: Uid
	// (near miss): "Uid" vs "UID"
	return out
}

func BackupDRBackupVaultSpec_v1beta1_ToProto added in v1.138.0 

func BackupDRBackupVaultSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRBackupVaultSpec) *pb.BackupVault

func BackupDRManagementServerObservedState_v1alpha1_FromProto added in v1.134.0 

func BackupDRManagementServerObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ManagementServer) *krm.BackupDRManagementServerObservedState

func BackupDRManagementServerObservedState_v1alpha1_ToProto added in v1.134.0 

func BackupDRManagementServerObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.BackupDRManagementServerObservedState) *pb.ManagementServer

func BackupDRManagementServerSpec_v1alpha1_FromProto added in v1.134.0 

func BackupDRManagementServerSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ManagementServer) *krmbackupdrv1alpha1.BackupDRManagementServerSpec

found existing non-generated mapping function "BackupDRManagementServerObservedState_v1alpha1_ToProto", skipping 

func BackupDRManagementServerObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbackupdrv1alpha1.BackupDRManagementServerObservedState) *pb.ManagementServer {
	if in == nil {
		return nil
	}
	out := &pb.ManagementServer{}
	// MISSING: Name
	out.CreateTime = direct.StringTimestamp_ToProto(mapCtx, in.CreateTime)
	out.UpdateTime = direct.StringTimestamp_ToProto(mapCtx, in.UpdateTime)
	out.ManagementUri = ManagementURIObservedState_v1alpha1_ToProto(mapCtx, in.ManagementURI)
	out.WorkforceIdentityBasedManagementUri = WorkforceIdentityBasedManagementURIObservedState_v1alpha1_ToProto(mapCtx, in.WorkforceIdentityBasedManagementURI)
	out.State = direct.Enum_ToProto[pb.ManagementServer_InstanceState](mapCtx, in.State)
	// MISSING: Etag
	// MISSING: OAUTH2ClientID
	// (near miss): "OAUTH2ClientID" vs "OAuth2ClientID"
	// MISSING: WorkforceIdentityBasedOAUTH2ClientID
	// (near miss): "WorkforceIdentityBasedOAUTH2ClientID" vs "WorkforceIdentityBasedOAuth2ClientID"
	// MISSING: BaProxyURI
	// MISSING: SatisfiesPzs
	// MISSING: SatisfiesPzi
	return out
}

func BackupDRManagementServerSpec_v1alpha1_ToProto added in v1.134.0 

func BackupDRManagementServerSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbackupdrv1alpha1.BackupDRManagementServerSpec) *pb.ManagementServer

func BackupRule_v1beta1_FromProto added in v1.137.0 

func BackupRule_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupRule) *krm.BackupRule

func BackupRule_v1beta1_ToProto added in v1.137.0 

func BackupRule_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupRule) *pb.BackupRule

func BackupWindow_v1beta1_FromProto added in v1.137.0 

func BackupWindow_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupWindow) *krm.BackupWindow

func BackupWindow_v1beta1_ToProto added in v1.137.0 

func BackupWindow_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupWindow) *pb.BackupWindow

func DeprecatedAny_v1beta1_FromProto added in v1.153.0 

func DeprecatedAny_v1beta1_FromProto(mapCtx *direct.MapContext, in *anypb.Any) *common.DeprecatedAny

func DeprecatedAny_v1beta1_ToProto added in v1.153.0 

func DeprecatedAny_v1beta1_ToProto(mapCtx *direct.MapContext, in *common.DeprecatedAny) *anypb.Any

func DeprecatedStatusWithDetails_v1beta1_FromProto added in v1.153.0 

func DeprecatedStatusWithDetails_v1beta1_FromProto(mapCtx *direct.MapContext, in *statuspb.Status) *common.DeprecatedStatusWithDetails

func DeprecatedStatusWithDetails_v1beta1_ToProto added in v1.153.0 

func DeprecatedStatusWithDetails_v1beta1_ToProto(mapCtx *direct.MapContext, in *common.DeprecatedStatusWithDetails) *statuspb.Status

func ManagementURIObservedState_v1alpha1_FromProto added in v1.134.0 

func ManagementURIObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.ManagementURI) *krm.ManagementURIObservedState

func ManagementURIObservedState_v1alpha1_ToProto added in v1.134.0 

func ManagementURIObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.ManagementURIObservedState) *pb.ManagementURI

func NetworkConfig_v1alpha1_FromProto added in v1.134.0 

func NetworkConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig) *krm.NetworkConfig

func NetworkConfig_v1alpha1_ToProto added in v1.134.0 

func NetworkConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbackupdrv1alpha1.NetworkConfig) *pb.NetworkConfig

found existing non-generated mapping function "NetworkConfig_v1alpha1_FromProto", skipping 

func NetworkConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.NetworkConfig) *krmbackupdrv1alpha1.NetworkConfig {
	if in == nil {
		return nil
	}
	out := &krmbackupdrv1alpha1.NetworkConfig{}
	if in.GetNetwork() != "" {
		out.NetworkRef = &computerefs.ComputeNetworkRef{External: in.GetNetwork()}
	}
	out.PeeringMode = direct.Enum_FromProto(mapCtx, in.GetPeeringMode())
	return out
}

func NewBackupPlanAssociationModel 

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

func NewBackupPlanModel 

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

func NewBackupVaultModel 

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

func NewManagementServerModel 

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

func RuleConfigInfoObservedState_v1beta1_FromProto added in v1.134.0 

func RuleConfigInfoObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.RuleConfigInfo) *krm.RuleConfigInfoObservedState

func RuleConfigInfoObservedState_v1beta1_ToProto added in v1.134.0 

func RuleConfigInfoObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.RuleConfigInfoObservedState) *pb.RuleConfigInfo

func StandardSchedule_v1beta1_FromProto added in v1.137.0 

func StandardSchedule_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.StandardSchedule) *krm.StandardSchedule

found existing non-generated mapping function "RuleConfigInfoObservedState_v1beta1_ToProto", skipping 

func RuleConfigInfoObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.RuleConfigInfoObservedState) *pb.RuleConfigInfo {
	if in == nil {
		return nil
	}
	out := &pb.RuleConfigInfo{}
	out.RuleId = direct.ValueOf(in.RuleID)
	out.LastBackupState = direct.Enum_ToProto[pb.RuleConfigInfo_LastBackupState](mapCtx, in.LastBackupState)
	out.LastBackupError = direct.Status_ToProto(mapCtx, in.LastBackupError)
	out.LastSuccessfulBackupConsistencyTime = direct.StringTimestamp_ToProto(mapCtx, in.LastSuccessfulBackupConsistencyTime)
	return out
}

func StandardSchedule_v1beta1_ToProto added in v1.137.0 

func StandardSchedule_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.StandardSchedule) *pb.StandardSchedule

func WeekDayOfMonth_v1beta1_FromProto added in v1.137.0 

func WeekDayOfMonth_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.WeekDayOfMonth) *krm.WeekDayOfMonth

func WeekDayOfMonth_v1beta1_ToProto added in v1.137.0 

func WeekDayOfMonth_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.WeekDayOfMonth) *pb.WeekDayOfMonth

func WorkforceIdentityBasedManagementURIObservedState_v1alpha1_FromProto added in v1.134.0 

func WorkforceIdentityBasedManagementURIObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkforceIdentityBasedManagementURI) *krmbackupdrv1alpha1.WorkforceIdentityBasedManagementURIObservedState

func WorkforceIdentityBasedManagementURIObservedState_v1alpha1_ToProto added in v1.134.0 

func WorkforceIdentityBasedManagementURIObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbackupdrv1alpha1.WorkforceIdentityBasedManagementURIObservedState) *pb.WorkforceIdentityBasedManagementURI

func WorkforceIdentityBasedOAuth2ClientIDObservedState_v1alpha1_FromProto added in v1.134.0 

func WorkforceIdentityBasedOAuth2ClientIDObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.WorkforceIdentityBasedOAuth2ClientID) *krm.WorkforceIdentityBasedOAuth2ClientIDObservedState

func WorkforceIdentityBasedOAuth2ClientIDObservedState_v1alpha1_ToProto added in v1.134.0 

func WorkforceIdentityBasedOAuth2ClientIDObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.WorkforceIdentityBasedOAuth2ClientIDObservedState) *pb.WorkforceIdentityBasedOAuth2ClientID

Types

type BackupPlanAdapter 

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

func (*BackupPlanAdapter) Create 

func (a *BackupPlanAdapter) 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 (*BackupPlanAdapter) Delete 

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

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

func (*BackupPlanAdapter) Export 

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

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

func (*BackupPlanAdapter) Find 

func (a *BackupPlanAdapter) 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 (*BackupPlanAdapter) Update 

func (a *BackupPlanAdapter) 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.

type BackupPlanAssociationAdapter 

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

func (*BackupPlanAssociationAdapter) Create 

func (a *BackupPlanAssociationAdapter) 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 (*BackupPlanAssociationAdapter) Delete 

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

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

func (*BackupPlanAssociationAdapter) Export 

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

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

func (*BackupPlanAssociationAdapter) Find 

func (a *BackupPlanAssociationAdapter) 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 (*BackupPlanAssociationAdapter) Update 

func (a *BackupPlanAssociationAdapter) 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.

type BackupVaultAdapter 

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

func (*BackupVaultAdapter) Create 

func (a *BackupVaultAdapter) 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 (*BackupVaultAdapter) Delete 

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

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

func (*BackupVaultAdapter) Export 

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

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

func (*BackupVaultAdapter) Find 

func (a *BackupVaultAdapter) 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 (*BackupVaultAdapter) Update 

func (a *BackupVaultAdapter) 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.

type ManagementServerAdapter 

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

func (*ManagementServerAdapter) Create 

func (a *ManagementServerAdapter) 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 (*ManagementServerAdapter) Delete 

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

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

func (*ManagementServerAdapter) Export 

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

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

func (*ManagementServerAdapter) Find 

func (a *ManagementServerAdapter) 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 (*ManagementServerAdapter) Update 

func (a *ManagementServerAdapter) 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.