spanner

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides_FromProto 

func AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides) *krm.AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides

func AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides_ToProto 

func AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides) *pb.AutoscalingConfig_AsymmetricAutoscalingOption_AutoscalingConfigOverrides

func AutoscalingConfig_AsymmetricAutoscalingOption_FromProto 

func AutoscalingConfig_AsymmetricAutoscalingOption_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingConfig_AsymmetricAutoscalingOption) *krm.AutoscalingConfig_AsymmetricAutoscalingOption

func AutoscalingConfig_AsymmetricAutoscalingOption_ToProto 

func AutoscalingConfig_AsymmetricAutoscalingOption_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingConfig_AsymmetricAutoscalingOption) *pb.AutoscalingConfig_AsymmetricAutoscalingOption

func AutoscalingConfig_AutoscalingLimits_FromProto 

func AutoscalingConfig_AutoscalingLimits_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingConfig_AutoscalingLimits) *krm.AutoscalingConfig_AutoscalingLimits

func AutoscalingConfig_AutoscalingLimits_MaxNodes_ToProto 

func AutoscalingConfig_AutoscalingLimits_MaxNodes_ToProto(mapCtx *direct.MapContext, m *int32) *pb.AutoscalingConfig_AutoscalingLimits_MaxNodes

func AutoscalingConfig_AutoscalingLimits_MaxProcessingUnits_ToProto 

func AutoscalingConfig_AutoscalingLimits_MaxProcessingUnits_ToProto(mapCtx *direct.MapContext, m *int32) *pb.AutoscalingConfig_AutoscalingLimits_MaxProcessingUnits

func AutoscalingConfig_AutoscalingLimits_MinNodes_ToProto 

func AutoscalingConfig_AutoscalingLimits_MinNodes_ToProto(mapCtx *direct.MapContext, m *int32) *pb.AutoscalingConfig_AutoscalingLimits_MinNodes

func AutoscalingConfig_AutoscalingLimits_MinProcessingUnits_ToProto 

func AutoscalingConfig_AutoscalingLimits_MinProcessingUnits_ToProto(mapCtx *direct.MapContext, m *int32) *pb.AutoscalingConfig_AutoscalingLimits_MinProcessingUnits

func AutoscalingConfig_AutoscalingLimits_ToProto 

func AutoscalingConfig_AutoscalingLimits_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingConfig_AutoscalingLimits) *pb.AutoscalingConfig_AutoscalingLimits

func AutoscalingConfig_AutoscalingTargets_FromProto 

func AutoscalingConfig_AutoscalingTargets_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingConfig_AutoscalingTargets) *krm.AutoscalingConfig_AutoscalingTargets

func AutoscalingConfig_AutoscalingTargets_ToProto 

func AutoscalingConfig_AutoscalingTargets_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingConfig_AutoscalingTargets) *pb.AutoscalingConfig_AutoscalingTargets

func AutoscalingConfig_FromProto 

func AutoscalingConfig_FromProto(mapCtx *direct.MapContext, in *pb.AutoscalingConfig) *krm.AutoscalingConfig

func AutoscalingConfig_ToProto 

func AutoscalingConfig_ToProto(mapCtx *direct.MapContext, in *krm.AutoscalingConfig) *pb.AutoscalingConfig

func BackupScheduleSpecObservedState_FromProto added in v1.130.1 

func BackupScheduleSpecObservedState_FromProto(mapCtx *direct.MapContext, in *pb.BackupScheduleSpec) *krm.SpannerBackupScheduleObservedState

func BackupScheduleSpecObservedState_ToProto added in v1.130.1 

func BackupScheduleSpecObservedState_ToProto(mapCtx *direct.MapContext, in *krm.SpannerBackupScheduleObservedState) *pb.BackupScheduleSpec

func BackupScheduleSpec_FromProto added in v1.130.1 

func BackupScheduleSpec_FromProto(mapCtx *direct.MapContext, in *pb.BackupScheduleSpec) *krm.BackupScheduleSpec

func BackupScheduleSpec_ToProto added in v1.130.1 

func BackupScheduleSpec_ToProto(mapCtx *direct.MapContext, in *krm.BackupScheduleSpec) *pb.BackupScheduleSpec

func CreateBackupEncryptionConfig_FromProto added in v1.130.1 

func CreateBackupEncryptionConfig_FromProto(mapCtx *direct.MapContext, in *pb.CreateBackupEncryptionConfig) *krm.CreateBackupEncryptionConfig

func CreateBackupEncryptionConfig_ToProto added in v1.130.1 

func CreateBackupEncryptionConfig_ToProto(mapCtx *direct.MapContext, in *krm.CreateBackupEncryptionConfig) *pb.CreateBackupEncryptionConfig

func CrontabSpecObservedState_FromProto added in v1.130.1 

func CrontabSpecObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CrontabSpec) *krm.CrontabSpecObservedState

func CrontabSpecObservedState_ToProto added in v1.130.1 

func CrontabSpecObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CrontabSpecObservedState) *pb.CrontabSpec

func CrontabSpec_FromProto added in v1.130.1 

func CrontabSpec_FromProto(mapCtx *direct.MapContext, in *pb.CrontabSpec) *krm.CrontabSpec

func CrontabSpec_ToProto added in v1.130.1 

func CrontabSpec_ToProto(mapCtx *direct.MapContext, in *krm.CrontabSpec) *pb.CrontabSpec

func FullBackupSpec_FromProto added in v1.130.1 

func FullBackupSpec_FromProto(mapCtx *direct.MapContext, in *pb.FullBackupSpec) *krm.FullBackupSpec

func FullBackupSpec_ToProto added in v1.130.1 

func FullBackupSpec_ToProto(mapCtx *direct.MapContext, in *krm.FullBackupSpec) *pb.FullBackupSpec

func IncrementalBackupSpec_FromProto added in v1.130.1 

func IncrementalBackupSpec_FromProto(mapCtx *direct.MapContext, in *pb.IncrementalBackupSpec) *krm.IncrementalBackupSpec

func IncrementalBackupSpec_ToProto added in v1.130.1 

func IncrementalBackupSpec_ToProto(mapCtx *direct.MapContext, in *krm.IncrementalBackupSpec) *pb.IncrementalBackupSpec

func Instance_FromProto 

func Instance_FromProto(mapCtx *direct.MapContext, in *pb.Instance, parent *string) *krm.Instance

func Instance_ToProto 

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

func NewBackupScheduleModel added in v1.130.1 

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

func NewInstanceConfigModel added in v1.130.1 

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

func NewSpannerInstanceModel 

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

func ReplicaComputeCapacity_FromProto 

func ReplicaComputeCapacity_FromProto(mapCtx *direct.MapContext, in *pb.ReplicaComputeCapacity) *krm.ReplicaComputeCapacity

func ReplicaComputeCapacity_NodeCount_ToProto 

func ReplicaComputeCapacity_NodeCount_ToProto(mapCtx *direct.MapContext, m *int32) *pb.ReplicaComputeCapacity_NodeCount

func ReplicaComputeCapacity_ProcessingUnits_ToProto 

func ReplicaComputeCapacity_ProcessingUnits_ToProto(mapCtx *direct.MapContext, m *int32) *pb.ReplicaComputeCapacity_ProcessingUnits

func ReplicaComputeCapacity_ToProto 

func ReplicaComputeCapacity_ToProto(mapCtx *direct.MapContext, in *krm.ReplicaComputeCapacity) *pb.ReplicaComputeCapacity

func ReplicaInfo_FromProto added in v1.130.1 

func ReplicaInfo_FromProto(mapCtx *direct.MapContext, in *pb.ReplicaInfo) *krm.ReplicaInfo

func ReplicaInfo_ToProto added in v1.130.1 

func ReplicaInfo_ToProto(mapCtx *direct.MapContext, in *krm.ReplicaInfo) *pb.ReplicaInfo

func ReplicaSelection_FromProto 

func ReplicaSelection_FromProto(mapCtx *direct.MapContext, in *pb.ReplicaSelection) *krm.ReplicaSelection

func ReplicaSelection_ToProto 

func ReplicaSelection_ToProto(mapCtx *direct.MapContext, in *krm.ReplicaSelection) *pb.ReplicaSelection

func SpannerBackupScheduleObservedState_FromProto added in v1.130.1 

func SpannerBackupScheduleObservedState_FromProto(mapCtx *direct.MapContext, in *pb.BackupSchedule) *krm.SpannerBackupScheduleObservedState

func SpannerBackupScheduleObservedState_ToProto added in v1.130.1 

func SpannerBackupScheduleObservedState_ToProto(mapCtx *direct.MapContext, in *krm.SpannerBackupScheduleObservedState) *pb.BackupSchedule

func SpannerBackupScheduleSpec_FromProto added in v1.130.1 

func SpannerBackupScheduleSpec_FromProto(mapCtx *direct.MapContext, in *pb.BackupSchedule) *krm.SpannerBackupScheduleSpec

func SpannerBackupScheduleSpec_ToProto added in v1.130.1 

func SpannerBackupScheduleSpec_ToProto(mapCtx *direct.MapContext, in *krm.SpannerBackupScheduleSpec) *pb.BackupSchedule

func SpannerInstanceConfigObservedState_FromProto added in v1.130.1 

func SpannerInstanceConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.InstanceConfig) *krm.SpannerInstanceConfigObservedState

func SpannerInstanceConfigObservedState_ToProto added in v1.130.1 

func SpannerInstanceConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.SpannerInstanceConfigObservedState) *pb.InstanceConfig

func SpannerInstanceConfigSpec_FromProto added in v1.130.1 

func SpannerInstanceConfigSpec_FromProto(mapCtx *direct.MapContext, in *pb.InstanceConfig) *krm.SpannerInstanceConfigSpec

func SpannerInstanceConfigSpec_ToProto added in v1.130.1 

func SpannerInstanceConfigSpec_ToProto(mapCtx *direct.MapContext, in *krm.SpannerInstanceConfigSpec) *pb.InstanceConfig

func SpannerInstanceSpec_FromProto 

func SpannerInstanceSpec_FromProto(mapCtx *direct.MapContext, in *pb.Instance, configPrefix string) *krm.SpannerInstanceSpec

func SpannerInstanceSpec_ToProto 

func SpannerInstanceSpec_ToProto(mapCtx *direct.MapContext, in *krm.SpannerInstanceSpec, configPrefix string) *pb.Instance

func SpannerInstanceStatus_FromProto added in v1.128.0 

func SpannerInstanceStatus_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krm.SpannerInstanceStatus

func State_FromProto 

func State_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *string

Types

type BackupScheduleAdapter added in v1.130.1 

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

func (*BackupScheduleAdapter) Create added in v1.130.1 

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

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

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

func (*BackupScheduleAdapter) Export added in v1.130.1 

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

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

func (*BackupScheduleAdapter) Find added in v1.130.1 

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

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

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

func (*SpannerInstanceAdapter) Create 

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

func (*SpannerInstanceAdapter) Delete 

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

Delete implements the Adapter interface.

func (*SpannerInstanceAdapter) Export 

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

func (*SpannerInstanceAdapter) Find 

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

func (*SpannerInstanceAdapter) SpecValidation 

func (a *SpannerInstanceAdapter) SpecValidation() error

func (*SpannerInstanceAdapter) Update 

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

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.