bigtable

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: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Any_v1alpha1_FromProto added in v1.138.0 

func Any_v1alpha1_FromProto(mapCtx *direct.MapContext, in *anypb.Any) *krmbigtablev1alpha1.Any

func Any_v1alpha1_ToProto added in v1.138.0 

func Any_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.Any) *anypb.Any

func AppProfile_DataBoostIsolationReadOnly_ComputeBillingOwner_ToProto 

func AppProfile_DataBoostIsolationReadOnly_ComputeBillingOwner_ToProto(mapCtx *direct.MapContext, in *string) *pb.AppProfile_DataBoostIsolationReadOnly_ComputeBillingOwner

func AppProfile_DataBoostIsolationReadOnly_v1beta1_FromProto added in v1.138.0 

func AppProfile_DataBoostIsolationReadOnly_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AppProfile_DataBoostIsolationReadOnly) *krm.AppProfile_DataBoostIsolationReadOnly

func AppProfile_DataBoostIsolationReadOnly_v1beta1_ToProto added in v1.138.0 

func AppProfile_DataBoostIsolationReadOnly_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.AppProfile_DataBoostIsolationReadOnly) *pb.AppProfile_DataBoostIsolationReadOnly

func AppProfile_SingleClusterRouting_v1beta1_FromProto added in v1.138.0 

func AppProfile_SingleClusterRouting_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AppProfile_SingleClusterRouting) *krm.AppProfile_SingleClusterRouting

func AppProfile_SingleClusterRouting_v1beta1_ToProto added in v1.138.0 

func AppProfile_SingleClusterRouting_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.AppProfile_SingleClusterRouting) *pb.AppProfile_SingleClusterRouting

func AppProfile_StandardIsolation_v1beta1_FromProto added in v1.138.0 

func AppProfile_StandardIsolation_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AppProfile_StandardIsolation) *krm.AppProfile_StandardIsolation

func AppProfile_StandardIsolation_v1beta1_ToProto added in v1.138.0 

func AppProfile_StandardIsolation_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.AppProfile_StandardIsolation) *pb.AppProfile_StandardIsolation

func AuthorizedView_FamilySubsets_v1alpha1_FromProto added in v1.138.0 

func AuthorizedView_FamilySubsets_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AuthorizedView_FamilySubsets) *krmbigtablev1alpha1.AuthorizedView_FamilySubsets

func AuthorizedView_FamilySubsets_v1alpha1_ToProto added in v1.138.0 

func AuthorizedView_FamilySubsets_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.AuthorizedView_FamilySubsets) *pb.AuthorizedView_FamilySubsets

func AuthorizedView_SubsetView_v1alpha1_FromProto added in v1.138.0 

func AuthorizedView_SubsetView_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AuthorizedView_SubsetView) *krmbigtablev1alpha1.AuthorizedView_SubsetView

func AuthorizedView_SubsetView_v1alpha1_ToProto added in v1.138.0 

func AuthorizedView_SubsetView_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.AuthorizedView_SubsetView) *pb.AuthorizedView_SubsetView

func AutoscalingLimits_v1alpha1_FromProto added in v1.138.0 

func AutoscalingLimits_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingLimits) *krmbigtablev1alpha1.AutoscalingLimits

func AutoscalingLimits_v1alpha1_ToProto added in v1.138.0 

func AutoscalingLimits_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.AutoscalingLimits) *pb.AutoscalingLimits

func AutoscalingTargets_v1alpha1_FromProto added in v1.138.0 

func AutoscalingTargets_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingTargets) *krmbigtablev1alpha1.AutoscalingTargets

func AutoscalingTargets_v1alpha1_ToProto added in v1.138.0 

func AutoscalingTargets_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.AutoscalingTargets) *pb.AutoscalingTargets

func BackupInfo_v1beta1_FromProto added in v1.138.0 

func BackupInfo_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.BackupInfo) *krm.BackupInfo

func BackupInfo_v1beta1_ToProto added in v1.138.0 

func BackupInfo_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BackupInfo) *pb.BackupInfo

func BigtableAppProfileObservedState_v1beta1_FromProto added in v1.138.0 

func BigtableAppProfileObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AppProfile) *krm.BigtableAppProfileObservedState

func BigtableAppProfileObservedState_v1beta1_ToProto added in v1.138.0 

func BigtableAppProfileObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigtableAppProfileObservedState) *pb.AppProfile

func BigtableAppProfileSpec_v1beta1_FromProto added in v1.138.0 

func BigtableAppProfileSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.AppProfile) *krmv1beta1.BigtableAppProfileSpec

func BigtableAppProfileSpec_v1beta1_ToProto added in v1.138.0 

func BigtableAppProfileSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.BigtableAppProfileSpec) *pb.AppProfile

func BigtableAuthorizedViewObservedState_v1alpha1_FromProto added in v1.138.0 

func BigtableAuthorizedViewObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AuthorizedView) *krmbigtablev1alpha1.BigtableAuthorizedViewObservedState

func BigtableAuthorizedViewObservedState_v1alpha1_ToProto added in v1.138.0 

func BigtableAuthorizedViewObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableAuthorizedViewObservedState) *pb.AuthorizedView

func BigtableAuthorizedViewSpec_v1alpha1_FromProto added in v1.138.0 

func BigtableAuthorizedViewSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.AuthorizedView) *krmbigtablev1alpha1.BigtableAuthorizedViewSpec

func BigtableAuthorizedViewSpec_v1alpha1_ToProto added in v1.138.0 

func BigtableAuthorizedViewSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableAuthorizedViewSpec) *pb.AuthorizedView

func BigtableBackupObservedState_v1alpha1_FromProto added in v1.138.0 

func BigtableBackupObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Backup) *krmbigtablev1alpha1.BigtableBackupObservedState

func BigtableBackupObservedState_v1alpha1_ToProto added in v1.138.0 

func BigtableBackupObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableBackupObservedState) *pb.Backup

func BigtableBackupSpec_v1alpha1_FromProto added in v1.138.0 

func BigtableBackupSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Backup) *krmbigtablev1alpha1.BigtableBackupSpec

func BigtableBackupSpec_v1alpha1_ToProto added in v1.138.0 

func BigtableBackupSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableBackupSpec) *pb.Backup

func BigtableClusterFuzzer added in v1.130.1 

func BigtableClusterFuzzer() fuzztesting.KRMFuzzer

func BigtableClusterObservedState_v1alpha1_FromProto added in v1.138.0 

func BigtableClusterObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krmbigtablev1alpha1.BigtableClusterObservedState

func BigtableClusterObservedState_v1alpha1_ToProto added in v1.138.0 

func BigtableClusterObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableClusterObservedState) *pb.Cluster

func BigtableClusterSpec_v1alpha1_FromProto added in v1.138.0 

func BigtableClusterSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster) *krmbigtablev1alpha1.BigtableClusterSpec

func BigtableClusterSpec_v1alpha1_ToProto added in v1.138.0 

func BigtableClusterSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableClusterSpec) *pb.Cluster

func BigtableGCPolicySpec_v1beta1_FromProto added in v1.154.0 

func BigtableGCPolicySpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.GcRule) *krm.BigtableGCPolicySpec

func BigtableGCPolicySpec_v1beta1_ToProto added in v1.154.0 

func BigtableGCPolicySpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigtableGCPolicySpec) *pb.GcRule

func BigtableInstanceSpec_v1beta1_FromProto added in v1.138.0 

func BigtableInstanceSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krm.BigtableInstanceSpec

func BigtableInstanceSpec_v1beta1_ToProto added in v1.138.0 

func BigtableInstanceSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigtableInstanceSpec) *pb.Instance

func BigtableLogicalViewObservedState_v1alpha1_FromProto added in v1.138.0 

func BigtableLogicalViewObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.LogicalView) *krmbigtablev1alpha1.BigtableLogicalViewObservedState

func BigtableLogicalViewObservedState_v1alpha1_ToProto added in v1.138.0 

func BigtableLogicalViewObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableLogicalViewObservedState) *pb.LogicalView

func BigtableLogicalViewSpec_v1alpha1_FromProto added in v1.138.0 

func BigtableLogicalViewSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.LogicalView) *krmbigtablev1alpha1.BigtableLogicalViewSpec

func BigtableLogicalViewSpec_v1alpha1_ToProto added in v1.138.0 

func BigtableLogicalViewSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableLogicalViewSpec) *pb.LogicalView

func BigtableMaterializedViewFuzzer added in v1.137.0 

func BigtableMaterializedViewFuzzer() fuzztesting.KRMFuzzer

func BigtableMaterializedViewInfo_ToBigtableMaterializedView added in v1.140.0 

func BigtableMaterializedViewInfo_ToBigtableMaterializedView(in *gcp.MaterializedViewInfo) *pb.MaterializedView

func BigtableMaterializedViewObservedState_v1alpha1_FromProto added in v1.138.0 

func BigtableMaterializedViewObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.MaterializedView) *krmbigtablev1alpha1.BigtableMaterializedViewObservedState

func BigtableMaterializedViewObservedState_v1alpha1_ToProto added in v1.138.0 

func BigtableMaterializedViewObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableMaterializedViewObservedState) *pb.MaterializedView

func BigtableMaterializedViewSpec_v1alpha1_FromProto added in v1.138.0 

func BigtableMaterializedViewSpec_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.MaterializedView) *krmbigtablev1alpha1.BigtableMaterializedViewSpec

func BigtableMaterializedViewSpec_v1alpha1_ToProto added in v1.138.0 

func BigtableMaterializedViewSpec_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.BigtableMaterializedViewSpec) *pb.MaterializedView

func BigtableMaterializedView_ToBigtableMaterializedViewInfo added in v1.140.0 

func BigtableMaterializedView_ToBigtableMaterializedViewInfo(in *pb.MaterializedView) *gcp.MaterializedViewInfo

func BigtableTableObservedState_v1beta1_FromProto added in v1.138.0 

func BigtableTableObservedState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krm.BigtableTableObservedState

func BigtableTableObservedState_v1beta1_ToProto added in v1.138.0 

func BigtableTableObservedState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigtableTableObservedState) *pb.Table

func BigtableTableSpec_v1beta1_FromProto added in v1.138.0 

func BigtableTableSpec_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Table) *krm.BigtableTableSpec

func BigtableTableSpec_v1beta1_ToProto added in v1.138.0 

func BigtableTableSpec_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.BigtableTableSpec) *pb.Table

func ChangeStreamConfig_v1beta1_FromProto added in v1.138.0 

func ChangeStreamConfig_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ChangeStreamConfig) *krm.ChangeStreamConfig

func ChangeStreamConfig_v1beta1_ToProto added in v1.138.0 

func ChangeStreamConfig_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.ChangeStreamConfig) *pb.ChangeStreamConfig

func Cluster_ClusterAutoscalingConfig_v1alpha1_FromProto added in v1.138.0 

func Cluster_ClusterAutoscalingConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster_ClusterAutoscalingConfig) *krmbigtablev1alpha1.Cluster_ClusterAutoscalingConfig

func Cluster_ClusterAutoscalingConfig_v1alpha1_ToProto added in v1.138.0 

func Cluster_ClusterAutoscalingConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.Cluster_ClusterAutoscalingConfig) *pb.Cluster_ClusterAutoscalingConfig

func Cluster_ClusterConfig_v1alpha1_FromProto added in v1.138.0 

func Cluster_ClusterConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster_ClusterConfig) *krmbigtablev1alpha1.Cluster_ClusterConfig

func Cluster_ClusterConfig_v1alpha1_ToProto added in v1.138.0 

func Cluster_ClusterConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.Cluster_ClusterConfig) *pb.Cluster_ClusterConfig

func Cluster_EncryptionConfig_v1alpha1_FromProto added in v1.138.0 

func Cluster_EncryptionConfig_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.Cluster_EncryptionConfig) *krmbigtablev1alpha1.Cluster_EncryptionConfig

func Cluster_EncryptionConfig_v1alpha1_ToProto added in v1.138.0 

func Cluster_EncryptionConfig_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.Cluster_EncryptionConfig) *pb.Cluster_EncryptionConfig

func EncryptionInfoObservedState_v1alpha1_FromProto added in v1.138.0 

func EncryptionInfoObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionInfo) *krmbigtablev1alpha1.EncryptionInfoObservedState

func EncryptionInfoObservedState_v1alpha1_ToProto added in v1.138.0 

func EncryptionInfoObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.EncryptionInfoObservedState) *pb.EncryptionInfo

func EncryptionInfo_v1alpha1_FromProto added in v1.138.0 

func EncryptionInfo_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionInfo) *krmbigtablev1alpha1.EncryptionInfo

func EncryptionInfo_v1alpha1_ToProto added in v1.138.0 

func EncryptionInfo_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.EncryptionInfo) *pb.EncryptionInfo

func EncryptionInfo_v1beta1_FromProto added in v1.138.0 

func EncryptionInfo_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionInfo) *krm.EncryptionInfo

func EncryptionInfo_v1beta1_ToProto added in v1.138.0 

func EncryptionInfo_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.EncryptionInfo) *pb.EncryptionInfo

func HasHTTPCode 

func HasHTTPCode(err error, code int) bool

HasHTTPCode returns true if the given error is an HTTP response with the given code.

func IsNotFound 

func IsNotFound(err error) bool

IsNotFound returns true if the given error is an HTTP 404.

func NewBigtableAppProfileModel added in v1.132.0 

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

func NewGCPolicyModel added in v1.154.0 

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

func NewLogicalViewModel added in v1.133.0 

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

func NewMaterializedViewModel added in v1.140.0 

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

func ParseDuration added in v1.154.0 

func ParseDuration(s string) (time.Duration, error)

ParseDuration parses a duration string. A duration string is a possibly signed sequence of decimal numbers, each with optional fraction and a unit suffix, such as "300ms", "-1.5h" or "2h45m". Valid time units are "ns", "us" (or "µs"), "ms", "s", "m", "h".

func PtrTo 

func PtrTo[T any](t T) *T

func RestoreInfo_v1beta1_FromProto added in v1.138.0 

func RestoreInfo_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.RestoreInfo) *krm.RestoreInfo

func RestoreInfo_v1beta1_ToProto added in v1.138.0 

func RestoreInfo_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.RestoreInfo) *pb.RestoreInfo

func Status_v1alpha1_FromProto added in v1.138.0 

func Status_v1alpha1_FromProto(mapCtx *direct.MapContext, in *status.Status) *krmbigtablev1alpha1.Status

func Status_v1alpha1_ToProto added in v1.138.0 

func Status_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krmbigtablev1alpha1.Status) *status.Status

func TableColumnFamily_v1beta1_FromProto added in v1.138.0 

func TableColumnFamily_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.ColumnFamily) *krm.TableColumnFamily

func TableColumnFamily_v1beta1_ToProto added in v1.138.0 

func TableColumnFamily_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.TableColumnFamily) *pb.ColumnFamily

func Table_ClusterState_v1beta1_FromProto added in v1.138.0 

func Table_ClusterState_v1beta1_FromProto(mapCtx *direct.MapContext, in *pb.Table_ClusterState) *krm.Table_ClusterState

func Table_ClusterState_v1beta1_ToProto added in v1.138.0 

func Table_ClusterState_v1beta1_ToProto(mapCtx *direct.MapContext, in *krm.Table_ClusterState) *pb.Table_ClusterState

func ValueOf 

func ValueOf[T any](p *T) T

Types

type BigtableAppProfileAdapter added in v1.132.0 

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

func (*BigtableAppProfileAdapter) Create added in v1.132.0 

func (a *BigtableAppProfileAdapter) 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 (*BigtableAppProfileAdapter) Delete added in v1.132.0 

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

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

func (*BigtableAppProfileAdapter) Export added in v1.132.0 

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

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

func (*BigtableAppProfileAdapter) Find added in v1.132.0 

func (a *BigtableAppProfileAdapter) 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 (*BigtableAppProfileAdapter) Update added in v1.132.0 

func (a *BigtableAppProfileAdapter) 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 GCPolicyAdapter added in v1.154.0 

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

func (*GCPolicyAdapter) Create added in v1.154.0 

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

func (*GCPolicyAdapter) Delete added in v1.154.0 

func (a *GCPolicyAdapter) Delete(ctx context.Context, _ *directbase.DeleteOperation) (bool, error)

func (*GCPolicyAdapter) Export added in v1.154.0 

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

func (*GCPolicyAdapter) Find added in v1.154.0 

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

func (*GCPolicyAdapter) Update added in v1.154.0 

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

type LogicalViewAdapter added in v1.133.0 

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

func (*LogicalViewAdapter) Create added in v1.133.0 

func (a *LogicalViewAdapter) 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 (*LogicalViewAdapter) Delete added in v1.133.0 

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

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

func (*LogicalViewAdapter) Export added in v1.133.0 

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

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

func (*LogicalViewAdapter) Find added in v1.133.0 

func (a *LogicalViewAdapter) 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 (*LogicalViewAdapter) Update added in v1.133.0 

func (a *LogicalViewAdapter) 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 MaterializedViewAdapter added in v1.140.0 

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

func (*MaterializedViewAdapter) Create added in v1.140.0 

func (a *MaterializedViewAdapter) 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 (*MaterializedViewAdapter) Delete added in v1.140.0 

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

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

func (*MaterializedViewAdapter) Export added in v1.140.0 

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

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

func (*MaterializedViewAdapter) Find added in v1.140.0 

func (a *MaterializedViewAdapter) 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 (*MaterializedViewAdapter) Update added in v1.140.0 

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

Directories

Path Synopsis

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.