Versions in this module Expand all Collapse all v0 v0.5.0 May 8, 2022 Changes in this version + type ConsumerChannel struct + Spec ConsumerChannelSpec + Status ConsumerChannelStatus + func (in *ConsumerChannel) DeepCopy() *ConsumerChannel + func (in *ConsumerChannel) DeepCopyInto(out *ConsumerChannel) + func (in *ConsumerChannel) DeepCopyObject() runtime.Object + func (r *ConsumerChannel) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *ConsumerChannel) ValidateCreate() error + func (r *ConsumerChannel) ValidateDelete() error + func (r *ConsumerChannel) ValidateUpdate(old runtime.Object) error + type ConsumerChannelList struct + Items []ConsumerChannel + func (in *ConsumerChannelList) DeepCopy() *ConsumerChannelList + func (in *ConsumerChannelList) DeepCopyInto(out *ConsumerChannelList) + func (in *ConsumerChannelList) DeepCopyObject() runtime.Object + type ConsumerChannelSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource ConsumerChannelSpecResource + State *ConsumerChannelSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *ConsumerChannelSpec) DeepCopy() *ConsumerChannelSpec + func (in *ConsumerChannelSpec) DeepCopyInto(out *ConsumerChannelSpec) + type ConsumerChannelSpecResource struct + ConsumerGroupID *string + ConsumerGroupName *string + ConsumerGroupPassword *string + ConsumerGroupUserName *string + DtsInstanceID *string + ID string + func (in *ConsumerChannelSpecResource) DeepCopy() *ConsumerChannelSpecResource + func (in *ConsumerChannelSpecResource) DeepCopyInto(out *ConsumerChannelSpecResource) + type ConsumerChannelStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *ConsumerChannelStatus) DeepCopy() *ConsumerChannelStatus + func (in *ConsumerChannelStatus) DeepCopyInto(out *ConsumerChannelStatus) + type MigrationInstance struct + Spec MigrationInstanceSpec + Status MigrationInstanceStatus + func (in *MigrationInstance) DeepCopy() *MigrationInstance + func (in *MigrationInstance) DeepCopyInto(out *MigrationInstance) + func (in *MigrationInstance) DeepCopyObject() runtime.Object + func (r *MigrationInstance) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *MigrationInstance) ValidateCreate() error + func (r *MigrationInstance) ValidateDelete() error + func (r *MigrationInstance) ValidateUpdate(old runtime.Object) error + type MigrationInstanceList struct + Items []MigrationInstance + func (in *MigrationInstanceList) DeepCopy() *MigrationInstanceList + func (in *MigrationInstanceList) DeepCopyInto(out *MigrationInstanceList) + func (in *MigrationInstanceList) DeepCopyObject() runtime.Object + type MigrationInstanceSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource MigrationInstanceSpecResource + State *MigrationInstanceSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *MigrationInstanceSpec) DeepCopy() *MigrationInstanceSpec + func (in *MigrationInstanceSpec) DeepCopyInto(out *MigrationInstanceSpec) + type MigrationInstanceSpecResource struct + ComputeUnit *int64 + DatabaseCount *int64 + DestinationEndpointEngineName *string + DestinationEndpointRegion *string + DtsInstanceID *string + ID string + InstanceClass *string + PaymentType *string + SourceEndpointEngineName *string + SourceEndpointRegion *string + Status *string + SyncArchitecture *string + Tags map[string]string + func (in *MigrationInstanceSpecResource) DeepCopy() *MigrationInstanceSpecResource + func (in *MigrationInstanceSpecResource) DeepCopyInto(out *MigrationInstanceSpecResource) + type MigrationInstanceStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *MigrationInstanceStatus) DeepCopy() *MigrationInstanceStatus + func (in *MigrationInstanceStatus) DeepCopyInto(out *MigrationInstanceStatus) + type MigrationJob struct + Spec MigrationJobSpec + Status MigrationJobStatus + func (in *MigrationJob) DeepCopy() *MigrationJob + func (in *MigrationJob) DeepCopyInto(out *MigrationJob) + func (in *MigrationJob) DeepCopyObject() runtime.Object + func (r *MigrationJob) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *MigrationJob) ValidateCreate() error + func (r *MigrationJob) ValidateDelete() error + func (r *MigrationJob) ValidateUpdate(old runtime.Object) error + type MigrationJobList struct + Items []MigrationJob + func (in *MigrationJobList) DeepCopy() *MigrationJobList + func (in *MigrationJobList) DeepCopyInto(out *MigrationJobList) + func (in *MigrationJobList) DeepCopyObject() runtime.Object + type MigrationJobSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource MigrationJobSpecResource + State *MigrationJobSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *MigrationJobSpec) DeepCopy() *MigrationJobSpec + func (in *MigrationJobSpec) DeepCopyInto(out *MigrationJobSpec) + type MigrationJobSpecResource struct + Checkpoint *string + DataInitialization *bool + DataSynchronization *bool + DbList *string + DestinationEndpointDatabaseName *string + DestinationEndpointEngineName *string + DestinationEndpointIP *string + DestinationEndpointInstanceID *string + DestinationEndpointInstanceType *string + DestinationEndpointOracleSid *string + DestinationEndpointPassword *string + DestinationEndpointPort *string + DestinationEndpointRegion *string + DestinationEndpointUserName *string + DtsInstanceID *string + DtsJobName *string + ID string + InstanceClass *string + SourceEndpointDatabaseName *string + SourceEndpointEngineName *string + SourceEndpointIP *string + SourceEndpointInstanceID *string + SourceEndpointInstanceType *string + SourceEndpointOracleSid *string + SourceEndpointOwnerID *string + SourceEndpointPassword *string + SourceEndpointPort *string + SourceEndpointRegion *string + SourceEndpointRole *string + SourceEndpointUserName *string + Status *string + StructureInitialization *bool + Timeouts *base.ResourceTimeout + func (in *MigrationJobSpecResource) DeepCopy() *MigrationJobSpecResource + func (in *MigrationJobSpecResource) DeepCopyInto(out *MigrationJobSpecResource) + type MigrationJobStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *MigrationJobStatus) DeepCopy() *MigrationJobStatus + func (in *MigrationJobStatus) DeepCopyInto(out *MigrationJobStatus) type SynchronizationInstanceSpecResource + AutoPay *string + AutoStart *string v0.4.0 Oct 28, 2021 Changes in this version + var AddToScheme = localSchemeBuilder.AddToScheme + var SchemeBuilder runtime.SchemeBuilder + var SchemeGroupVersion = schema.GroupVersion + func GetDecoder() map[string]jsoniter.ValDecoder + func GetEncoder() map[string]jsoniter.ValEncoder + func Kind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + type JobMonitorRule struct + Spec JobMonitorRuleSpec + Status JobMonitorRuleStatus + func (in *JobMonitorRule) DeepCopy() *JobMonitorRule + func (in *JobMonitorRule) DeepCopyInto(out *JobMonitorRule) + func (in *JobMonitorRule) DeepCopyObject() runtime.Object + func (r *JobMonitorRule) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *JobMonitorRule) ValidateCreate() error + func (r *JobMonitorRule) ValidateDelete() error + func (r *JobMonitorRule) ValidateUpdate(old runtime.Object) error + type JobMonitorRuleList struct + Items []JobMonitorRule + func (in *JobMonitorRuleList) DeepCopy() *JobMonitorRuleList + func (in *JobMonitorRuleList) DeepCopyInto(out *JobMonitorRuleList) + func (in *JobMonitorRuleList) DeepCopyObject() runtime.Object + type JobMonitorRuleSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource JobMonitorRuleSpecResource + State *JobMonitorRuleSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *JobMonitorRuleSpec) DeepCopy() *JobMonitorRuleSpec + func (in *JobMonitorRuleSpec) DeepCopyInto(out *JobMonitorRuleSpec) + type JobMonitorRuleSpecResource struct + DelayRuleTime *string + DtsJobID *string + ID string + Phone *string + State *string + Type *string + func (in *JobMonitorRuleSpecResource) DeepCopy() *JobMonitorRuleSpecResource + func (in *JobMonitorRuleSpecResource) DeepCopyInto(out *JobMonitorRuleSpecResource) + type JobMonitorRuleStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *JobMonitorRuleStatus) DeepCopy() *JobMonitorRuleStatus + func (in *JobMonitorRuleStatus) DeepCopyInto(out *JobMonitorRuleStatus) + type SubscriptionJob struct + Spec SubscriptionJobSpec + Status SubscriptionJobStatus + func (in *SubscriptionJob) DeepCopy() *SubscriptionJob + func (in *SubscriptionJob) DeepCopyInto(out *SubscriptionJob) + func (in *SubscriptionJob) DeepCopyObject() runtime.Object + func (r *SubscriptionJob) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *SubscriptionJob) ValidateCreate() error + func (r *SubscriptionJob) ValidateDelete() error + func (r *SubscriptionJob) ValidateUpdate(old runtime.Object) error + type SubscriptionJobList struct + Items []SubscriptionJob + func (in *SubscriptionJobList) DeepCopy() *SubscriptionJobList + func (in *SubscriptionJobList) DeepCopyInto(out *SubscriptionJobList) + func (in *SubscriptionJobList) DeepCopyObject() runtime.Object + type SubscriptionJobSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource SubscriptionJobSpecResource + State *SubscriptionJobSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *SubscriptionJobSpec) DeepCopy() *SubscriptionJobSpec + func (in *SubscriptionJobSpec) DeepCopyInto(out *SubscriptionJobSpec) + type SubscriptionJobSpecResource struct + Checkpoint *string + ComputeUnit *int64 + DatabaseCount *int64 + DbList *string + DelayNotice *bool + DelayPhone *string + DelayRuleTime *string + DestinationEndpointEngineName *string + DestinationRegion *string + DtsInstanceID *string + DtsJobName *string + ErrorNotice *bool + ErrorPhone *string + ID string + InstanceClass *string + PaymentDuration *int64 + PaymentDurationUnit *string + PaymentType *string + Reserve *string + SourceEndpointDatabaseName *string + SourceEndpointEngineName *string + SourceEndpointIP *string + SourceEndpointInstanceID *string + SourceEndpointInstanceType *string + SourceEndpointOracleSid *string + SourceEndpointOwnerID *string + SourceEndpointPassword *string + SourceEndpointPort *string + SourceEndpointRegion *string + SourceEndpointRole *string + SourceEndpointUserName *string + Status *string + SubscriptionDataTypeDdl *bool + SubscriptionDataTypeDml *bool + SubscriptionInstanceNetworkType *string + SubscriptionInstanceVpcID *string + SubscriptionInstanceVswitchID *string + SyncArchitecture *string + SynchronizationDirection *string + Tags map[string]string + Timeouts *base.ResourceTimeout + func (in *SubscriptionJobSpecResource) DeepCopy() *SubscriptionJobSpecResource + func (in *SubscriptionJobSpecResource) DeepCopyInto(out *SubscriptionJobSpecResource) + type SubscriptionJobStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *SubscriptionJobStatus) DeepCopy() *SubscriptionJobStatus + func (in *SubscriptionJobStatus) DeepCopyInto(out *SubscriptionJobStatus) + type SynchronizationInstance struct + Spec SynchronizationInstanceSpec + Status SynchronizationInstanceStatus + func (in *SynchronizationInstance) DeepCopy() *SynchronizationInstance + func (in *SynchronizationInstance) DeepCopyInto(out *SynchronizationInstance) + func (in *SynchronizationInstance) DeepCopyObject() runtime.Object + func (r *SynchronizationInstance) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *SynchronizationInstance) ValidateCreate() error + func (r *SynchronizationInstance) ValidateDelete() error + func (r *SynchronizationInstance) ValidateUpdate(old runtime.Object) error + type SynchronizationInstanceList struct + Items []SynchronizationInstance + func (in *SynchronizationInstanceList) DeepCopy() *SynchronizationInstanceList + func (in *SynchronizationInstanceList) DeepCopyInto(out *SynchronizationInstanceList) + func (in *SynchronizationInstanceList) DeepCopyObject() runtime.Object + type SynchronizationInstanceSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource SynchronizationInstanceSpecResource + State *SynchronizationInstanceSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *SynchronizationInstanceSpec) DeepCopy() *SynchronizationInstanceSpec + func (in *SynchronizationInstanceSpec) DeepCopyInto(out *SynchronizationInstanceSpec) + type SynchronizationInstanceSpecResource struct + ComputeUnit *int64 + DatabaseCount *int64 + DestinationEndpointEngineName *string + DestinationEndpointRegion *string + ID string + InstanceClass *string + PaymentDuration *int64 + PaymentDurationUnit *string + PaymentType *string + Quantity *int64 + SourceEndpointEngineName *string + SourceEndpointRegion *string + Status *string + SyncArchitecture *string + func (in *SynchronizationInstanceSpecResource) DeepCopy() *SynchronizationInstanceSpecResource + func (in *SynchronizationInstanceSpecResource) DeepCopyInto(out *SynchronizationInstanceSpecResource) + type SynchronizationInstanceStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *SynchronizationInstanceStatus) DeepCopy() *SynchronizationInstanceStatus + func (in *SynchronizationInstanceStatus) DeepCopyInto(out *SynchronizationInstanceStatus) + type SynchronizationJob struct + Spec SynchronizationJobSpec + Status SynchronizationJobStatus + func (in *SynchronizationJob) DeepCopy() *SynchronizationJob + func (in *SynchronizationJob) DeepCopyInto(out *SynchronizationJob) + func (in *SynchronizationJob) DeepCopyObject() runtime.Object + func (r *SynchronizationJob) SetupWebhookWithManager(mgr ctrl.Manager) error + func (r *SynchronizationJob) ValidateCreate() error + func (r *SynchronizationJob) ValidateDelete() error + func (r *SynchronizationJob) ValidateUpdate(old runtime.Object) error + type SynchronizationJobList struct + Items []SynchronizationJob + func (in *SynchronizationJobList) DeepCopy() *SynchronizationJobList + func (in *SynchronizationJobList) DeepCopyInto(out *SynchronizationJobList) + func (in *SynchronizationJobList) DeepCopyObject() runtime.Object + type SynchronizationJobSpec struct + BackendRef *core.LocalObjectReference + ProviderRef core.LocalObjectReference + Resource SynchronizationJobSpecResource + State *SynchronizationJobSpecResource + TerminationPolicy base.TerminationPolicy + UpdatePolicy base.UpdatePolicy + func (in *SynchronizationJobSpec) DeepCopy() *SynchronizationJobSpec + func (in *SynchronizationJobSpec) DeepCopyInto(out *SynchronizationJobSpec) + type SynchronizationJobSpecResource struct + Checkpoint *string + DataInitialization *bool + DataSynchronization *bool + DbList *string + DelayNotice *bool + DelayPhone *string + DelayRuleTime *string + DestinationEndpointDatabaseName *string + DestinationEndpointEngineName *string + DestinationEndpointIP *string + DestinationEndpointInstanceID *string + DestinationEndpointInstanceType *string + DestinationEndpointOracleSid *string + DestinationEndpointPassword *string + DestinationEndpointPort *string + DestinationEndpointRegion *string + DestinationEndpointUserName *string + DtsInstanceID *string + DtsJobName *string + ErrorNotice *bool + ErrorPhone *string + ID string + InstanceClass *string + Reserve *string + SourceEndpointDatabaseName *string + SourceEndpointEngineName *string + SourceEndpointIP *string + SourceEndpointInstanceID *string + SourceEndpointInstanceType *string + SourceEndpointOracleSid *string + SourceEndpointOwnerID *string + SourceEndpointPassword *string + SourceEndpointPort *string + SourceEndpointRegion *string + SourceEndpointRole *string + SourceEndpointUserName *string + Status *string + StructureInitialization *bool + SynchronizationDirection *string + Timeouts *base.ResourceTimeout + func (in *SynchronizationJobSpecResource) DeepCopy() *SynchronizationJobSpecResource + func (in *SynchronizationJobSpecResource) DeepCopyInto(out *SynchronizationJobSpecResource) + type SynchronizationJobStatus struct + Conditions []kmapi.Condition + ObservedGeneration int64 + Phase status.Status + func (in *SynchronizationJobStatus) DeepCopy() *SynchronizationJobStatus + func (in *SynchronizationJobStatus) DeepCopyInto(out *SynchronizationJobStatus)
Go to main page