Documentation
¶
Index ¶
- func AutomatedBackupConfig_FixedFrequencySchedule_FromProto(mapCtx *direct.MapContext, in *pb.AutomatedBackupConfig_FixedFrequencySchedule) *krmv1beta1.AutomatedBackupConfig_FixedFrequencySchedule
- func AutomatedBackupConfig_FixedFrequencySchedule_ToProto(mapCtx *direct.MapContext, ...) *pb.AutomatedBackupConfig_FixedFrequencySchedule
- func AutomatedBackupConfig_FromProto(mapCtx *direct.MapContext, in *pb.AutomatedBackupConfig) *krmv1beta1.AutomatedBackupConfig
- func AutomatedBackupConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.AutomatedBackupConfig) *pb.AutomatedBackupConfig
- func CrossInstanceReplicationConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig) *krm.CrossInstanceReplicationConfigObservedState
- func CrossInstanceReplicationConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfigObservedState) *pb.CrossInstanceReplicationConfig
- func CrossInstanceReplicationConfig_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig) *krm.CrossInstanceReplicationConfig
- func CrossInstanceReplicationConfig_MembershipObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig_Membership) *krm.CrossInstanceReplicationConfig_MembershipObservedState
- func CrossInstanceReplicationConfig_MembershipObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.CrossInstanceReplicationConfig_Membership
- func CrossInstanceReplicationConfig_RemoteInstanceObservedState_FromProto(mapCtx *direct.MapContext, ...) *krm.CrossInstanceReplicationConfig_RemoteInstanceObservedState
- func CrossInstanceReplicationConfig_RemoteInstanceObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.CrossInstanceReplicationConfig_RemoteInstance
- func CrossInstanceReplicationConfig_RemoteInstance_FromProto(mapCtx *direct.MapContext, ...) *krm.CrossInstanceReplicationConfig_RemoteInstance
- func CrossInstanceReplicationConfig_RemoteInstance_ToProto(mapCtx *direct.MapContext, ...) *pb.CrossInstanceReplicationConfig_RemoteInstance
- func CrossInstanceReplicationConfig_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfig) *pb.CrossInstanceReplicationConfig
- func DiscoveryEndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.DiscoveryEndpoint) *krm.DiscoveryEndpointObservedState
- func DiscoveryEndpointObservedState_ToProto(mapCtx *direct.MapContext, in *krm.DiscoveryEndpointObservedState) *pb.DiscoveryEndpoint
- func EncryptionInfoObservedState_FromProto(mapCtx *direct.MapContext, in *pb.EncryptionInfo) *krmv1beta1.EncryptionInfoObservedState
- func EncryptionInfoObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.EncryptionInfoObservedState) *pb.EncryptionInfo
- func EndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krm.EndpointObservedState
- func EndpointObservedState_ToProto(mapCtx *direct.MapContext, in *krm.EndpointObservedState) *pb.Instance_InstanceEndpoint
- func Endpoint_ConnectionDetailObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krm.Endpoint_ConnectionDetailObservedState
- func Endpoint_ConnectionDetailObservedState_ToProto(mapCtx *direct.MapContext, in *krm.Endpoint_ConnectionDetailObservedState) *pb.Instance_ConnectionDetail
- func Endpoint_ConnectionDetail_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krm.Endpoint_ConnectionDetail
- func Endpoint_ConnectionDetail_ToProto(mapCtx *direct.MapContext, in *krm.Endpoint_ConnectionDetail) *pb.Instance_ConnectionDetail
- func Endpoint_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krm.Endpoint
- func Endpoint_ToProto(mapCtx *direct.MapContext, in *krm.Endpoint) *pb.Instance_InstanceEndpoint
- func Instance_ConnectionDetailObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krmv1beta1.Instance_ConnectionDetailObservedState
- func Instance_ConnectionDetailObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.Instance_ConnectionDetail
- func Instance_ConnectionDetail_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krmv1beta1.Instance_ConnectionDetail
- func Instance_ConnectionDetail_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_ConnectionDetail) *pb.Instance_ConnectionDetail
- func Instance_InstanceEndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krmv1beta1.Instance_InstanceEndpointObservedState
- func Instance_InstanceEndpointObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.Instance_InstanceEndpoint
- func Instance_InstanceEndpoint_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krmv1beta1.Instance_InstanceEndpoint
- func Instance_InstanceEndpoint_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_InstanceEndpoint) *pb.Instance_InstanceEndpoint
- func Instance_StateInfoObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_StateInfo) *krmv1beta1.Instance_StateInfoObservedState
- func Instance_StateInfoObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_StateInfoObservedState) *pb.Instance_StateInfo
- func Instance_StateInfo_UpdateInfoObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_StateInfo_UpdateInfo) *krmv1beta1.Instance_StateInfo_UpdateInfoObservedState
- func Instance_StateInfo_UpdateInfoObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.Instance_StateInfo_UpdateInfo
- func MaintenancePolicyObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MaintenancePolicy) *krm.MaintenancePolicyObservedState
- func MaintenancePolicyObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MaintenancePolicyObservedState) *pb.MaintenancePolicy
- func MaintenancePolicy_FromProto(mapCtx *direct.MapContext, in *pb.MaintenancePolicy) *krm.MaintenancePolicy
- func MaintenancePolicy_ToProto(mapCtx *direct.MapContext, in *krm.MaintenancePolicy) *pb.MaintenancePolicy
- func MaintenanceScheduleObservedState_FromProto(mapCtx *direct.MapContext, in *pb.MaintenanceSchedule) *krm.MaintenanceScheduleObservedState
- func MaintenanceScheduleObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MaintenanceScheduleObservedState) *pb.MaintenanceSchedule
- func MemorystoreInstanceEndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krm.MemorystoreInstanceEndpointObservedState
- func MemorystoreInstanceEndpointObservedState_ToProto(mapCtx *direct.MapContext, in *krm.MemorystoreInstanceEndpointObservedState) *pb.Instance
- func MemorystoreInstanceEndpointSpec_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krm.MemorystoreInstanceEndpointSpec
- func MemorystoreInstanceEndpointSpec_ToProto(mapCtx *direct.MapContext, in *krm.MemorystoreInstanceEndpointSpec) *pb.Instance
- func MemorystoreInstanceObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krmv1beta1.MemorystoreInstanceObservedState
- func MemorystoreInstanceObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.MemorystoreInstanceObservedState) *pb.Instance
- func MemorystoreInstanceSpec_FromProto(mapCtx *direct.MapContext, in *pb.Instance) *krmv1beta1.MemorystoreInstanceSpec
- func MemorystoreInstanceSpec_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.MemorystoreInstanceSpec) *pb.Instance
- func NewEndpointModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
- func NewInstanceModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)
- func NodeConfigObservedState_FromProto(mapCtx *direct.MapContext, in *pb.NodeConfig) *krmv1beta1.NodeConfigObservedState
- func NodeConfigObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.NodeConfigObservedState) *pb.NodeConfig
- func PersistenceConfig_AofConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig_AOFConfig) *krmv1beta1.PersistenceConfig_AofConfig
- func PersistenceConfig_AofConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PersistenceConfig_AofConfig) *pb.PersistenceConfig_AOFConfig
- func PersistenceConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig) *krmv1beta1.PersistenceConfig
- func PersistenceConfig_RdbConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig_RDBConfig) *krmv1beta1.PersistenceConfig_RdbConfig
- func PersistenceConfig_RdbConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PersistenceConfig_RdbConfig) *pb.PersistenceConfig_RDBConfig
- func PersistenceConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PersistenceConfig) *pb.PersistenceConfig
- func PscAttachmentDetailObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PscAttachmentDetail) *krm.PscAttachmentDetailObservedState
- func PscAttachmentDetailObservedState_ToProto(mapCtx *direct.MapContext, in *krm.PscAttachmentDetailObservedState) *pb.PscAttachmentDetail
- func PscAutoConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PscAutoConnection) *krmv1beta1.PscAutoConnectionObservedState
- func PscAutoConnectionObservedState_Port_ToProto(mapCtx *direct.MapContext, in *int32) *pb.PscAutoConnection_Port
- func PscAutoConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PscAutoConnectionObservedState) *pb.PscAutoConnection
- func PscAutoConnection_FromProto(mapCtx *direct.MapContext, in *pb.PscAutoConnection) *krmv1beta1.PscAutoConnection
- func PscAutoConnection_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PscAutoConnection) *pb.PscAutoConnection
- func PscConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PscConnection) *krmmemorystorev1alpha1.PscConnectionObservedState
- func PscConnectionObservedState_ToProto(mapCtx *direct.MapContext, ...) *pb.PscConnection
- func PscConnectionObservedState_v1alpha1_FromProto(mapCtx *direct.MapContext, in *pb.PscConnection) *krm.PscConnectionObservedState
- func PscConnectionObservedState_v1alpha1_ToProto(mapCtx *direct.MapContext, in *krm.PscConnectionObservedState) *pb.PscConnection
- func PscConnection_FromProto(mapCtx *direct.MapContext, in *pb.PscConnection) *krm.PscConnection
- func PscConnection_Port_ToProto(mapCtx *direct.MapContext, in *int32) *pb.PscConnection_Port
- func PscConnection_ToProto(mapCtx *direct.MapContext, in *krm.PscConnection) *pb.PscConnection
- func TimeOfDay_FromProto(mapCtx *direct.MapContext, in *timeofdaypb.TimeOfDay) *krm.TimeOfDay
- func TimeOfDay_ToProto(mapCtx *direct.MapContext, in *krm.TimeOfDay) *timeofdaypb.TimeOfDay
- func WeeklyMaintenanceWindow_FromProto(mapCtx *direct.MapContext, in *pb.WeeklyMaintenanceWindow) *krm.WeeklyMaintenanceWindow
- func WeeklyMaintenanceWindow_ToProto(mapCtx *direct.MapContext, in *krm.WeeklyMaintenanceWindow) *pb.WeeklyMaintenanceWindow
- func ZoneDistributionConfig_FromProto(mapCtx *direct.MapContext, in *pb.ZoneDistributionConfig) *krmv1beta1.ZoneDistributionConfig
- func ZoneDistributionConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.ZoneDistributionConfig) *pb.ZoneDistributionConfig
- type EndpointAdapter
- func (a *EndpointAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
- func (a *EndpointAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
- func (a *EndpointAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
- func (a *EndpointAdapter) Find(ctx context.Context) (bool, error)
- func (a *EndpointAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error
- type InstanceAdapter
- func (a *InstanceAdapter) Create(ctx context.Context, createOp *directbase.CreateOperation) error
- func (a *InstanceAdapter) Delete(ctx context.Context, deleteOp *directbase.DeleteOperation) (bool, error)
- func (a *InstanceAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
- func (a *InstanceAdapter) Find(ctx context.Context) (bool, error)
- func (a *InstanceAdapter) Update(ctx context.Context, updateOp *directbase.UpdateOperation) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AutomatedBackupConfig_FixedFrequencySchedule_FromProto ¶ added in v1.150.0
func AutomatedBackupConfig_FixedFrequencySchedule_FromProto(mapCtx *direct.MapContext, in *pb.AutomatedBackupConfig_FixedFrequencySchedule) *krmv1beta1.AutomatedBackupConfig_FixedFrequencySchedule
func AutomatedBackupConfig_FixedFrequencySchedule_ToProto ¶ added in v1.150.0
func AutomatedBackupConfig_FixedFrequencySchedule_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.AutomatedBackupConfig_FixedFrequencySchedule) *pb.AutomatedBackupConfig_FixedFrequencySchedule
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_MembershipObservedState_FromProto ¶ added in v1.150.0
func CrossInstanceReplicationConfig_MembershipObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig_Membership) *krm.CrossInstanceReplicationConfig_MembershipObservedState
func CrossInstanceReplicationConfig_MembershipObservedState_ToProto ¶ added in v1.150.0
func CrossInstanceReplicationConfig_MembershipObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfig_MembershipObservedState) *pb.CrossInstanceReplicationConfig_Membership
func CrossInstanceReplicationConfig_RemoteInstanceObservedState_FromProto ¶ added in v1.150.0
func CrossInstanceReplicationConfig_RemoteInstanceObservedState_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig_RemoteInstance) *krm.CrossInstanceReplicationConfig_RemoteInstanceObservedState
func CrossInstanceReplicationConfig_RemoteInstanceObservedState_ToProto ¶ added in v1.150.0
func CrossInstanceReplicationConfig_RemoteInstanceObservedState_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfig_RemoteInstanceObservedState) *pb.CrossInstanceReplicationConfig_RemoteInstance
func CrossInstanceReplicationConfig_RemoteInstance_FromProto ¶ added in v1.150.0
func CrossInstanceReplicationConfig_RemoteInstance_FromProto(mapCtx *direct.MapContext, in *pb.CrossInstanceReplicationConfig_RemoteInstance) *krm.CrossInstanceReplicationConfig_RemoteInstance
func CrossInstanceReplicationConfig_RemoteInstance_ToProto ¶ added in v1.150.0
func CrossInstanceReplicationConfig_RemoteInstance_ToProto(mapCtx *direct.MapContext, in *krm.CrossInstanceReplicationConfig_RemoteInstance) *pb.CrossInstanceReplicationConfig_RemoteInstance
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 Instance_ConnectionDetailObservedState_FromProto ¶
func Instance_ConnectionDetailObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krmv1beta1.Instance_ConnectionDetailObservedState
func Instance_ConnectionDetailObservedState_ToProto ¶
func Instance_ConnectionDetailObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_ConnectionDetailObservedState) *pb.Instance_ConnectionDetail
func Instance_ConnectionDetail_FromProto ¶
func Instance_ConnectionDetail_FromProto(mapCtx *direct.MapContext, in *pb.Instance_ConnectionDetail) *krmv1beta1.Instance_ConnectionDetail
func Instance_ConnectionDetail_ToProto ¶
func Instance_ConnectionDetail_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_ConnectionDetail) *pb.Instance_ConnectionDetail
func Instance_InstanceEndpointObservedState_FromProto ¶
func Instance_InstanceEndpointObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krmv1beta1.Instance_InstanceEndpointObservedState
func Instance_InstanceEndpointObservedState_ToProto ¶
func Instance_InstanceEndpointObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_InstanceEndpointObservedState) *pb.Instance_InstanceEndpoint
func Instance_InstanceEndpoint_FromProto ¶
func Instance_InstanceEndpoint_FromProto(mapCtx *direct.MapContext, in *pb.Instance_InstanceEndpoint) *krmv1beta1.Instance_InstanceEndpoint
func Instance_InstanceEndpoint_ToProto ¶
func Instance_InstanceEndpoint_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_InstanceEndpoint) *pb.Instance_InstanceEndpoint
func Instance_StateInfoObservedState_FromProto ¶
func Instance_StateInfoObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_StateInfo) *krmv1beta1.Instance_StateInfoObservedState
func Instance_StateInfoObservedState_ToProto ¶
func Instance_StateInfoObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_StateInfoObservedState) *pb.Instance_StateInfo
func Instance_StateInfo_UpdateInfoObservedState_FromProto ¶
func Instance_StateInfo_UpdateInfoObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Instance_StateInfo_UpdateInfo) *krmv1beta1.Instance_StateInfo_UpdateInfoObservedState
func Instance_StateInfo_UpdateInfoObservedState_ToProto ¶
func Instance_StateInfo_UpdateInfoObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.Instance_StateInfo_UpdateInfoObservedState) *pb.Instance_StateInfo_UpdateInfo
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_AofConfig_FromProto ¶
func PersistenceConfig_AofConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig_AOFConfig) *krmv1beta1.PersistenceConfig_AofConfig
func PersistenceConfig_AofConfig_ToProto ¶
func PersistenceConfig_AofConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PersistenceConfig_AofConfig) *pb.PersistenceConfig_AOFConfig
func PersistenceConfig_FromProto ¶
func PersistenceConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig) *krmv1beta1.PersistenceConfig
func PersistenceConfig_RdbConfig_FromProto ¶
func PersistenceConfig_RdbConfig_FromProto(mapCtx *direct.MapContext, in *pb.PersistenceConfig_RDBConfig) *krmv1beta1.PersistenceConfig_RdbConfig
func PersistenceConfig_RdbConfig_ToProto ¶
func PersistenceConfig_RdbConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PersistenceConfig_RdbConfig) *pb.PersistenceConfig_RDBConfig
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_FromProto ¶
func PscAutoConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PscAutoConnection) *krmv1beta1.PscAutoConnectionObservedState
func PscAutoConnectionObservedState_Port_ToProto ¶
func PscAutoConnectionObservedState_Port_ToProto(mapCtx *direct.MapContext, in *int32) *pb.PscAutoConnection_Port
func PscAutoConnectionObservedState_ToProto ¶
func PscAutoConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.PscAutoConnectionObservedState) *pb.PscAutoConnection
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_FromProto ¶
func PscConnectionObservedState_FromProto(mapCtx *direct.MapContext, in *pb.PscConnection) *krmmemorystorev1alpha1.PscConnectionObservedState
func PscConnectionObservedState_ToProto ¶
func PscConnectionObservedState_ToProto(mapCtx *direct.MapContext, in *krmmemorystorev1alpha1.PscConnectionObservedState) *pb.PscConnection
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
func ZoneDistributionConfig_FromProto ¶
func ZoneDistributionConfig_FromProto(mapCtx *direct.MapContext, in *pb.ZoneDistributionConfig) *krmv1beta1.ZoneDistributionConfig
func ZoneDistributionConfig_ToProto ¶
func ZoneDistributionConfig_ToProto(mapCtx *direct.MapContext, in *krmv1beta1.ZoneDistributionConfig) *pb.ZoneDistributionConfig
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
func (a *EndpointAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
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
func (a *InstanceAdapter) Export(ctx context.Context) (*unstructured.Unstructured, error)
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.