memorystore

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AutomatedBackupConfig_FromProto added in v1.150.0

func AutomatedBackupConfig_FromProto(mapCtx *direct.MapContext, in *pb.AutomatedBackupConfig) *krmv1beta1.AutomatedBackupConfig

func AutomatedBackupConfig_ToProto added in v1.150.0

func AutomatedBackupConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.AutomatedBackupConfig) *pb.AutomatedBackupConfig

func CrossInstanceReplicationConfigObservedState_FromProto added in v1.150.0

func CrossInstanceReplicationConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig) *krm.CrossInstanceReplicationConfigObservedState

func CrossInstanceReplicationConfigObservedState_ToProto added in v1.150.0

func CrossInstanceReplicationConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfigObservedState) *pb.CrossInstanceReplicationConfig

func CrossInstanceReplicationConfig_FromProto added in v1.150.0

func CrossInstanceReplicationConfig_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig) *krm.CrossInstanceReplicationConfig

func CrossInstanceReplicationConfig_ToProto added in v1.150.0

func CrossInstanceReplicationConfig_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfig) *pb.CrossInstanceReplicationConfig

func DiscoveryEndpointObservedState_FromProto added in v1.150.0

func DiscoveryEndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DiscoveryEndpoint) *krm.DiscoveryEndpointObservedState

func DiscoveryEndpointObservedState_ToProto added in v1.150.0

func DiscoveryEndpointObservedState_ToProto(mapCtx *direct.MapContext, in *krm.DiscoveryEndpointObservedState) *pb.DiscoveryEndpoint

func EncryptionInfoObservedState_FromProto added in v1.153.0

func EncryptionInfoObservedState_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionInfo) *krmv1beta1.EncryptionInfoObservedState

func EncryptionInfoObservedState_ToProto added in v1.153.0

func EncryptionInfoObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.EncryptionInfoObservedState) *pb.EncryptionInfo

func EndpointObservedState_FromProto added in v1.150.0

func EndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krm.EndpointObservedState

func EndpointObservedState_ToProto added in v1.150.0

func EndpointObservedState_ToProto(mapCtx *direct.MapContext, in *krm.EndpointObservedState) *pb.Instance_InstanceEndpoint

func Endpoint_ConnectionDetailObservedState_FromProto added in v1.150.0

func Endpoint_ConnectionDetailObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krm.Endpoint_ConnectionDetailObservedState

func Endpoint_ConnectionDetailObservedState_ToProto added in v1.150.0

func Endpoint_ConnectionDetailObservedState_ToProto(mapCtx *direct.MapContext, in *krm.Endpoint_ConnectionDetailObservedState) *pb.Instance_ConnectionDetail

func Endpoint_ConnectionDetail_FromProto added in v1.150.0

func Endpoint_ConnectionDetail_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krm.Endpoint_ConnectionDetail

func Endpoint_ConnectionDetail_ToProto added in v1.150.0

func Endpoint_ConnectionDetail_ToProto(mapCtx *direct.MapContext, in *krm.Endpoint_ConnectionDetail) *pb.Instance_ConnectionDetail

func Endpoint_FromProto added in v1.150.0

func Endpoint_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krm.Endpoint

func Endpoint_ToProto added in v1.150.0

func Endpoint_ToProto(mapCtx *direct.MapContext, in *krm.Endpoint) *pb.Instance_InstanceEndpoint

func MaintenancePolicyObservedState_FromProto added in v1.150.0

func MaintenancePolicyObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MaintenancePolicy) *krm.MaintenancePolicyObservedState

func MaintenancePolicyObservedState_ToProto added in v1.150.0

func MaintenancePolicyObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MaintenancePolicyObservedState) *pb.MaintenancePolicy

func MaintenancePolicy_FromProto added in v1.150.0

func MaintenancePolicy_FromProto(mapCtx *direct.MapContext, in *pb.MaintenancePolicy) *krm.MaintenancePolicy

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

func Instance_StateInfo_UpdateInfoObservedState_ToProto(mapCtx *direct.MapContext, in *krm.Instance_StateInfo_UpdateInfoObservedState) *pb.Instance_StateInfo_UpdateInfo {
	if in == nil {
		return nil
	}
	out := &pb.Instance_StateInfo_UpdateInfo{}
	out.TargetShardCount = in.TargetShardCount
	out.TargetReplicaCount = in.TargetReplicaCount
	// MISSING: TargetEngineVersion
	// MISSING: TargetNodeType
	return out
}

func MaintenancePolicy_ToProto added in v1.150.0

func MaintenancePolicy_ToProto(mapCtx *direct.MapContext, in *krm.MaintenancePolicy) *pb.MaintenancePolicy

func MaintenanceScheduleObservedState_FromProto added in v1.150.0

func MaintenanceScheduleObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MaintenanceSchedule) *krm.MaintenanceScheduleObservedState

func MaintenanceScheduleObservedState_ToProto added in v1.150.0

func MaintenanceScheduleObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MaintenanceScheduleObservedState) *pb.MaintenanceSchedule

func MemorystoreInstanceEndpointObservedState_FromProto added in v1.150.0

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

func MemorystoreInstanceEndpointObservedState_ToProto added in v1.150.0

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

func MemorystoreInstanceEndpointSpec_FromProto added in v1.150.0

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

func MemorystoreInstanceEndpointSpec_ToProto added in v1.150.0

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

func MemorystoreInstanceObservedState_FromProto

func MemorystoreInstanceObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krmv1beta1.MemorystoreInstanceObservedState

func MemorystoreInstanceObservedState_ToProto

func MemorystoreInstanceObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.MemorystoreInstanceObservedState) *pb.Instance

func MemorystoreInstanceSpec_FromProto

func MemorystoreInstanceSpec_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krmv1beta1.MemorystoreInstanceSpec

func MemorystoreInstanceSpec_ToProto

func MemorystoreInstanceSpec_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.MemorystoreInstanceSpec) *pb.Instance

func NewEndpointModel added in v1.151.0

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

func NewInstanceModel added in v1.137.0

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

func NodeConfigObservedState_FromProto

func NodeConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.NodeConfig) *krmv1beta1.NodeConfigObservedState

func NodeConfigObservedState_ToProto

func NodeConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.NodeConfigObservedState) *pb.NodeConfig

func PersistenceConfig_FromProto

func PersistenceConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig) *krmv1beta1.PersistenceConfig

func PersistenceConfig_ToProto

func PersistenceConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PersistenceConfig) *pb.PersistenceConfig

func PscAttachmentDetailObservedState_FromProto added in v1.150.0

func PscAttachmentDetailObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PscAttachmentDetail) *krm.PscAttachmentDetailObservedState

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

func PersistenceConfig_RdbConfig_ToProto(mapCtx *direct.MapContext, in *krm.PersistenceConfig_RdbConfig) *pb.PersistenceConfig_RDBConfig {
	if in == nil {
		return nil
	}
	out := &pb.PersistenceConfig_RDBConfig{}
	out.RdbSnapshotPeriod = direct.Enum_ToProto[pb.PersistenceConfig_RDBConfig_SnapshotPeriod](mapCtx, in.RdbSnapshotPeriod)
	out.RdbSnapshotStartTime = direct.StringTimestamp_ToProto(mapCtx, in.RdbSnapshotStartTime)
	return out
}

func PscAttachmentDetailObservedState_ToProto added in v1.150.0

func PscAttachmentDetailObservedState_ToProto(mapCtx *direct.MapContext, in *krm.PscAttachmentDetailObservedState) *pb.PscAttachmentDetail

func PscAutoConnectionObservedState_Port_ToProto

func PscAutoConnectionObservedState_Port_ToProto(mapCtx *direct.MapContext, in *int32) *pb.PscAutoConnection_Port

func PscAutoConnection_FromProto

func PscAutoConnection_FromProto(mapCtx *direct.MapContext, in *pb.PscAutoConnection) *krmv1beta1.PscAutoConnection

func PscAutoConnection_ToProto

func PscAutoConnection_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PscAutoConnection) *pb.PscAutoConnection

func PscConnectionObservedState_v1alpha1_FromProto added in v1.150.0

func PscConnectionObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PscConnection) *krm.PscConnectionObservedState

func PscConnectionObservedState_v1alpha1_ToProto added in v1.150.0

func PscConnectionObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PscConnectionObservedState) *pb.PscConnection

func PscConnection_FromProto

func PscConnection_FromProto(mapCtx *direct.MapContext, in *pb.PscConnection) *krm.PscConnection

func PscConnection_Port_ToProto added in v1.150.0

func PscConnection_Port_ToProto(mapCtx *direct.MapContext, in *int32) *pb.PscConnection_Port

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

func PscConnection_ToProto(mapCtx *direct.MapContext, in *krmmemorystorev1alpha1.PscConnection) *pb.PscConnection {
	if in == nil {
		return nil
	}
	out := &pb.PscConnection{}
	if oneof := PscConnection_Port_ToProto(mapCtx, in.Port); oneof != nil {
		out.Ports = oneof
	}
	// MISSING: PSCConnectionID
	// MISSING: IPAddress
	if in.ForwardingRuleRef != nil {
		out.ForwardingRule = in.ForwardingRuleRef.External
	}
	// MISSING: ProjectID
	// MISSING: Network
	// MISSING: ServiceAttachment
	// MISSING: PSCConnectionStatus
	// MISSING: ConnectionType
	return out
}

func PscConnection_ToProto

func PscConnection_ToProto(mapCtx *direct.MapContext, in *krm.PscConnection) *pb.PscConnection

func TimeOfDay_FromProto added in v1.150.0

func TimeOfDay_FromProto(mapCtx *direct.MapContext, in *timeofdaypb.TimeOfDay) *krm.TimeOfDay

func TimeOfDay_ToProto added in v1.150.0

func TimeOfDay_ToProto(mapCtx *direct.MapContext, in *krm.TimeOfDay) *timeofdaypb.TimeOfDay

func WeeklyMaintenanceWindow_FromProto added in v1.150.0

func WeeklyMaintenanceWindow_FromProto(mapCtx *direct.MapContext, in *pb.WeeklyMaintenanceWindow) *krm.WeeklyMaintenanceWindow

func WeeklyMaintenanceWindow_ToProto added in v1.150.0

func WeeklyMaintenanceWindow_ToProto(mapCtx *direct.MapContext, in *krm.WeeklyMaintenanceWindow) *pb.WeeklyMaintenanceWindow

Types

type EndpointAdapter added in v1.151.0

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

func (*EndpointAdapter) Create added in v1.151.0

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

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

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

func (*EndpointAdapter) Export added in v1.151.0

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

func (*EndpointAdapter) Find added in v1.151.0

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

func (a *EndpointAdapter) 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 InstanceAdapter added in v1.137.0

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

func (*InstanceAdapter) Create added in v1.137.0

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

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

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

func (*InstanceAdapter) Export added in v1.137.0

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

func (*InstanceAdapter) Find added in v1.137.0

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL