v1alpha1

Nov 27, 2024

Changes in this version

type ClusterTopologyComponent

+ Template *bool

type HorizontalScaling

+ Shards *int32

type LastComponentConfiguration

+ Shards *int32

type OpsRequest

+ func (r *OpsRequest) ValidateClusterPhase(cluster *Cluster) error

+ func (r *OpsRequest) ValidateOps(ctx context.Context, k8sClient client.Client, cluster *Cluster) error

type Restore

+ Env []corev1.EnvVar

type SpecificOpsRequest

+ StartList []ComponentOps

+ StopList []ComponentOps

Sep 11, 2024

Changes in this version

type ClusterComponentSpec

+ InstanceUpdateStrategy *InstanceUpdateStrategy

+ ParallelPodManagementConcurrency *intstr.IntOrString

+ PodUpdatePolicy *workloads.PodUpdatePolicyType

+ SchedulingPolicy *SchedulingPolicy

+ Stop *bool

type ClusterSpec

+ SchedulingPolicy *SchedulingPolicy

type ComponentSpec

+ InstanceUpdateStrategy *InstanceUpdateStrategy

+ ParallelPodManagementConcurrency *intstr.IntOrString

+ PodUpdatePolicy *workloads.PodUpdatePolicyType

+ SchedulingPolicy *SchedulingPolicy

+ Stop *bool

type InstanceTemplate

+ SchedulingPolicy *SchedulingPolicy

+ func (t *InstanceTemplate) GetOrdinals() workloads.Ordinals

+ type InstanceUpdateStrategy struct

+ MaxUnavailable *intstr.IntOrString

+ Partition *int32

+ func (in *InstanceUpdateStrategy) DeepCopy() *InstanceUpdateStrategy

+ func (in *InstanceUpdateStrategy) DeepCopyInto(out *InstanceUpdateStrategy)

type OpsRequestSpec

+ EnqueueOnForce bool

+ TTLSecondsAfterUnsuccessfulCompletion int32

type RebuildInstance

+ InPlace bool

+ type SchedulingPolicy struct

+ Affinity *corev1.Affinity

+ NodeName string

+ NodeSelector map[string]string

+ SchedulerName string

+ Tolerations []corev1.Toleration

+ TopologySpreadConstraints []corev1.TopologySpreadConstraint

+ func (in *SchedulingPolicy) DeepCopy() *SchedulingPolicy

+ func (in *SchedulingPolicy) DeepCopyInto(out *SchedulingPolicy)

type TargetInstance

+ FallbackRole string

type ValueFrom

+ ServiceVersion []ValueMapping

Jul 4, 2024

Changes in this version

+ const ComponentKind

+ const ConditionTypeAborted

+ func GetInstanceTemplateName(clusterName, componentName, instanceName string) string

+ func NewAbortedCondition(message string) *metav1.Condition

+ type ActionTask struct

+ Namespace string

+ ObjectKey string

+ Retries int32

+ Status ActionTaskStatus

+ TargetPodName string

+ func (in *ActionTask) DeepCopy() *ActionTask

+ func (in *ActionTask) DeepCopyInto(out *ActionTask)

+ type ActionTaskStatus string

+ const FailedActionTaskStatus

+ const ProcessingActionTaskStatus

+ const SucceedActionTaskStatus

+ type Backup struct

+ BackupMethod string

+ BackupName string

+ BackupPolicyName string

+ DeletionPolicy string

+ ParentBackupName string

+ RetentionPeriod string

+ func (in *Backup) DeepCopy() *Backup

+ func (in *Backup) DeepCopyInto(out *Backup)

type ClusterComponentDefinition

+ Exporter *Exporter

type ClusterComponentService

+ PodService *bool

type ClusterComponentSpec

+ DisableExporter *bool

+ OfflineInstances []string

+ ServiceVersion string

+ SystemAccounts []ComponentSystemAccount

+ func (r *ClusterComponentSpec) GetDisableExporter() *bool

type ClusterDefinitionSpec

+ Topologies []ClusterTopology

type ClusterDefinitionStatus

+ ServiceRefs string

+ Topologies string

type ClusterSpec

+ RuntimeClassName *string

+ Topology string

+ func (r ClusterSpec) GetShardingByName(shardingName string) *ShardingSpec

+ type ClusterTopology struct

+ Components []ClusterTopologyComponent

+ Default bool

+ Name string

+ Orders *ClusterTopologyOrders

+ func (in *ClusterTopology) DeepCopy() *ClusterTopology

+ func (in *ClusterTopology) DeepCopyInto(out *ClusterTopology)

+ type ClusterTopologyComponent struct

+ CompDef string

+ Name string

+ func (in *ClusterTopologyComponent) DeepCopy() *ClusterTopologyComponent

+ func (in *ClusterTopologyComponent) DeepCopyInto(out *ClusterTopologyComponent)

+ type ClusterTopologyOrders struct

+ Provision []string

+ Terminate []string

+ Update []string

+ func (in *ClusterTopologyOrders) DeepCopy() *ClusterTopologyOrders

+ func (in *ClusterTopologyOrders) DeepCopyInto(out *ClusterTopologyOrders)

+ type CompletionProbe struct

+ InitialDelaySeconds int32

+ MatchExpressions MatchExpressions

+ PeriodSeconds int32

+ TimeoutSeconds int32

+ func (in *CompletionProbe) DeepCopy() *CompletionProbe

+ func (in *CompletionProbe) DeepCopyInto(out *CompletionProbe)

type ComponentConfigSpec

+ InjectEnvTo []string

+ ReRenderResourceTypes []RerenderResourceType

+ func (configSpec *ComponentConfigSpec) ContainersInjectedTo() []string

+ func (configSpec *ComponentConfigSpec) InjectEnvEnabled() bool

type ComponentDefinitionSpec

+ Annotations map[string]string

+ Exporter *Exporter

+ HostNetwork *HostNetwork

+ MinReadySeconds int32

+ PodManagementPolicy *appsv1.PodManagementPolicyType

+ type ComponentInfo struct

+ AccountName string

+ ComponentDefinitionName string

+ ServiceName string

+ func (in *ComponentInfo) DeepCopy() *ComponentInfo

+ func (in *ComponentInfo) DeepCopyInto(out *ComponentInfo)

type ComponentLifecycleActions

+ DataDump *LifecycleActionHandler

+ DataLoad *LifecycleActionHandler

type ComponentOps

+ func (c ComponentOps) GetComponentName() string

type ComponentService

+ DisableAutoProvision *bool

+ PodService *bool

type ComponentSpec

+ DisableExporter *bool

+ OfflineInstances []string

+ RuntimeClassName *string

+ ServiceVersion string

+ Services []ComponentService

+ SystemAccounts []ComponentSystemAccount

+ type ComponentSystemAccount struct

+ Name string

+ PasswordConfig *PasswordConfig

+ SecretRef *ProvisionSecretRef

+ func (in *ComponentSystemAccount) DeepCopy() *ComponentSystemAccount

+ func (in *ComponentSystemAccount) DeepCopyInto(out *ComponentSystemAccount)

+ type ComponentVarSelector struct

+ func (in *ComponentVarSelector) DeepCopy() *ComponentVarSelector

+ func (in *ComponentVarSelector) DeepCopyInto(out *ComponentVarSelector)

+ type ComponentVars struct

+ ComponentName *VarOption

+ InstanceNames *VarOption

+ PodFQDNs *VarOption

+ Replicas *VarOption

+ func (in *ComponentVars) DeepCopy() *ComponentVars

+ func (in *ComponentVars) DeepCopyInto(out *ComponentVars)

+ type ComponentVersion struct

+ Spec ComponentVersionSpec

+ Status ComponentVersionStatus

+ func (in *ComponentVersion) DeepCopy() *ComponentVersion

+ func (in *ComponentVersion) DeepCopyInto(out *ComponentVersion)

+ func (in *ComponentVersion) DeepCopyObject() runtime.Object

+ func (r *ComponentVersion) Default()

+ func (r *ComponentVersion) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ComponentVersion) ValidateCreate() (admission.Warnings, error)

+ func (r *ComponentVersion) ValidateDelete() (admission.Warnings, error)

+ func (r *ComponentVersion) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type ComponentVersionCompatibilityRule struct

+ CompDefs []string

+ Releases []string

+ func (in *ComponentVersionCompatibilityRule) DeepCopy() *ComponentVersionCompatibilityRule

+ func (in *ComponentVersionCompatibilityRule) DeepCopyInto(out *ComponentVersionCompatibilityRule)

+ type ComponentVersionList struct

+ Items []ComponentVersion

+ func (in *ComponentVersionList) DeepCopy() *ComponentVersionList

+ func (in *ComponentVersionList) DeepCopyInto(out *ComponentVersionList)

+ func (in *ComponentVersionList) DeepCopyObject() runtime.Object

+ type ComponentVersionRelease struct

+ Changes string

+ Images map[string]string

+ Name string

+ ServiceVersion string

+ func (in *ComponentVersionRelease) DeepCopy() *ComponentVersionRelease

+ func (in *ComponentVersionRelease) DeepCopyInto(out *ComponentVersionRelease)

+ type ComponentVersionSpec struct

+ CompatibilityRules []ComponentVersionCompatibilityRule

+ Releases []ComponentVersionRelease

+ func (in *ComponentVersionSpec) DeepCopy() *ComponentVersionSpec

+ func (in *ComponentVersionSpec) DeepCopyInto(out *ComponentVersionSpec)

+ type ComponentVersionStatus struct

+ Message string

+ ObservedGeneration int64

+ Phase Phase

+ ServiceVersions string

+ func (in *ComponentVersionStatus) DeepCopy() *ComponentVersionStatus

+ func (in *ComponentVersionStatus) DeepCopyInto(out *ComponentVersionStatus)

type ConfigConstraint

+ func (cc *ConfigConstraint) ConvertFrom(srcRaw conversion.Hub) error

+ func (cc *ConfigConstraint) ConvertTo(dstRaw conversion.Hub) error

type ConfigConstraintSpec

+ ReloadStaticParamsBeforeRestart *bool

+ type ContainerVars struct

+ Name string

+ Port *NamedVar

+ func (in *ContainerVars) DeepCopy() *ContainerVars

+ func (in *ContainerVars) DeepCopyInto(out *ContainerVars)

+ type CustomOps struct

+ CustomOpsComponents []CustomOpsComponent

+ MaxConcurrentComponents intstr.IntOrString

+ OpsDefinitionName string

+ ServiceAccountName *string

+ func (in *CustomOps) DeepCopy() *CustomOps

+ func (in *CustomOps) DeepCopyInto(out *CustomOps)

+ type CustomOpsComponent struct

+ Parameters []Parameter

+ func (in *CustomOpsComponent) DeepCopy() *CustomOpsComponent

+ func (in *CustomOpsComponent) DeepCopyInto(out *CustomOpsComponent)

type EnvVar

+ Expression *string

type EnvVarRef

+ TargetContainerName string

+ type Exporter struct

+ ContainerName string

+ ScrapePath string

+ ScrapePort string

+ ScrapeScheme PrometheusScheme

+ func (in *Exporter) DeepCopy() *Exporter

+ func (in *Exporter) DeepCopyInto(out *Exporter)

type Expose

+ ComponentName string

type HorizontalScaling

+ ScaleIn *ScaleIn

+ ScaleOut *ScaleOut

+ type HostNetwork struct

+ ContainerPorts []HostNetworkContainerPort

+ func (in *HostNetwork) DeepCopy() *HostNetwork

+ func (in *HostNetwork) DeepCopyInto(out *HostNetwork)

+ type HostNetworkContainerPort struct

+ Container string

+ Ports []string

+ func (in *HostNetworkContainerPort) DeepCopy() *HostNetworkContainerPort

+ func (in *HostNetworkContainerPort) DeepCopyInto(out *HostNetworkContainerPort)

+ type HostNetworkVarSelector struct

+ func (in *HostNetworkVarSelector) DeepCopy() *HostNetworkVarSelector

+ func (in *HostNetworkVarSelector) DeepCopyInto(out *HostNetworkVarSelector)

+ type HostNetworkVars struct

+ Container *ContainerVars

+ func (in *HostNetworkVars) DeepCopy() *HostNetworkVars

+ func (in *HostNetworkVars) DeepCopyInto(out *HostNetworkVars)

+ type InstanceReplicasTemplate struct

+ Name string

+ ReplicaChanges int32

+ func (in *InstanceReplicasTemplate) DeepCopy() *InstanceReplicasTemplate

+ func (in *InstanceReplicasTemplate) DeepCopyInto(out *InstanceReplicasTemplate)

+ type InstanceResourceTemplate struct

+ Name string

+ func (in *InstanceResourceTemplate) DeepCopy() *InstanceResourceTemplate

+ func (in *InstanceResourceTemplate) DeepCopyInto(out *InstanceResourceTemplate)

+ type InstanceTemplate struct

+ Annotations map[string]string

+ Env []corev1.EnvVar

+ Image *string

+ Labels map[string]string

+ Name string

+ NodeName *string

+ NodeSelector map[string]string

+ Replicas *int32

+ Resources *corev1.ResourceRequirements

+ Tolerations []corev1.Toleration

+ VolumeClaimTemplates []ClusterComponentVolumeClaimTemplate

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

+ func (in *InstanceTemplate) DeepCopy() *InstanceTemplate

+ func (in *InstanceTemplate) DeepCopyInto(out *InstanceTemplate)

+ func (t *InstanceTemplate) GetName() string

+ func (t *InstanceTemplate) GetReplicas() int32

+ type InstanceVolumeClaimTemplate struct

+ Name string

+ VolumeClaimTemplates []OpsRequestVolumeClaimTemplate

+ func (in *InstanceVolumeClaimTemplate) DeepCopy() *InstanceVolumeClaimTemplate

+ func (in *InstanceVolumeClaimTemplate) DeepCopyInto(out *InstanceVolumeClaimTemplate)

+ type JSONPatchOperation struct

+ Operation string

+ Path string

+ Value string

+ func (in *JSONPatchOperation) DeepCopy() *JSONPatchOperation

+ func (in *JSONPatchOperation) DeepCopyInto(out *JSONPatchOperation)

type LastComponentConfiguration

+ ComponentDefinitionName string

+ Instances []InstanceTemplate

+ OfflineInstances []string

+ ServiceVersion string

+ type MatchExpressions struct

+ Failure string

+ Success string

+ func (in *MatchExpressions) DeepCopy() *MatchExpressions

+ func (in *MatchExpressions) DeepCopyInto(out *MatchExpressions)

+ type OpsAction struct

+ Exec *OpsExecAction

+ FailurePolicy FailurePolicyType

+ Name string

+ Parameters []string

+ ResourceModifier *OpsResourceModifierAction

+ Workload *OpsWorkloadAction

+ func (in *OpsAction) DeepCopy() *OpsAction

+ func (in *OpsAction) DeepCopyInto(out *OpsAction)

type OpsDefinition

+ func (o *OpsDefinition) GetComponentInfo(compDefName string) *ComponentInfo

type OpsDefinitionSpec

+ Actions []OpsAction

+ ComponentInfos []ComponentInfo

+ PodInfoExtractors []PodInfoExtractor

+ type OpsExecAction struct

+ BackoffLimit int32

+ Command []string

+ ContainerName string

+ PodInfoExtractorName string

+ func (in *OpsExecAction) DeepCopy() *OpsExecAction

+ func (in *OpsExecAction) DeepCopyInto(out *OpsExecAction)

type OpsPhase

+ const OpsAbortedPhase

type OpsRecorder

+ QueueBySelf bool

type OpsRequest

+ func (r *OpsRequest) CountOfflineOrOnlineInstances(clusterName, componentName string, hScaleInstanceNames []string) map[string]int32

+ func (r *OpsRequest) Force() bool

type OpsRequestComponentStatus

+ PreCheckResult *PreCheckResult

type OpsRequestSpec

+ ClusterName string

+ Force bool

+ PreConditionDeadlineSeconds *int32

+ TimeoutSeconds *int32

+ func (r OpsRequestSpec) GetBackup() *Backup

+ func (r OpsRequestSpec) GetClusterName() string

+ func (r OpsRequestSpec) GetRestore() *Restore

type OpsRequestStatus

+ Extras []map[string]string

+ type OpsResourceModifierAction struct

+ CompletionProbe CompletionProbe

+ JSONPatches []JSONPatchOperation

+ Resource TypedObjectRef

+ func (in *OpsResourceModifierAction) DeepCopy() *OpsResourceModifierAction

+ func (in *OpsResourceModifierAction) DeepCopyInto(out *OpsResourceModifierAction)

type OpsService

+ PodSelector map[string]string

type OpsVarSource

+ FieldRef *corev1.ObjectFieldSelector

+ type OpsWorkloadAction struct

+ BackoffLimit int32

+ PodInfoExtractorName string

+ PodSpec corev1.PodSpec

+ Type OpsWorkloadType

+ func (in *OpsWorkloadAction) DeepCopy() *OpsWorkloadAction

+ func (in *OpsWorkloadAction) DeepCopyInto(out *OpsWorkloadAction)

+ type OpsWorkloadType string

+ const JobWorkload

+ const PodWorkload

+ type OverrideBy struct

+ OpsName string

+ func (in *OverrideBy) DeepCopy() *OverrideBy

+ func (in *OverrideBy) DeepCopyInto(out *OverrideBy)

+ type Parameter struct

+ Name string

+ Value string

+ func (in *Parameter) DeepCopy() *Parameter

+ func (in *Parameter) DeepCopyInto(out *Parameter)

+ type PodAvailabilityPolicy string

+ const AvailablePolicy

+ const NoneAvailabilityPolicy

+ const UnAvailablePolicy

+ type PodInfoExtractor struct

+ Env []OpsEnvVar

+ Name string

+ PodSelector PodSelector

+ VolumeMounts []corev1.VolumeMount

+ func (in *PodInfoExtractor) DeepCopy() *PodInfoExtractor

+ func (in *PodInfoExtractor) DeepCopyInto(out *PodInfoExtractor)

+ type PodSelectionPolicy string

+ const All

+ const Any

+ type PodSelector struct

+ MultiPodSelectionPolicy PodSelectionPolicy

+ Role string

+ func (in *PodSelector) DeepCopy() *PodSelector

+ func (in *PodSelector) DeepCopyInto(out *PodSelector)

+ type PreCheckResult struct

+ Message string

+ Pass bool

+ func (in *PreCheckResult) DeepCopy() *PreCheckResult

+ func (in *PreCheckResult) DeepCopyInto(out *PreCheckResult)

type ProgressStatusDetail

+ ActionName string

+ ActionTasks []ActionTask

+ type PrometheusScheme string

+ const HTTPProtocol

+ const HTTPSProtocol

type RebuildInstance

+ RestoreEnv []corev1.EnvVar

+ type ReplicaChanger struct

+ Instances []InstanceReplicasTemplate

+ ReplicaChanges *int32

+ func (in *ReplicaChanger) DeepCopy() *ReplicaChanger

+ func (in *ReplicaChanger) DeepCopyInto(out *ReplicaChanger)

+ type RerenderResourceType string

+ const ComponentHScaleType

+ const ComponentVScaleType

+ type Restore struct

+ BackupName string

+ DeferPostReadyUntilClusterRunning bool

+ RestorePointInTime string

+ VolumeRestorePolicy string

+ func (in *Restore) DeepCopy() *Restore

+ func (in *Restore) DeepCopyInto(out *Restore)

+ type ScaleIn struct

+ OnlineInstancesToOffline []string

+ func (in *ScaleIn) DeepCopy() *ScaleIn

+ func (in *ScaleIn) DeepCopyInto(out *ScaleIn)

+ type ScaleOut struct

+ NewInstances []InstanceTemplate

+ OfflineInstancesToOnline []string

+ func (in *ScaleOut) DeepCopy() *ScaleOut

+ func (in *ScaleOut) DeepCopyInto(out *ScaleOut)

type ServiceDescriptorSpec

+ Host *CredentialVar

type ServiceRef

+ ClusterServiceSelector *ServiceRefClusterSelector

+ type ServiceRefClusterSelector struct

+ Cluster string

+ Credential *ServiceRefCredentialSelector

+ Service *ServiceRefServiceSelector

+ func (in *ServiceRefClusterSelector) DeepCopy() *ServiceRefClusterSelector

+ func (in *ServiceRefClusterSelector) DeepCopyInto(out *ServiceRefClusterSelector)

+ type ServiceRefCredentialSelector struct

+ Component string

+ Name string

+ func (in *ServiceRefCredentialSelector) DeepCopy() *ServiceRefCredentialSelector

+ func (in *ServiceRefCredentialSelector) DeepCopyInto(out *ServiceRefCredentialSelector)

type ServiceRefDeclaration

+ Optional *bool

+ type ServiceRefServiceSelector struct

+ Component string

+ Port string

+ Service string

+ func (in *ServiceRefServiceSelector) DeepCopy() *ServiceRefServiceSelector

+ func (in *ServiceRefServiceSelector) DeepCopyInto(out *ServiceRefServiceSelector)

type ServiceRefVars

+ Host *VarOption

type ServiceVars

+ LoadBalancer *VarOption

+ type SpecificOpsRequest struct

+ Backup *Backup

+ BackupSpec *Backup

+ CustomOps *CustomOps

+ ExposeList []Expose

+ HorizontalScalingList []HorizontalScaling

+ RebuildFrom []RebuildInstance

+ Reconfigure *Reconfigure

+ Reconfigures []Reconfigure

+ RestartList []ComponentOps

+ Restore *Restore

+ RestoreSpec *Restore

+ ScriptSpec *ScriptSpec

+ SwitchoverList []Switchover

+ Upgrade *Upgrade

+ VerticalScalingList []VerticalScaling

+ VolumeExpansionList []VolumeExpansion

+ func (in *SpecificOpsRequest) DeepCopy() *SpecificOpsRequest

+ func (in *SpecificOpsRequest) DeepCopyInto(out *SpecificOpsRequest)

+ type TypedObjectRef struct

+ APIGroup *string

+ Kind string

+ Name string

+ func (in *TypedObjectRef) DeepCopy() *TypedObjectRef

+ func (in *TypedObjectRef) DeepCopyInto(out *TypedObjectRef)

type Upgrade

+ Components []UpgradeComponent

+ type UpgradeComponent struct

+ ComponentDefinitionName *string

+ ServiceVersion *string

+ func (in *UpgradeComponent) DeepCopy() *UpgradeComponent

+ func (in *UpgradeComponent) DeepCopyInto(out *UpgradeComponent)

type VarSource

+ ComponentVarRef *ComponentVarSelector

+ HostNetworkVarRef *HostNetworkVarSelector

type VerticalScaling

+ Instances []InstanceResourceTemplate

type VolumeExpansion

+ Instances []InstanceVolumeClaimTemplate

Jul 9, 2024

Changes in this version

type ClusterComponentSpec

+ Annotations map[string]string

+ Env []corev1.EnvVar

+ Labels map[string]string

+ Volumes []corev1.Volume

type ComponentSpec

+ Annotations map[string]string

+ Env []corev1.EnvVar

+ Labels map[string]string

+ Volumes []corev1.Volume

type RestoreSpec

+ DoReadyRestoreAfterClusterRunning bool

Apr 10, 2024

Changes in this version

+ const ConditionTypeInstanceRebuilding

+ func NewInstancesRebuildingCondition(ops *OpsRequest) *metav1.Condition

type ClusterObjectReference

+ MultipleClusterObjectOption *MultipleClusterObjectOption

+ type Instance struct

+ Name string

+ TargetNodeName string

+ func (in *Instance) DeepCopy() *Instance

+ func (in *Instance) DeepCopyInto(out *Instance)

+ type MultipleClusterObjectCombinedOption struct

+ FlattenFormat *MultipleClusterObjectValueFormatFlatten

+ NewVarSuffix *string

+ ValueFormat MultipleClusterObjectValueFormat

+ func (in *MultipleClusterObjectCombinedOption) DeepCopy() *MultipleClusterObjectCombinedOption

+ func (in *MultipleClusterObjectCombinedOption) DeepCopyInto(out *MultipleClusterObjectCombinedOption)

+ type MultipleClusterObjectOption struct

+ CombinedOption *MultipleClusterObjectCombinedOption

+ Strategy MultipleClusterObjectStrategy

+ func (in *MultipleClusterObjectOption) DeepCopy() *MultipleClusterObjectOption

+ func (in *MultipleClusterObjectOption) DeepCopyInto(out *MultipleClusterObjectOption)

+ type MultipleClusterObjectStrategy string

+ const MultipleClusterObjectStrategyCombined

+ const MultipleClusterObjectStrategyIndividual

+ type MultipleClusterObjectValueFormat string

+ const FlattenFormat

+ type MultipleClusterObjectValueFormatFlatten struct

+ Delimiter string

+ KeyValueDelimiter string

+ func (in *MultipleClusterObjectValueFormatFlatten) DeepCopy() *MultipleClusterObjectValueFormatFlatten

+ func (in *MultipleClusterObjectValueFormatFlatten) DeepCopyInto(out *MultipleClusterObjectValueFormatFlatten)

type OpsRequestSpec

+ RebuildFrom []RebuildInstance

type OpsService

+ IPFamilies []corev1.IPFamily

+ IPFamilyPolicy *corev1.IPFamilyPolicy

type OpsType

+ const RebuildInstanceType

+ type RebuildInstance struct

+ BackupName string

+ EnvForRestore []corev1.EnvVar

+ Instances []Instance

+ func (in *RebuildInstance) DeepCopy() *RebuildInstance

+ func (in *RebuildInstance) DeepCopyInto(out *RebuildInstance)

Mar 20, 2024

Changes in this version

type BuiltinActionHandlerType

+ const CustomActionHandler

type ClusterService

+ ShardingSelector string

type ClusterSpec

+ ShardingSpecs []ShardingSpec

type ConfigConstraintSpec

+ DynamicActionCanBeMerged *bool

+ DynamicParameterSelectedPolicy *DynamicParameterSelectedPolicy

+ func (in *ConfigConstraintSpec) DynamicParametersPolicy() DynamicParameterSelectedPolicy

+ func (in *ConfigConstraintSpec) NeedDynamicReloadAction() bool

type ConfigurationSpec

+ func (configuration *ConfigurationSpec) GetConfigSpec(configSpecName string) *ComponentConfigSpec

+ type DynamicParameterSelectedPolicy string

+ const SelectedAllParameters

+ const SelectedDynamicParameters

type PasswordConfig

+ Seed string

+ type ShardingSpec struct

+ Name string

+ Shards int32

+ Template ClusterComponentSpec

+ func (in *ShardingSpec) DeepCopy() *ShardingSpec

+ func (in *ShardingSpec) DeepCopyInto(out *ShardingSpec)

type UpgradePolicy

+ const AsyncDynamicReloadPolicy

+ const DynamicReloadAndRestartPolicy

+ const SyncDynamicReloadPolicy

Jan 12, 2024

Changes in this version

+ const ConditionTypeCustomOperation

+ const ConditionTypeWaitForProgressing

+ const KBSwitchoverCandidateInstanceForAnyPod

+ const ReasonOpsCancelByController

+ func NewRestoreCondition(ops *OpsRequest) *metav1.Condition

+ func NewWaitForProcessingCondition(ops *OpsRequest) *metav1.Condition

+ type Action struct

+ Container string

+ Env []corev1.EnvVar

+ Exec *ExecAction

+ HTTP *HTTPAction

+ Image string

+ MatchingKey string

+ PreCondition *PreConditionType

+ RetryPolicy *RetryPolicy

+ TargetPodSelector TargetPodSelector

+ TimeoutSeconds int32

+ func (in *Action) DeepCopy() *Action

+ func (in *Action) DeepCopyInto(out *Action)

+ type AutoTrigger struct

+ ProcessName string

+ func (in *AutoTrigger) DeepCopy() *AutoTrigger

+ func (in *AutoTrigger) DeepCopyInto(out *AutoTrigger)

type BackupPolicy

+ BackoffLimit *int32

+ ComponentDefs []string

+ type BuiltinActionHandlerType string

+ const ApeCloudPostgresqlBuiltinActionHandler

+ const ETCDBuiltinActionHandler

+ const MongoDBBuiltinActionHandler

+ const MySQLBuiltinActionHandler

+ const OceanbaseBuiltinActionHandler

+ const OfficialPostgresqlBuiltinActionHandler

+ const PolarDBXBuiltinActionHandler

+ const PostgresqlBuiltinActionHandler

+ const RedisBuiltinActionHandler

+ const UnknownBuiltinActionHandler

+ const WeSQLBuiltinActionHandler

type CfgReloadType

+ const AutoType

type ClusterComponentSpec

+ ComponentDef string

+ Instances []string

+ Nodes []types.NodeName

+ RsmTransformPolicy workloads.RsmTransformPolicy

+ UpdateStrategy *UpdateStrategy

+ UserResourceRefs *UserResourceRefs

+ type ClusterObjectReference struct

+ CompDef string

+ Name string

+ Optional *bool

+ func (in *ClusterObjectReference) DeepCopy() *ClusterObjectReference

+ func (in *ClusterObjectReference) DeepCopyInto(out *ClusterObjectReference)

+ type ClusterService struct

+ ComponentSelector string

+ func (in *ClusterService) DeepCopy() *ClusterService

+ func (in *ClusterService) DeepCopyInto(out *ClusterService)

type ClusterSpec

+ Services []ClusterService

+ type Component struct

+ Spec ComponentSpec

+ Status ComponentStatus

+ func (in *Component) DeepCopy() *Component

+ func (in *Component) DeepCopyInto(out *Component)

+ func (in *Component) DeepCopyObject() runtime.Object

+ func (r *Component) Default()

+ func (r *Component) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Component) ValidateCreate() (admission.Warnings, error)

+ func (r *Component) ValidateDelete() (admission.Warnings, error)

+ func (r *Component) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type ComponentDefinition struct

+ Spec ComponentDefinitionSpec

+ Status ComponentDefinitionStatus

+ func (in *ComponentDefinition) DeepCopy() *ComponentDefinition

+ func (in *ComponentDefinition) DeepCopyInto(out *ComponentDefinition)

+ func (in *ComponentDefinition) DeepCopyObject() runtime.Object

+ func (r *ComponentDefinition) Default()

+ func (r *ComponentDefinition) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ComponentDefinition) ValidateCreate() (admission.Warnings, error)

+ func (r *ComponentDefinition) ValidateDelete() (admission.Warnings, error)

+ func (r *ComponentDefinition) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type ComponentDefinitionList struct

+ Items []ComponentDefinition

+ func (in *ComponentDefinitionList) DeepCopy() *ComponentDefinitionList

+ func (in *ComponentDefinitionList) DeepCopyInto(out *ComponentDefinitionList)

+ func (in *ComponentDefinitionList) DeepCopyObject() runtime.Object

+ type ComponentDefinitionRef struct

+ AccountName string

+ Name string

+ ServiceName string

+ VarsRef *VarsRef

+ func (in *ComponentDefinitionRef) DeepCopy() *ComponentDefinitionRef

+ func (in *ComponentDefinitionRef) DeepCopyInto(out *ComponentDefinitionRef)

+ type ComponentDefinitionSpec struct

+ Configs []ComponentConfigSpec

+ Description string

+ Labels map[string]string

+ LifecycleActions *ComponentLifecycleActions

+ LogConfigs []LogConfig

+ Monitor *MonitorConfig

+ PolicyRules []rbacv1.PolicyRule

+ Provider string

+ ReplicasLimit *ReplicasLimit

+ RoleArbitrator *RoleArbitrator

+ Roles []ReplicaRole

+ Runtime corev1.PodSpec

+ Scripts []ComponentTemplateSpec

+ ServiceKind string

+ ServiceRefDeclarations []ServiceRefDeclaration

+ ServiceVersion string

+ Services []ComponentService

+ SystemAccounts []SystemAccount

+ UpdateStrategy *UpdateStrategy

+ Vars []EnvVar

+ Volumes []ComponentVolume

+ func (in *ComponentDefinitionSpec) DeepCopy() *ComponentDefinitionSpec

+ func (in *ComponentDefinitionSpec) DeepCopyInto(out *ComponentDefinitionSpec)

+ type ComponentDefinitionStatus struct

+ Message string

+ ObservedGeneration int64

+ Phase Phase

+ func (in *ComponentDefinitionStatus) DeepCopy() *ComponentDefinitionStatus

+ func (in *ComponentDefinitionStatus) DeepCopyInto(out *ComponentDefinitionStatus)

+ type ComponentLifecycleActions struct

+ AccountProvision *LifecycleActionHandler

+ DataAssemble *LifecycleActionHandler

+ DataPopulate *LifecycleActionHandler

+ MemberJoin *LifecycleActionHandler

+ MemberLeave *LifecycleActionHandler

+ PostProvision *LifecycleActionHandler

+ PreTerminate *LifecycleActionHandler

+ Readonly *LifecycleActionHandler

+ Readwrite *LifecycleActionHandler

+ Reconfigure *LifecycleActionHandler

+ RoleProbe *RoleProbe

+ Switchover *ComponentSwitchover

+ func (in *ComponentLifecycleActions) DeepCopy() *ComponentLifecycleActions

+ func (in *ComponentLifecycleActions) DeepCopyInto(out *ComponentLifecycleActions)

+ type ComponentList struct

+ Items []Component

+ func (in *ComponentList) DeepCopy() *ComponentList

+ func (in *ComponentList) DeepCopyInto(out *ComponentList)

+ func (in *ComponentList) DeepCopyObject() runtime.Object

type ComponentResourceConstraint

+ func (c *ComponentResourceConstraint) FindRulesWithCompDef(compDef string) []ResourceConstraintRule

type ComponentResourceConstraintSpec

+ ComponentSelector []ComponentResourceConstraintSelector

+ type ComponentService struct

+ GeneratePodOrdinalService bool

+ func (in *ComponentService) DeepCopy() *ComponentService

+ func (in *ComponentService) DeepCopyInto(out *ComponentService)

+ type ComponentSpec struct

+ Affinity *Affinity

+ ClassDefRef *ClassDefRef

+ CompDef string

+ Configs []ComponentConfigSpec

+ EnabledLogs []string

+ Instances []string

+ Monitor bool

+ Nodes []types.NodeName

+ Replicas int32

+ Resources corev1.ResourceRequirements

+ RsmTransformPolicy workloads.RsmTransformPolicy

+ ServiceAccountName string

+ ServiceRefs []ServiceRef

+ TLSConfig *TLSConfig

+ Tolerations []corev1.Toleration

+ UpdateStrategy *UpdateStrategy

+ VolumeClaimTemplates []ClusterComponentVolumeClaimTemplate

+ func (in *ComponentSpec) DeepCopy() *ComponentSpec

+ func (in *ComponentSpec) DeepCopyInto(out *ComponentSpec)

+ type ComponentStatus struct

+ Conditions []metav1.Condition

+ Message ComponentMessageMap

+ ObservedGeneration int64

+ Phase ClusterComponentPhase

+ func (in *ComponentStatus) DeepCopy() *ComponentStatus

+ func (in *ComponentStatus) DeepCopyInto(out *ComponentStatus)

+ type ComponentSwitchover struct

+ ScriptSpecSelectors []ScriptSpecSelector

+ WithCandidate *Action

+ WithoutCandidate *Action

+ func (in *ComponentSwitchover) DeepCopy() *ComponentSwitchover

+ func (in *ComponentSwitchover) DeepCopyInto(out *ComponentSwitchover)

+ type ComponentVolume struct

+ HighWatermark int

+ Name string

+ NeedSnapshot bool

+ func (in *ComponentVolume) DeepCopy() *ComponentVolume

+ func (in *ComponentVolume) DeepCopyInto(out *ComponentVolume)

+ type ConfigMapRef struct

+ ConfigMap corev1.ConfigMapVolumeSource

+ func (in *ConfigMapRef) DeepCopy() *ConfigMapRef

+ func (in *ConfigMapRef) DeepCopyInto(out *ConfigMapRef)

type ConfigurationItemDetail

+ Payload Payload

+ type CredentialVarSelector struct

+ func (in *CredentialVarSelector) DeepCopy() *CredentialVarSelector

+ func (in *CredentialVarSelector) DeepCopyInto(out *CredentialVarSelector)

+ type CredentialVars struct

+ Password *VarOption

+ Username *VarOption

+ func (in *CredentialVars) DeepCopy() *CredentialVars

+ func (in *CredentialVars) DeepCopyInto(out *CredentialVars)

+ type CustomOpsSpec struct

+ ComponentName string

+ OpsDefinitionRef string

+ Params []map[string]string

+ func (in *CustomOpsSpec) DeepCopy() *CustomOpsSpec

+ func (in *CustomOpsSpec) DeepCopyInto(out *CustomOpsSpec)

+ type EnvVar struct

+ Name string

+ Value string

+ ValueFrom *VarSource

+ func (in *EnvVar) DeepCopy() *EnvVar

+ func (in *EnvVar) DeepCopyInto(out *EnvVar)

+ type EnvVarRef struct

+ ContainerName string

+ EnvName string

+ func (in *EnvVarRef) DeepCopy() *EnvVarRef

+ func (in *EnvVarRef) DeepCopyInto(out *EnvVarRef)

+ type ExecAction struct

+ Args []string

+ Command []string

+ func (in *ExecAction) DeepCopy() *ExecAction

+ func (in *ExecAction) DeepCopyInto(out *ExecAction)

type Expose

+ Switch ExposeSwitch

+ type ExposeSwitch string

+ const DisableExposeSwitch

+ const EnableExposeSwitch

+ type HTTPAction struct

+ HTTPHeaders []corev1.HTTPHeader

+ Host string

+ Method string

+ Path string

+ Port intstr.IntOrString

+ Scheme corev1.URIScheme

+ func (in *HTTPAction) DeepCopy() *HTTPAction

+ func (in *HTTPAction) DeepCopyInto(out *HTTPAction)

type HorizontalScaling

+ Instances []string

+ Nodes []types.NodeName

+ type LifecycleActionHandler struct

+ BuiltinHandler *BuiltinActionHandlerType

+ CustomHandler *Action

+ func (in *LifecycleActionHandler) DeepCopy() *LifecycleActionHandler

+ func (in *LifecycleActionHandler) DeepCopyInto(out *LifecycleActionHandler)

+ type NamedVar struct

+ Name string

+ Option *VarOption

+ func (in *NamedVar) DeepCopy() *NamedVar

+ func (in *NamedVar) DeepCopyInto(out *NamedVar)

+ type OpsDefinition struct

+ Spec OpsDefinitionSpec

+ Status OpsDefinitionStatus

+ func (in *OpsDefinition) DeepCopy() *OpsDefinition

+ func (in *OpsDefinition) DeepCopyInto(out *OpsDefinition)

+ func (in *OpsDefinition) DeepCopyObject() runtime.Object

+ func (o *OpsDefinition) GetComponentDefRef(compDefName string) *ComponentDefinitionRef

+ type OpsDefinitionList struct

+ Items []OpsDefinition

+ func (in *OpsDefinitionList) DeepCopy() *OpsDefinitionList

+ func (in *OpsDefinitionList) DeepCopyInto(out *OpsDefinitionList)

+ func (in *OpsDefinitionList) DeepCopyObject() runtime.Object

+ type OpsDefinitionSpec struct

+ ComponentDefinitionRefs []ComponentDefinitionRef

+ JobSpec batchv1.JobSpec

+ ParametersSchema *ParametersSchema

+ PreConditions []PreCondition

+ VarsRef *VarsRef

+ func (in *OpsDefinitionSpec) DeepCopy() *OpsDefinitionSpec

+ func (in *OpsDefinitionSpec) DeepCopyInto(out *OpsDefinitionSpec)

+ type OpsDefinitionStatus struct

+ Message string

+ ObservedGeneration int64

+ Phase Phase

+ func (in *OpsDefinitionStatus) DeepCopy() *OpsDefinitionStatus

+ func (in *OpsDefinitionStatus) DeepCopyInto(out *OpsDefinitionStatus)

+ type OpsEnvVar struct

+ Name string

+ ValueFrom *OpsVarSource

+ func (in *OpsEnvVar) DeepCopy() *OpsEnvVar

+ func (in *OpsEnvVar) DeepCopyInto(out *OpsEnvVar)

type OpsRecorder

+ InQueue bool

type OpsRequestSpec

+ CustomSpec *CustomOpsSpec

+ RestoreSpec *RestoreSpec

+ type OpsService struct

+ Annotations map[string]string

+ Name string

+ Ports []corev1.ServicePort

+ RoleSelector string

+ Selector map[string]string

+ ServiceType corev1.ServiceType

+ func (in *OpsService) DeepCopy() *OpsService

+ func (in *OpsService) DeepCopyInto(out *OpsService)

type OpsType

+ const CustomType

+ const RestoreType

+ type OpsVarSource struct

+ EnvVarRef *EnvVarRef

+ func (in *OpsVarSource) DeepCopy() *OpsVarSource

+ func (in *OpsVarSource) DeepCopyInto(out *OpsVarSource)

+ type ParametersSchema struct

+ OpenAPIV3Schema *apiextensionsv1.JSONSchemaProps

+ func (in *ParametersSchema) DeepCopy() *ParametersSchema

+ func (in *ParametersSchema) DeepCopyInto(out *ParametersSchema)

+ type Payload struct

+ Data map[string]any

+ func (c *Payload) DeepCopyInto(out *Payload)

+ func (c *Payload) MarshalJSON() ([]byte, error)

+ func (c *Payload) UnmarshalJSON(data []byte) error

+ func (in *Payload) DeepCopy() *Payload

+ type PodSelectionStrategy string

+ const Available

+ const PreferredAvailable

+ type PreCondition struct

+ Exec *PreConditionExec

+ Rule *Rule

+ func (in *PreCondition) DeepCopy() *PreCondition

+ func (in *PreCondition) DeepCopyInto(out *PreCondition)

+ type PreConditionExec struct

+ Args []string

+ Command []string

+ Env []corev1.EnvVar

+ Image string

+ func (in *PreConditionExec) DeepCopy() *PreConditionExec

+ func (in *PreConditionExec) DeepCopyInto(out *PreConditionExec)

+ type PreConditionType string

+ const ClusterReadyPreConditionType

+ const ComponentReadyPreConditionType

+ const ImmediatelyPreConditionType

+ const RuntimeReadyPreConditionType

type ReloadOptions

+ AutoTrigger *AutoTrigger

+ type ReplicaRole struct

+ Name string

+ Serviceable bool

+ Votable bool

+ Writable bool

+ func (in *ReplicaRole) DeepCopy() *ReplicaRole

+ func (in *ReplicaRole) DeepCopyInto(out *ReplicaRole)

+ type ReplicasLimit struct

+ MaxReplicas int32

+ MinReplicas int32

+ func (in *ReplicasLimit) DeepCopy() *ReplicasLimit

+ func (in *ReplicasLimit) DeepCopyInto(out *ReplicasLimit)

+ type ResourceMeta struct

+ AsVolumeFrom []string

+ MountPoint string

+ Name string

+ SubPath string

+ func (in *ResourceMeta) DeepCopy() *ResourceMeta

+ func (in *ResourceMeta) DeepCopyInto(out *ResourceMeta)

+ type RestoreSpec struct

+ BackupName string

+ EffectiveCommonComponentDef bool

+ RestoreTimeStr string

+ VolumeRestorePolicy string

+ func (in *RestoreSpec) DeepCopy() *RestoreSpec

+ func (in *RestoreSpec) DeepCopyInto(out *RestoreSpec)

+ type RetryPolicy struct

+ MaxRetries int

+ RetryInterval time.Duration

+ func (in *RetryPolicy) DeepCopy() *RetryPolicy

+ func (in *RetryPolicy) DeepCopyInto(out *RetryPolicy)

+ type RoleArbitrator string

+ const ExternalRoleArbitrator

+ const LorryRoleArbitrator

+ type RoleProbe struct

+ FailureThreshold int32

+ InitialDelaySeconds int32

+ PeriodSeconds int32

+ SuccessThreshold int32

+ TerminationGracePeriodSeconds *int64

+ TimeoutSeconds int32

+ func (in *RoleProbe) DeepCopy() *RoleProbe

+ func (in *RoleProbe) DeepCopyInto(out *RoleProbe)

+ type Rule struct

+ Expression string

+ Message string

+ func (in *Rule) DeepCopy() *Rule

+ func (in *Rule) DeepCopyInto(out *Rule)

+ type SecretRef struct

+ Secret corev1.SecretVolumeSource

+ func (in *SecretRef) DeepCopy() *SecretRef

+ func (in *SecretRef) DeepCopyInto(out *SecretRef)

+ type Service struct

+ Annotations map[string]string

+ Name string

+ RoleSelector string

+ ServiceName string

+ Spec corev1.ServiceSpec

+ func (in *Service) DeepCopy() *Service

+ func (in *Service) DeepCopyInto(out *Service)

+ type ServiceRefVarSelector struct

+ func (in *ServiceRefVarSelector) DeepCopy() *ServiceRefVarSelector

+ func (in *ServiceRefVarSelector) DeepCopyInto(out *ServiceRefVarSelector)

+ type ServiceRefVars struct

+ Endpoint *VarOption

+ Port *VarOption

+ func (in *ServiceRefVars) DeepCopy() *ServiceRefVars

+ func (in *ServiceRefVars) DeepCopyInto(out *ServiceRefVars)

type ServiceSpec

+ func (r *ServiceSpec) ToSVCPorts() []corev1.ServicePort

+ type ServiceVarSelector struct

+ GeneratePodOrdinalServiceVar bool

+ func (in *ServiceVarSelector) DeepCopy() *ServiceVarSelector

+ func (in *ServiceVarSelector) DeepCopyInto(out *ServiceVarSelector)

+ type ServiceVars struct

+ Host *VarOption

+ NodePort *NamedVar

+ Port *NamedVar

+ func (in *ServiceVars) DeepCopy() *ServiceVars

+ func (in *ServiceVars) DeepCopyInto(out *ServiceVars)

+ type SystemAccount struct

+ InitAccount bool

+ Name string

+ PasswordGenerationPolicy PasswordConfig

+ SecretRef *ProvisionSecretRef

+ Statement string

+ func (in *SystemAccount) DeepCopy() *SystemAccount

+ func (in *SystemAccount) DeepCopyInto(out *SystemAccount)

+ type TLSConfig struct

+ Enable bool

+ Issuer *Issuer

+ func (in *TLSConfig) DeepCopy() *TLSConfig

+ func (in *TLSConfig) DeepCopyInto(out *TLSConfig)

type TargetInstance

+ Strategy dpv1alpha1.PodSelectionStrategy

+ type TargetPodSelector string

+ const AllReplicas

+ const AnyReplica

+ const OrdinalSelector

+ const RoleSelector

+ type UserResourceRefs struct

+ ConfigMapRefs []ConfigMapRef

+ SecretRefs []SecretRef

+ func (in *UserResourceRefs) DeepCopy() *UserResourceRefs

+ func (in *UserResourceRefs) DeepCopyInto(out *UserResourceRefs)

type ValueFrom

+ ComponentDef []ValueMapping

+ type ValueMapping struct

+ MappingValue string

+ Names []string

+ func (in *ValueMapping) DeepCopy() *ValueMapping

+ func (in *ValueMapping) DeepCopyInto(out *ValueMapping)

+ type VarOption string

+ var VarOptional VarOption = "Optional"

+ var VarRequired VarOption = "Required"

+ type VarSource struct

+ ConfigMapKeyRef *corev1.ConfigMapKeySelector

+ CredentialVarRef *CredentialVarSelector

+ SecretKeyRef *corev1.SecretKeySelector

+ ServiceRefVarRef *ServiceRefVarSelector

+ ServiceVarRef *ServiceVarSelector

+ func (in *VarSource) DeepCopy() *VarSource

+ func (in *VarSource) DeepCopyInto(out *VarSource)

+ type VarsRef struct

+ PodSelectionStrategy PodSelectionStrategy

+ Vars []OpsEnvVar

+ func (in *VarsRef) DeepCopy() *VarsRef

+ func (in *VarsRef) DeepCopyInto(out *VarsRef)

Dec 19, 2023

Changes in this version

type BackupMethod

+ Target *TargetInstance

type OpsRequestSpec

+ Reconfigures []Reconfigure

type OpsRequestStatus

+ ReconfiguringStatusAsComponent map[string]*ReconfiguringStatus

type ReconfiguringStatus

+ Conditions []metav1.Condition

Nov 24, 2023

Changes in this version

+ const ReplicatedStateMachineKind

type ClusterComponentDefinition

+ PostStartSpec *PostStartAction

+ type PostStartAction struct

+ CmdExecutorConfig CmdExecutorConfig

+ ScriptSpecSelectors []ScriptSpecSelector

+ func (in *PostStartAction) DeepCopy() *PostStartAction

+ func (in *PostStartAction) DeepCopyInto(out *PostStartAction)

type SchedulePolicy

+ RetentionPeriod dpv1alpha1.RetentionPeriod

Nov 3, 2023

Changes in this version

+ const ConditionTypeBackup

+ const ReasonReconfigurePersisted

+ const ReasonReconfigurePersisting

+ func NewBackupCondition(ops *OpsRequest) *metav1.Condition

+ type BackupMethod struct

+ EnvMapping []EnvMappingVar

+ func (in *BackupMethod) DeepCopy() *BackupMethod

+ func (in *BackupMethod) DeepCopyInto(out *BackupMethod)

type BackupPolicy

+ BackupMethods []BackupMethod

+ RetentionPeriod dpv1alpha1.RetentionPeriod

+ Schedules []SchedulePolicy

+ Target TargetInstance

+ type BackupSpec struct

+ BackupMethod string

+ BackupName string

+ BackupPolicyName string

+ DeletionPolicy string

+ ParentBackupName string

+ RetentionPeriod string

+ func (in *BackupSpec) DeepCopy() *BackupSpec

+ func (in *BackupSpec) DeepCopyInto(out *BackupSpec)

type ClusterComponentDefinition

+ RSMSpec *RSMSpec

+ ServiceRefDeclarations []ServiceRefDeclaration

+ func GetComponentDefByCluster(ctx context.Context, cli client.Client, cluster Cluster, compDefName string) (*ClusterComponentDefinition, error)

type ClusterComponentPhase

+ const DeletingClusterCompPhase

+ const StoppingClusterCompPhase

+ const UpdatingClusterCompPhase

type ClusterComponentSpec

+ ServiceRefs []ServiceRef

type ClusterComponentStatus

+ MembersStatus []workloads.MemberStatus

type ClusterPhase

+ const DeletingClusterPhase

+ const StoppingClusterPhase

+ const UpdatingClusterPhase

+ type ClusterVersionMapping struct

+ MappingValue string

+ Names []string

+ func (in *ClusterVersionMapping) DeepCopy() *ClusterVersionMapping

+ func (in *ClusterVersionMapping) DeepCopyInto(out *ClusterVersionMapping)

type ComponentConfigSpec

+ LegacyRenderedConfigSpec *LegacyRenderedTemplateSpec

+ type ConfigParams struct

+ Content *string

+ Parameters map[string]*string

+ func (in *ConfigParams) DeepCopy() *ConfigParams

+ func (in *ConfigParams) DeepCopyInto(out *ConfigParams)

+ type ConfigTemplateExtension struct

+ Namespace string

+ Policy MergedPolicy

+ TemplateRef string

+ func (in *ConfigTemplateExtension) DeepCopy() *ConfigTemplateExtension

+ func (in *ConfigTemplateExtension) DeepCopyInto(out *ConfigTemplateExtension)

type Configuration

+ Spec ConfigurationSpec

+ Status ConfigurationStatus

+ func (in *Configuration) DeepCopyObject() runtime.Object

+ type ConfigurationItem struct

+ Keys []ParameterConfig

+ Name string

+ Policy *UpgradePolicy

+ func (in *ConfigurationItem) DeepCopy() *ConfigurationItem

+ func (in *ConfigurationItem) DeepCopyInto(out *ConfigurationItem)

+ type ConfigurationItemDetail struct

+ ConfigFileParams map[string]ConfigParams

+ ConfigSpec *ComponentConfigSpec

+ ImportTemplateRef *ConfigTemplateExtension

+ Name string

+ Version string

+ func (in *ConfigurationItemDetail) DeepCopy() *ConfigurationItemDetail

+ func (in *ConfigurationItemDetail) DeepCopyInto(out *ConfigurationItemDetail)

+ type ConfigurationItemDetailStatus struct

+ LastDoneRevision string

+ Message *string

+ Name string

+ Phase ConfigurationPhase

+ ReconcileDetail *ReconcileDetail

+ UpdateRevision string

+ func (in *ConfigurationItemDetailStatus) DeepCopy() *ConfigurationItemDetailStatus

+ func (in *ConfigurationItemDetailStatus) DeepCopyInto(out *ConfigurationItemDetailStatus)

+ type ConfigurationItemStatus struct

+ ExpectedCount int32

+ LastAppliedConfiguration map[string]string

+ LastAppliedStatus string

+ Message string

+ Name string

+ Status string

+ SucceedCount int32

+ UpdatePolicy UpgradePolicy

+ UpdatedParameters UpdatedParameters

+ func (in *ConfigurationItemStatus) DeepCopy() *ConfigurationItemStatus

+ func (in *ConfigurationItemStatus) DeepCopyInto(out *ConfigurationItemStatus)

+ type ConfigurationList struct

+ Items []Configuration

+ func (in *ConfigurationList) DeepCopy() *ConfigurationList

+ func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)

+ func (in *ConfigurationList) DeepCopyObject() runtime.Object

+ type ConfigurationPhase string

+ const CCreatingPhase

+ const CDeletingPhase

+ const CFailedAndPausePhase

+ const CFailedPhase

+ const CFinishedPhase

+ const CInitPhase

+ const CMergeFailedPhase

+ const CMergedPhase

+ const CPendingPhase

+ const CRunningPhase

+ const CUpgradingPhase

+ type ConfigurationSpec struct

+ ClusterRef string

+ ComponentName string

+ ConfigItemDetails []ConfigurationItemDetail

+ func (configuration *ConfigurationSpec) GetConfigurationItem(name string) *ConfigurationItemDetail

+ func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec

+ func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)

type ConfigurationStatus

+ Conditions []metav1.Condition

+ ConfigurationItemStatus []ConfigurationItemDetailStatus

+ Message string

+ ObservedGeneration int64

+ func (status *ConfigurationStatus) GetItemStatus(name string) *ConfigurationItemDetailStatus

+ type ConnectionCredentialAuth struct

+ Password *CredentialVar

+ Username *CredentialVar

+ func (in *ConnectionCredentialAuth) DeepCopy() *ConnectionCredentialAuth

+ func (in *ConnectionCredentialAuth) DeepCopyInto(out *ConnectionCredentialAuth)

type ConnectionCredentialKey

+ HostKey *string

+ PortKey *string

+ type CredentialVar struct

+ Value string

+ ValueFrom *corev1.EnvVarSource

+ func (in *CredentialVar) DeepCopy() *CredentialVar

+ func (in *CredentialVar) DeepCopyInto(out *CredentialVar)

+ type EnvMappingVar struct

+ Key string

+ ValueFrom ValueFrom

+ func (in *EnvMappingVar) DeepCopy() *EnvMappingVar

+ func (in *EnvMappingVar) DeepCopyInto(out *EnvMappingVar)

+ type LegacyRenderedTemplateSpec struct

+ func (in *LegacyRenderedTemplateSpec) DeepCopy() *LegacyRenderedTemplateSpec

+ func (in *LegacyRenderedTemplateSpec) DeepCopyInto(out *LegacyRenderedTemplateSpec)

type OpsRequestSpec

+ BackupSpec *BackupSpec

type OpsType

+ const BackupType

type ParameterConfig

+ FileContent string

+ type RSMSpec struct

+ MemberUpdateStrategy *workloads.MemberUpdateStrategy

+ MembershipReconfiguration *workloads.MembershipReconfiguration

+ RoleProbe *workloads.RoleProbe

+ Roles []workloads.ReplicaRole

+ func (in *RSMSpec) DeepCopy() *RSMSpec

+ func (in *RSMSpec) DeepCopyInto(out *RSMSpec)

+ type ReconcileDetail struct

+ CurrentRevision string

+ ErrMessage string

+ ExecResult string

+ ExpectedCount int32

+ Policy string

+ SucceedCount int32

+ func (in *ReconcileDetail) DeepCopy() *ReconcileDetail

+ func (in *ReconcileDetail) DeepCopyInto(out *ReconcileDetail)

type SchedulePolicy

+ BackupMethod string

+ Enabled *bool

+ type ServiceDescriptor struct

+ Spec ServiceDescriptorSpec

+ Status ServiceDescriptorStatus

+ func (in *ServiceDescriptor) DeepCopy() *ServiceDescriptor

+ func (in *ServiceDescriptor) DeepCopyInto(out *ServiceDescriptor)

+ func (in *ServiceDescriptor) DeepCopyObject() runtime.Object

+ func (r *ServiceDescriptor) Default()

+ func (r *ServiceDescriptor) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ServiceDescriptor) ValidateCreate() (admission.Warnings, error)

+ func (r *ServiceDescriptor) ValidateDelete() (admission.Warnings, error)

+ func (r *ServiceDescriptor) ValidateUpdate(old runtime.Object) (admission.Warnings, error)

+ type ServiceDescriptorList struct

+ Items []ServiceDescriptor

+ func (in *ServiceDescriptorList) DeepCopy() *ServiceDescriptorList

+ func (in *ServiceDescriptorList) DeepCopyInto(out *ServiceDescriptorList)

+ func (in *ServiceDescriptorList) DeepCopyObject() runtime.Object

+ type ServiceDescriptorSpec struct

+ Auth *ConnectionCredentialAuth

+ Endpoint *CredentialVar

+ Port *CredentialVar

+ ServiceKind string

+ ServiceVersion string

+ func (in *ServiceDescriptorSpec) DeepCopy() *ServiceDescriptorSpec

+ func (in *ServiceDescriptorSpec) DeepCopyInto(out *ServiceDescriptorSpec)

+ type ServiceDescriptorStatus struct

+ Message string

+ ObservedGeneration int64

+ Phase Phase

+ func (in *ServiceDescriptorStatus) DeepCopy() *ServiceDescriptorStatus

+ func (in *ServiceDescriptorStatus) DeepCopyInto(out *ServiceDescriptorStatus)

+ func (r ServiceDescriptorStatus) GetTerminalPhases() []Phase

+ type ServiceRef struct

+ Cluster string

+ Name string

+ Namespace string

+ ServiceDescriptor string

+ func (in *ServiceRef) DeepCopy() *ServiceRef

+ func (in *ServiceRef) DeepCopyInto(out *ServiceRef)

+ type ServiceRefDeclaration struct

+ Name string

+ ServiceRefDeclarationSpecs []ServiceRefDeclarationSpec

+ func (in *ServiceRefDeclaration) DeepCopy() *ServiceRefDeclaration

+ func (in *ServiceRefDeclaration) DeepCopyInto(out *ServiceRefDeclaration)

+ type ServiceRefDeclarationSpec struct

+ ServiceKind string

+ ServiceVersion string

+ func (in *ServiceRefDeclarationSpec) DeepCopy() *ServiceRefDeclarationSpec

+ func (in *ServiceRefDeclarationSpec) DeepCopyInto(out *ServiceRefDeclarationSpec)

+ type ValueFrom struct

+ ClusterVersionRef []ClusterVersionMapping

+ func (in *ValueFrom) DeepCopy() *ValueFrom

+ func (in *ValueFrom) DeepCopyInto(out *ValueFrom)

Oct 9, 2023

Changes in this version

type PersistentVolumeClaimSpec

+ VolumeMode *corev1.PersistentVolumeMode

type ScriptSpec

+ Selector *metav1.LabelSelector

Aug 18, 2023

Changes in this version

+ const ConditionTypeCancelled

+ const ConditionTypeDataScript

+ const ConditionTypeSwitchover

+ const ConditionTypeSwitchoverPrefix

+ const ReasonOpsCancelFailed

+ const ReasonOpsCancelSucceed

+ const ReasonOpsCanceling

+ const ReasonReconfigureRestart

+ const ReasonReconfigureRestartFailed

+ var ErrNotMatchingCompDef = errors.New("not matching componentDefRef")

+ var ErrWorkloadTypeIsStateless = errors.New("workloadType should not be stateless")

+ var ErrWorkloadTypeIsUnknown = errors.New("workloadType is unknown")

+ var SchemeGroupVersion = GroupVersion

+ func ComponentPodsAreReady(podsAreReady *bool) bool

+ func NewCancelFailedCondition(ops *OpsRequest, err error) *metav1.Condition

+ func NewCancelSucceedCondition(opsName string) *metav1.Condition

+ func NewCancelingCondition(ops *OpsRequest) *metav1.Condition

+ func NewDataScriptCondition(ops *OpsRequest) *metav1.Condition

+ func NewSwitchoveringCondition(generation int64, message string) *metav1.Condition

+ func Resource(resource string) schema.GroupResource

type Affinity

+ func (in *Affinity) DeepCopy() *Affinity

+ func (in *Affinity) DeepCopyInto(out *Affinity)

+ type AvailabilityPolicyType string

+ const AvailabilityPolicyNode

+ const AvailabilityPolicyNone

+ const AvailabilityPolicyZone

type BackupPolicy

+ func (in *BackupPolicy) DeepCopy() *BackupPolicy

+ func (in *BackupPolicy) DeepCopyInto(out *BackupPolicy)

type BackupPolicyHook

+ func (in *BackupPolicyHook) DeepCopy() *BackupPolicyHook

+ func (in *BackupPolicyHook) DeepCopyInto(out *BackupPolicyHook)

type BackupPolicyTemplate

+ func (in *BackupPolicyTemplate) DeepCopy() *BackupPolicyTemplate

+ func (in *BackupPolicyTemplate) DeepCopyInto(out *BackupPolicyTemplate)

+ func (in *BackupPolicyTemplate) DeepCopyObject() runtime.Object

type BackupPolicyTemplateList

+ func (in *BackupPolicyTemplateList) DeepCopy() *BackupPolicyTemplateList

+ func (in *BackupPolicyTemplateList) DeepCopyInto(out *BackupPolicyTemplateList)

+ func (in *BackupPolicyTemplateList) DeepCopyObject() runtime.Object

type BackupPolicyTemplateSpec

+ func (in *BackupPolicyTemplateSpec) DeepCopy() *BackupPolicyTemplateSpec

+ func (in *BackupPolicyTemplateSpec) DeepCopyInto(out *BackupPolicyTemplateSpec)

type BackupPolicyTemplateStatus

+ func (in *BackupPolicyTemplateStatus) DeepCopy() *BackupPolicyTemplateStatus

+ func (in *BackupPolicyTemplateStatus) DeepCopyInto(out *BackupPolicyTemplateStatus)

type BackupRefSpec

+ func (in *BackupRefSpec) DeepCopy() *BackupRefSpec

+ func (in *BackupRefSpec) DeepCopyInto(out *BackupRefSpec)

type BackupStatusUpdate

+ UseTargetPodServiceAccount bool

+ func (in *BackupStatusUpdate) DeepCopy() *BackupStatusUpdate

+ func (in *BackupStatusUpdate) DeepCopyInto(out *BackupStatusUpdate)

type BasePolicy

+ func (in *BasePolicy) DeepCopy() *BasePolicy

+ func (in *BasePolicy) DeepCopyInto(out *BasePolicy)

type CPUConstraint

+ func (in *CPUConstraint) DeepCopy() *CPUConstraint

+ func (in *CPUConstraint) DeepCopyInto(out *CPUConstraint)

type CfgFileFormat

+ const PropertiesPlus

type ClassDefRef

+ func (in *ClassDefRef) DeepCopy() *ClassDefRef

+ func (in *ClassDefRef) DeepCopyInto(out *ClassDefRef)

type Cluster

+ func (in *Cluster) DeepCopy() *Cluster

+ func (in *Cluster) DeepCopyInto(out *Cluster)

+ func (in *Cluster) DeepCopyObject() runtime.Object

+ func (r Cluster) IsDeleting() bool

+ func (r Cluster) IsStatusUpdating() bool

+ func (r Cluster) IsUpdating() bool

+ type ClusterBackup struct

+ CronExpression string

+ Enabled *bool

+ Method dataprotectionv1alpha1.BackupMethod

+ PITREnabled *bool

+ RepoName string

+ RetentionPeriod *string

+ StartingDeadlineMinutes *int64

+ func (in *ClusterBackup) DeepCopy() *ClusterBackup

+ func (in *ClusterBackup) DeepCopyInto(out *ClusterBackup)

type ClusterComponentDefinition

+ ComponentDefRef []ComponentDefRef

+ StatefulSpec *StatefulSetSpec

+ StatelessSpec *StatelessSetSpec

+ SwitchoverSpec *SwitchoverSpec

+ VolumeProtectionSpec *VolumeProtectionSpec

+ func (in *ClusterComponentDefinition) DeepCopy() *ClusterComponentDefinition

+ func (in *ClusterComponentDefinition) DeepCopyInto(out *ClusterComponentDefinition)

+ func (r *ClusterComponentDefinition) GetCommonStatefulSpec() (*StatefulSetSpec, error)

+ func (r *ClusterComponentDefinition) GetMaxUnavailable() *intstr.IntOrString

+ func (r *ClusterComponentDefinition) GetMinAvailable() *intstr.IntOrString

+ func (r *ClusterComponentDefinition) GetStatefulSetWorkload() StatefulSetWorkload

+ func (r *ClusterComponentDefinition) IsStatelessWorkload() bool

type ClusterComponentPhase

+ func GetComponentUpRunningPhase() []ClusterComponentPhase

type ClusterComponentService

+ func (in *ClusterComponentService) DeepCopy() *ClusterComponentService

+ func (in *ClusterComponentService) DeepCopyInto(out *ClusterComponentService)

type ClusterComponentSpec

+ NoCreatePDB bool

+ func (in *ClusterComponentSpec) DeepCopy() *ClusterComponentSpec

+ func (in *ClusterComponentSpec) DeepCopyInto(out *ClusterComponentSpec)

+ func (r *ClusterComponentSpec) GetMinAvailable(prefer *intstr.IntOrString) *intstr.IntOrString

type ClusterComponentStatus

+ func (in *ClusterComponentStatus) DeepCopy() *ClusterComponentStatus

+ func (in *ClusterComponentStatus) DeepCopyInto(out *ClusterComponentStatus)

type ClusterComponentVersion

+ SwitchoverSpec *SwitchoverShortSpec

+ SystemAccountSpec *SystemAccountShortSpec

+ func (in *ClusterComponentVersion) DeepCopy() *ClusterComponentVersion

+ func (in *ClusterComponentVersion) DeepCopyInto(out *ClusterComponentVersion)

type ClusterComponentVolumeClaimTemplate

+ func (in *ClusterComponentVolumeClaimTemplate) DeepCopy() *ClusterComponentVolumeClaimTemplate

+ func (in *ClusterComponentVolumeClaimTemplate) DeepCopyInto(out *ClusterComponentVolumeClaimTemplate)

type ClusterDefinition

+ func (in *ClusterDefinition) DeepCopy() *ClusterDefinition

+ func (in *ClusterDefinition) DeepCopyInto(out *ClusterDefinition)

+ func (in *ClusterDefinition) DeepCopyObject() runtime.Object

type ClusterDefinitionList

+ func (in *ClusterDefinitionList) DeepCopy() *ClusterDefinitionList

+ func (in *ClusterDefinitionList) DeepCopyInto(out *ClusterDefinitionList)

+ func (in *ClusterDefinitionList) DeepCopyObject() runtime.Object

type ClusterDefinitionProbe

+ func (in *ClusterDefinitionProbe) DeepCopy() *ClusterDefinitionProbe

+ func (in *ClusterDefinitionProbe) DeepCopyInto(out *ClusterDefinitionProbe)

type ClusterDefinitionProbeCMDs

+ func (in *ClusterDefinitionProbeCMDs) DeepCopy() *ClusterDefinitionProbeCMDs

+ func (in *ClusterDefinitionProbeCMDs) DeepCopyInto(out *ClusterDefinitionProbeCMDs)

type ClusterDefinitionProbes

+ func (in *ClusterDefinitionProbes) DeepCopy() *ClusterDefinitionProbes

+ func (in *ClusterDefinitionProbes) DeepCopyInto(out *ClusterDefinitionProbes)

type ClusterDefinitionSpec

+ func (in *ClusterDefinitionSpec) DeepCopy() *ClusterDefinitionSpec

+ func (in *ClusterDefinitionSpec) DeepCopyInto(out *ClusterDefinitionSpec)

type ClusterDefinitionStatus

+ func (in *ClusterDefinitionStatus) DeepCopy() *ClusterDefinitionStatus

+ func (in *ClusterDefinitionStatus) DeepCopyInto(out *ClusterDefinitionStatus)

type ClusterList

+ func (in *ClusterList) DeepCopy() *ClusterList

+ func (in *ClusterList) DeepCopyInto(out *ClusterList)

+ func (in *ClusterList) DeepCopyObject() runtime.Object

+ type ClusterMonitor struct

+ MonitoringInterval *intstr.IntOrString

+ func (in *ClusterMonitor) DeepCopy() *ClusterMonitor

+ func (in *ClusterMonitor) DeepCopyInto(out *ClusterMonitor)

+ type ClusterNetwork struct

+ HostNetworkAccessible bool

+ PubliclyAccessible bool

+ func (in *ClusterNetwork) DeepCopy() *ClusterNetwork

+ func (in *ClusterNetwork) DeepCopyInto(out *ClusterNetwork)

type ClusterPhase

+ func GetReconfiguringRunningPhases() []ClusterPhase

+ type ClusterResourceConstraintSelector struct

+ ClusterDefRef string

+ Components []ComponentResourceConstraintSelector

+ func (in *ClusterResourceConstraintSelector) DeepCopy() *ClusterResourceConstraintSelector

+ func (in *ClusterResourceConstraintSelector) DeepCopyInto(out *ClusterResourceConstraintSelector)

+ type ClusterResources struct

+ CPU resource.Quantity

+ Memory resource.Quantity

+ func (in *ClusterResources) DeepCopy() *ClusterResources

+ func (in *ClusterResources) DeepCopyInto(out *ClusterResources)

type ClusterSpec

+ AvailabilityPolicy AvailabilityPolicyType

+ Backup *ClusterBackup

+ Monitor ClusterMonitor

+ Network *ClusterNetwork

+ Replicas *int32

+ Resources ClusterResources

+ Storage ClusterStorage

+ Tenancy TenancyType

+ func (in *ClusterSpec) DeepCopy() *ClusterSpec

+ func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)

type ClusterStatus

+ func (in *ClusterStatus) DeepCopy() *ClusterStatus

+ func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)

+ type ClusterStorage struct

+ Size resource.Quantity

+ func (in *ClusterStorage) DeepCopy() *ClusterStorage

+ func (in *ClusterStorage) DeepCopyInto(out *ClusterStorage)

type ClusterSwitchPolicy

+ func (in *ClusterSwitchPolicy) DeepCopy() *ClusterSwitchPolicy

+ func (in *ClusterSwitchPolicy) DeepCopyInto(out *ClusterSwitchPolicy)

type ClusterVersion

+ func (in *ClusterVersion) DeepCopy() *ClusterVersion

+ func (in *ClusterVersion) DeepCopyInto(out *ClusterVersion)

+ func (in *ClusterVersion) DeepCopyObject() runtime.Object

type ClusterVersionList

+ func (in *ClusterVersionList) DeepCopy() *ClusterVersionList

+ func (in *ClusterVersionList) DeepCopyInto(out *ClusterVersionList)

+ func (in *ClusterVersionList) DeepCopyObject() runtime.Object

type ClusterVersionSpec

+ func (in *ClusterVersionSpec) DeepCopy() *ClusterVersionSpec

+ func (in *ClusterVersionSpec) DeepCopyInto(out *ClusterVersionSpec)

type ClusterVersionStatus

+ func (in *ClusterVersionStatus) DeepCopy() *ClusterVersionStatus

+ func (in *ClusterVersionStatus) DeepCopyInto(out *ClusterVersionStatus)

type CmdExecutorConfig

+ func (in *CmdExecutorConfig) DeepCopy() *CmdExecutorConfig

+ func (in *CmdExecutorConfig) DeepCopyInto(out *CmdExecutorConfig)

type CommandExecutorEnvItem

+ func (in *CommandExecutorEnvItem) DeepCopy() *CommandExecutorEnvItem

+ func (in *CommandExecutorEnvItem) DeepCopyInto(out *CommandExecutorEnvItem)

type CommandExecutorItem

+ func (in *CommandExecutorItem) DeepCopy() *CommandExecutorItem

+ func (in *CommandExecutorItem) DeepCopyInto(out *CommandExecutorItem)

type CommonBackupPolicy

+ func (in *CommonBackupPolicy) DeepCopy() *CommonBackupPolicy

+ func (in *CommonBackupPolicy) DeepCopyInto(out *CommonBackupPolicy)

type ComponentClass

+ func (in *ComponentClass) DeepCopy() *ComponentClass

+ func (in *ComponentClass) DeepCopyInto(out *ComponentClass)

+ func (r *ComponentClass) Cmp(b *ComponentClass) int

type ComponentClassDefinition

+ func (in *ComponentClassDefinition) DeepCopy() *ComponentClassDefinition

+ func (in *ComponentClassDefinition) DeepCopyInto(out *ComponentClassDefinition)

+ func (in *ComponentClassDefinition) DeepCopyObject() runtime.Object

type ComponentClassDefinitionList

+ func (in *ComponentClassDefinitionList) DeepCopy() *ComponentClassDefinitionList

+ func (in *ComponentClassDefinitionList) DeepCopyInto(out *ComponentClassDefinitionList)

+ func (in *ComponentClassDefinitionList) DeepCopyObject() runtime.Object

type ComponentClassDefinitionSpec

+ func (in *ComponentClassDefinitionSpec) DeepCopy() *ComponentClassDefinitionSpec

+ func (in *ComponentClassDefinitionSpec) DeepCopyInto(out *ComponentClassDefinitionSpec)

type ComponentClassDefinitionStatus

+ func (in *ComponentClassDefinitionStatus) DeepCopy() *ComponentClassDefinitionStatus

+ func (in *ComponentClassDefinitionStatus) DeepCopyInto(out *ComponentClassDefinitionStatus)

type ComponentClassGroup

+ func (in *ComponentClassGroup) DeepCopy() *ComponentClassGroup

+ func (in *ComponentClassGroup) DeepCopyInto(out *ComponentClassGroup)

type ComponentClassSeries

+ func (in *ComponentClassSeries) DeepCopy() *ComponentClassSeries

+ func (in *ComponentClassSeries) DeepCopyInto(out *ComponentClassSeries)

type ComponentConfigSpec

+ AsEnvFrom []string

+ LazyRenderedConfigSpec *LazyRenderedTemplateSpec

+ func (in *ComponentConfigSpec) DeepCopy() *ComponentConfigSpec

+ func (in *ComponentConfigSpec) DeepCopyInto(out *ComponentConfigSpec)

+ type ComponentDefRef struct

+ ComponentDefName string

+ ComponentRefEnvs []ComponentRefEnv

+ FailurePolicy FailurePolicyType

+ func (in *ComponentDefRef) DeepCopy() *ComponentDefRef

+ func (in *ComponentDefRef) DeepCopyInto(out *ComponentDefRef)

type ComponentMessageMap

+ func (in ComponentMessageMap) DeepCopy() ComponentMessageMap

+ func (in ComponentMessageMap) DeepCopyInto(out *ComponentMessageMap)

type ComponentNameSet

+ func (in ComponentNameSet) DeepCopy() ComponentNameSet

+ func (in ComponentNameSet) DeepCopyInto(out *ComponentNameSet)

type ComponentOps

+ func (in *ComponentOps) DeepCopy() *ComponentOps

+ func (in *ComponentOps) DeepCopyInto(out *ComponentOps)

+ type ComponentRefEnv struct

+ Name string

+ Value string

+ ValueFrom *ComponentValueFrom

+ func (in *ComponentRefEnv) DeepCopy() *ComponentRefEnv

+ func (in *ComponentRefEnv) DeepCopyInto(out *ComponentRefEnv)

type ComponentResourceConstraint

+ func (c *ComponentResourceConstraint) FindMatchingRules(clusterDefRef string, componentDefRef string, resources corev1.ResourceList) []ResourceConstraintRule

+ func (c *ComponentResourceConstraint) FindRules(clusterDefRef, componentDefRef string) []ResourceConstraintRule

+ func (in *ComponentResourceConstraint) DeepCopy() *ComponentResourceConstraint

+ func (in *ComponentResourceConstraint) DeepCopyInto(out *ComponentResourceConstraint)

+ func (in *ComponentResourceConstraint) DeepCopyObject() runtime.Object

type ComponentResourceConstraintList

+ func (in *ComponentResourceConstraintList) DeepCopy() *ComponentResourceConstraintList

+ func (in *ComponentResourceConstraintList) DeepCopyInto(out *ComponentResourceConstraintList)

+ func (in *ComponentResourceConstraintList) DeepCopyObject() runtime.Object

+ type ComponentResourceConstraintSelector struct

+ ComponentDefRef string

+ Rules []string

+ func (in *ComponentResourceConstraintSelector) DeepCopy() *ComponentResourceConstraintSelector

+ func (in *ComponentResourceConstraintSelector) DeepCopyInto(out *ComponentResourceConstraintSelector)

type ComponentResourceConstraintSpec

+ Rules []ResourceConstraintRule

+ Selector []ClusterResourceConstraintSelector

+ func (in *ComponentResourceConstraintSpec) DeepCopy() *ComponentResourceConstraintSpec

+ func (in *ComponentResourceConstraintSpec) DeepCopyInto(out *ComponentResourceConstraintSpec)

type ComponentTemplateSpec

+ func (in *ComponentTemplateSpec) DeepCopy() *ComponentTemplateSpec

+ func (in *ComponentTemplateSpec) DeepCopyInto(out *ComponentTemplateSpec)

+ type ComponentValueFrom struct

+ FieldPath string

+ Format string

+ JoinWith string

+ Type ComponentValueFromType

+ func (in *ComponentValueFrom) DeepCopy() *ComponentValueFrom

+ func (in *ComponentValueFrom) DeepCopyInto(out *ComponentValueFrom)

+ type ComponentValueFromType string

+ const FromFieldRef

+ const FromHeadlessServiceRef

+ const FromServiceRef

type ConfigConstraint

+ func (in *ConfigConstraint) DeepCopy() *ConfigConstraint

+ func (in *ConfigConstraint) DeepCopyInto(out *ConfigConstraint)

+ func (in *ConfigConstraint) DeepCopyObject() runtime.Object

type ConfigConstraintList

+ func (in *ConfigConstraintList) DeepCopy() *ConfigConstraintList

+ func (in *ConfigConstraintList) DeepCopyInto(out *ConfigConstraintList)

+ func (in *ConfigConstraintList) DeepCopyObject() runtime.Object

type ConfigConstraintSpec

+ DownwardAPIOptions []DownwardAPIOption

+ ScriptConfigs []ScriptConfig

+ ToolsImageSpec *ToolsImageSpec

+ func (in *ConfigConstraintSpec) DeepCopy() *ConfigConstraintSpec

+ func (in *ConfigConstraintSpec) DeepCopyInto(out *ConfigConstraintSpec)

type ConfigConstraintStatus

+ func (in *ConfigConstraintStatus) DeepCopy() *ConfigConstraintStatus

+ func (in *ConfigConstraintStatus) DeepCopyInto(out *ConfigConstraintStatus)

type Configuration

+ func (in *Configuration) DeepCopy() *Configuration

+ func (in *Configuration) DeepCopyInto(out *Configuration)

type ConfigurationStatus

+ func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus

+ func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)

type ConnectionCredentialKey

+ func (in *ConnectionCredentialKey) DeepCopy() *ConnectionCredentialKey

+ func (in *ConnectionCredentialKey) DeepCopyInto(out *ConnectionCredentialKey)

type ConsensusMember

+ func (in *ConsensusMember) DeepCopy() *ConsensusMember

+ func (in *ConsensusMember) DeepCopyInto(out *ConsensusMember)

type ConsensusMemberStatus

+ func (in *ConsensusMemberStatus) DeepCopy() *ConsensusMemberStatus

+ func (in *ConsensusMemberStatus) DeepCopyInto(out *ConsensusMemberStatus)

type ConsensusSetSpec

+ func NewConsensusSetSpec() *ConsensusSetSpec

+ func (in *ConsensusSetSpec) DeepCopy() *ConsensusSetSpec

+ func (in *ConsensusSetSpec) DeepCopyInto(out *ConsensusSetSpec)

+ func (r *ConsensusSetSpec) FinalStsUpdateStrategy() (appsv1.PodManagementPolicyType, appsv1.StatefulSetUpdateStrategy)

+ func (r *ConsensusSetSpec) GetUpdateStrategy() UpdateStrategy

type ConsensusSetStatus

+ func (in *ConsensusSetStatus) DeepCopy() *ConsensusSetStatus

+ func (in *ConsensusSetStatus) DeepCopyInto(out *ConsensusSetStatus)

type CustomLabelSpec

+ func (in *CustomLabelSpec) DeepCopy() *CustomLabelSpec

+ func (in *CustomLabelSpec) DeepCopyInto(out *CustomLabelSpec)

type CustomParametersValidation

+ func (in *CustomParametersValidation) DeepCopy() *CustomParametersValidation

+ func (in *CustomParametersValidation) DeepCopyInto(out *CustomParametersValidation)

+ type DownwardAPIOption struct

+ Command []string

+ Items []corev1.DownwardAPIVolumeFile

+ MountPoint string

+ Name string

+ func (in *DownwardAPIOption) DeepCopy() *DownwardAPIOption

+ func (in *DownwardAPIOption) DeepCopyInto(out *DownwardAPIOption)

type ExporterConfig

+ func (in *ExporterConfig) DeepCopy() *ExporterConfig

+ func (in *ExporterConfig) DeepCopyInto(out *ExporterConfig)

type Expose

+ func (in *Expose) DeepCopy() *Expose

+ func (in *Expose) DeepCopyInto(out *Expose)

+ type FailurePolicyType string

+ const FailurePolicyFail

+ const FailurePolicyIgnore

type FormatterConfig

+ func (in *FormatterConfig) DeepCopy() *FormatterConfig

+ func (in *FormatterConfig) DeepCopyInto(out *FormatterConfig)

type FormatterOptions

+ func (in *FormatterOptions) DeepCopy() *FormatterOptions

+ func (in *FormatterOptions) DeepCopyInto(out *FormatterOptions)

type GVKResource

+ func (in *GVKResource) DeepCopy() *GVKResource

+ func (in *GVKResource) DeepCopyInto(out *GVKResource)

type HScaleDataClonePolicyType

+ const HScaleDataClonePolicyCloneVolume

type HorizontalScalePolicy

+ func (in *HorizontalScalePolicy) DeepCopy() *HorizontalScalePolicy

+ func (in *HorizontalScalePolicy) DeepCopyInto(out *HorizontalScalePolicy)

type HorizontalScaling

+ func (in *HorizontalScaling) DeepCopy() *HorizontalScaling

+ func (in *HorizontalScaling) DeepCopyInto(out *HorizontalScaling)

type IniConfig

+ func (in *IniConfig) DeepCopy() *IniConfig

+ func (in *IniConfig) DeepCopyInto(out *IniConfig)

type Issuer

+ func (in *Issuer) DeepCopy() *Issuer

+ func (in *Issuer) DeepCopyInto(out *Issuer)

type LastComponentConfiguration

+ ClassDefRef *ClassDefRef

+ func (in *LastComponentConfiguration) DeepCopy() *LastComponentConfiguration

+ func (in *LastComponentConfiguration) DeepCopyInto(out *LastComponentConfiguration)

type LastConfiguration

+ func (in *LastConfiguration) DeepCopy() *LastConfiguration

+ func (in *LastConfiguration) DeepCopyInto(out *LastConfiguration)

+ type LazyRenderedTemplateSpec struct

+ Namespace string

+ Policy MergedPolicy

+ TemplateRef string

+ func (in *LazyRenderedTemplateSpec) DeepCopy() *LazyRenderedTemplateSpec

+ func (in *LazyRenderedTemplateSpec) DeepCopyInto(out *LazyRenderedTemplateSpec)

type LogConfig

+ func (in *LogConfig) DeepCopy() *LogConfig

+ func (in *LogConfig) DeepCopyInto(out *LogConfig)

type MemoryConstraint

+ func (in *MemoryConstraint) DeepCopy() *MemoryConstraint

+ func (in *MemoryConstraint) DeepCopyInto(out *MemoryConstraint)

+ type MergedPolicy string

+ const NoneMergePolicy

+ const OnlyAddPolicy

+ const PatchPolicy

+ const ReplacePolicy

type MonitorConfig

+ func (in *MonitorConfig) DeepCopy() *MonitorConfig

+ func (in *MonitorConfig) DeepCopyInto(out *MonitorConfig)

type OpsPhase

+ const OpsCancelledPhase

+ const OpsCancellingPhase

type OpsRecorder

+ func (in *OpsRecorder) DeepCopy() *OpsRecorder

+ func (in *OpsRecorder) DeepCopyInto(out *OpsRecorder)

type OpsRequest

+ func GetRunningOpsByOpsType(ctx context.Context, cli client.Client, clusterName, namespace, opsType string) ([]OpsRequest, error)

+ func (in *OpsRequest) DeepCopy() *OpsRequest

+ func (in *OpsRequest) DeepCopyInto(out *OpsRequest)

+ func (in *OpsRequest) DeepCopyObject() runtime.Object

+ func (r *OpsRequest) IsComplete(phases ...OpsPhase) bool

type OpsRequestBehaviour

+ func (in *OpsRequestBehaviour) DeepCopy() *OpsRequestBehaviour

+ func (in *OpsRequestBehaviour) DeepCopyInto(out *OpsRequestBehaviour)

type OpsRequestComponentStatus

+ LastFailedTime metav1.Time

+ Message string

+ Reason string

+ func (in *OpsRequestComponentStatus) DeepCopy() *OpsRequestComponentStatus

+ func (in *OpsRequestComponentStatus) DeepCopyInto(out *OpsRequestComponentStatus)

type OpsRequestList

+ func (in *OpsRequestList) DeepCopy() *OpsRequestList

+ func (in *OpsRequestList) DeepCopyInto(out *OpsRequestList)

+ func (in *OpsRequestList) DeepCopyObject() runtime.Object

type OpsRequestSpec

+ Cancel bool

+ ScriptSpec *ScriptSpec

+ SwitchoverList []Switchover

+ TTLSecondsBeforeAbort *int32

+ func (in *OpsRequestSpec) DeepCopy() *OpsRequestSpec

+ func (in *OpsRequestSpec) DeepCopyInto(out *OpsRequestSpec)

+ func (r OpsRequestSpec) GetDataScriptComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) GetSwitchoverComponentNameSet() ComponentNameSet

type OpsRequestStatus

+ CancelTimestamp metav1.Time

+ func (in *OpsRequestStatus) DeepCopy() *OpsRequestStatus

+ func (in *OpsRequestStatus) DeepCopyInto(out *OpsRequestStatus)

type OpsRequestVolumeClaimTemplate

+ func (in *OpsRequestVolumeClaimTemplate) DeepCopy() *OpsRequestVolumeClaimTemplate

+ func (in *OpsRequestVolumeClaimTemplate) DeepCopyInto(out *OpsRequestVolumeClaimTemplate)

type OpsType

+ const DataScriptType

+ const SwitchoverType

type ParameterConfig

+ func (in *ParameterConfig) DeepCopy() *ParameterConfig

+ func (in *ParameterConfig) DeepCopyInto(out *ParameterConfig)

type ParameterPair

+ func (in *ParameterPair) DeepCopy() *ParameterPair

+ func (in *ParameterPair) DeepCopyInto(out *ParameterPair)

type PasswordConfig

+ func (in *PasswordConfig) DeepCopy() *PasswordConfig

+ func (in *PasswordConfig) DeepCopyInto(out *PasswordConfig)

type PersistentVolumeClaimSpec

+ func (in *PersistentVolumeClaimSpec) DeepCopy() *PersistentVolumeClaimSpec

+ func (in *PersistentVolumeClaimSpec) DeepCopyInto(out *PersistentVolumeClaimSpec)

type PointInTimeRefSpec

+ func (in *PointInTimeRefSpec) DeepCopy() *PointInTimeRefSpec

+ func (in *PointInTimeRefSpec) DeepCopyInto(out *PointInTimeRefSpec)

type ProgressStatusDetail

+ func (in *ProgressStatusDetail) DeepCopy() *ProgressStatusDetail

+ func (in *ProgressStatusDetail) DeepCopyInto(out *ProgressStatusDetail)

+ type ProtectedVolume struct

+ HighWatermark *int

+ Name string

+ func (in *ProtectedVolume) DeepCopy() *ProtectedVolume

+ func (in *ProtectedVolume) DeepCopyInto(out *ProtectedVolume)

type ProvisionPolicy

+ func (in *ProvisionPolicy) DeepCopy() *ProvisionPolicy

+ func (in *ProvisionPolicy) DeepCopyInto(out *ProvisionPolicy)

type ProvisionSecretRef

+ func (in *ProvisionSecretRef) DeepCopy() *ProvisionSecretRef

+ func (in *ProvisionSecretRef) DeepCopyInto(out *ProvisionSecretRef)

type ProvisionStatements

+ UpdateStatement string

+ func (in *ProvisionStatements) DeepCopy() *ProvisionStatements

+ func (in *ProvisionStatements) DeepCopyInto(out *ProvisionStatements)

type Reconfigure

+ func (in *Reconfigure) DeepCopy() *Reconfigure

+ func (in *Reconfigure) DeepCopyInto(out *Reconfigure)

type ReconfiguringStatus

+ func (in *ReconfiguringStatus) DeepCopy() *ReconfiguringStatus

+ func (in *ReconfiguringStatus) DeepCopyInto(out *ReconfiguringStatus)

type RefNamespaceName

+ func (in *RefNamespaceName) DeepCopy() *RefNamespaceName

+ func (in *RefNamespaceName) DeepCopyInto(out *RefNamespaceName)

type ReloadOptions

+ func (in *ReloadOptions) DeepCopy() *ReloadOptions

+ func (in *ReloadOptions) DeepCopyInto(out *ReloadOptions)

type ReplicationMemberStatus

+ func (in *ReplicationMemberStatus) DeepCopy() *ReplicationMemberStatus

+ func (in *ReplicationMemberStatus) DeepCopyInto(out *ReplicationMemberStatus)

+ type ReplicationSetSpec struct

+ func (in *ReplicationSetSpec) DeepCopy() *ReplicationSetSpec

+ func (in *ReplicationSetSpec) DeepCopyInto(out *ReplicationSetSpec)

+ func (r *ReplicationSetSpec) FinalStsUpdateStrategy() (appsv1.PodManagementPolicyType, appsv1.StatefulSetUpdateStrategy)

+ func (r *ReplicationSetSpec) GetUpdateStrategy() UpdateStrategy

type ReplicationSetStatus

+ func (in *ReplicationSetStatus) DeepCopy() *ReplicationSetStatus

+ func (in *ReplicationSetStatus) DeepCopyInto(out *ReplicationSetStatus)

+ type ResourceConstraintRule struct

+ CPU CPUConstraint

+ Memory MemoryConstraint

+ Name string

+ Storage StorageConstraint

+ func (in *ResourceConstraintRule) DeepCopy() *ResourceConstraintRule

+ func (in *ResourceConstraintRule) DeepCopyInto(out *ResourceConstraintRule)

+ func (m *ResourceConstraintRule) CompleteResources(r corev1.ResourceList) corev1.ResourceList

+ func (m *ResourceConstraintRule) GetMinimalResources() corev1.ResourceList

+ func (m *ResourceConstraintRule) ValidateCPU(cpu *resource.Quantity) bool

+ func (m *ResourceConstraintRule) ValidateMemory(cpu *resource.Quantity, memory *resource.Quantity) bool

+ func (m *ResourceConstraintRule) ValidateResources(r corev1.ResourceList) bool

+ func (m *ResourceConstraintRule) ValidateStorage(storage *resource.Quantity) bool

type RestoreFromSpec

+ func (in *RestoreFromSpec) DeepCopy() *RestoreFromSpec

+ func (in *RestoreFromSpec) DeepCopyInto(out *RestoreFromSpec)

type RetentionSpec

+ func (in *RetentionSpec) DeepCopy() *RetentionSpec

+ func (in *RetentionSpec) DeepCopyInto(out *RetentionSpec)

type Schedule

+ StartingDeadlineMinutes *int64

+ func (in *Schedule) DeepCopy() *Schedule

+ func (in *Schedule) DeepCopyInto(out *Schedule)

type SchedulePolicy

+ func (in *SchedulePolicy) DeepCopy() *SchedulePolicy

+ func (in *SchedulePolicy) DeepCopyInto(out *SchedulePolicy)

+ type ScriptConfig struct

+ Namespace string

+ ScriptConfigMapRef string

+ func (in *ScriptConfig) DeepCopy() *ScriptConfig

+ func (in *ScriptConfig) DeepCopyInto(out *ScriptConfig)

+ type ScriptFrom struct

+ ConfigMapRef []corev1.ConfigMapKeySelector

+ SecretRef []corev1.SecretKeySelector

+ func (in *ScriptFrom) DeepCopy() *ScriptFrom

+ func (in *ScriptFrom) DeepCopyInto(out *ScriptFrom)

+ type ScriptSecret struct

+ Name string

+ PasswordKey string

+ UsernameKey string

+ func (in *ScriptSecret) DeepCopy() *ScriptSecret

+ func (in *ScriptSecret) DeepCopyInto(out *ScriptSecret)

+ type ScriptSpec struct

+ Image string

+ Script []string

+ ScriptFrom *ScriptFrom

+ Secret *ScriptSecret

+ func (in *ScriptSpec) DeepCopy() *ScriptSpec

+ func (in *ScriptSpec) DeepCopyInto(out *ScriptSpec)

+ type ScriptSpecSelector struct

+ Name string

+ func (in *ScriptSpecSelector) DeepCopy() *ScriptSpecSelector

+ func (in *ScriptSpecSelector) DeepCopyInto(out *ScriptSpecSelector)

type ServicePort

+ func (in *ServicePort) DeepCopy() *ServicePort

+ func (in *ServicePort) DeepCopyInto(out *ServicePort)

type ServiceSpec

+ func (in *ServiceSpec) DeepCopy() *ServiceSpec

+ func (in *ServiceSpec) DeepCopyInto(out *ServiceSpec)

type ShellTrigger

+ Command []string

+ Sync *bool

+ func (in *ShellTrigger) DeepCopy() *ShellTrigger

+ func (in *ShellTrigger) DeepCopyInto(out *ShellTrigger)

type SnapshotPolicy

+ func (in *SnapshotPolicy) DeepCopy() *SnapshotPolicy

+ func (in *SnapshotPolicy) DeepCopyInto(out *SnapshotPolicy)

+ type StatefulSetSpec struct

+ LLPodManagementPolicy appsv1.PodManagementPolicyType

+ LLUpdateStrategy *appsv1.StatefulSetUpdateStrategy

+ UpdateStrategy UpdateStrategy

+ func (in *StatefulSetSpec) DeepCopy() *StatefulSetSpec

+ func (in *StatefulSetSpec) DeepCopyInto(out *StatefulSetSpec)

+ func (r *StatefulSetSpec) FinalStsUpdateStrategy() (appsv1.PodManagementPolicyType, appsv1.StatefulSetUpdateStrategy)

+ func (r *StatefulSetSpec) GetUpdateStrategy() UpdateStrategy

+ type StatefulSetWorkload interface

+ FinalStsUpdateStrategy func() (appsv1.PodManagementPolicyType, appsv1.StatefulSetUpdateStrategy)

+ GetUpdateStrategy func() UpdateStrategy

+ type StatelessSetSpec struct

+ UpdateStrategy appsv1.DeploymentStrategy

+ func (in *StatelessSetSpec) DeepCopy() *StatelessSetSpec

+ func (in *StatelessSetSpec) DeepCopyInto(out *StatelessSetSpec)

+ type StorageConstraint struct

+ Max *resource.Quantity

+ Min *resource.Quantity

+ func (in *StorageConstraint) DeepCopy() *StorageConstraint

+ func (in *StorageConstraint) DeepCopyInto(out *StorageConstraint)

+ type Switchover struct

+ InstanceName string

+ func (in *Switchover) DeepCopy() *Switchover

+ func (in *Switchover) DeepCopyInto(out *Switchover)

+ type SwitchoverAction struct

+ CmdExecutorConfig *CmdExecutorConfig

+ ScriptSpecSelectors []ScriptSpecSelector

+ func (in *SwitchoverAction) DeepCopy() *SwitchoverAction

+ func (in *SwitchoverAction) DeepCopyInto(out *SwitchoverAction)

+ type SwitchoverShortSpec struct

+ CmdExecutorConfig *CommandExecutorEnvItem

+ func (in *SwitchoverShortSpec) DeepCopy() *SwitchoverShortSpec

+ func (in *SwitchoverShortSpec) DeepCopyInto(out *SwitchoverShortSpec)

+ type SwitchoverSpec struct

+ WithCandidate *SwitchoverAction

+ WithoutCandidate *SwitchoverAction

+ func (in *SwitchoverSpec) DeepCopy() *SwitchoverSpec

+ func (in *SwitchoverSpec) DeepCopyInto(out *SwitchoverSpec)

type SystemAccountConfig

+ func (in *SystemAccountConfig) DeepCopy() *SystemAccountConfig

+ func (in *SystemAccountConfig) DeepCopyInto(out *SystemAccountConfig)

+ type SystemAccountShortSpec struct

+ CmdExecutorConfig *CommandExecutorEnvItem

+ func (in *SystemAccountShortSpec) DeepCopy() *SystemAccountShortSpec

+ func (in *SystemAccountShortSpec) DeepCopyInto(out *SystemAccountShortSpec)

type SystemAccountSpec

+ func (in *SystemAccountSpec) DeepCopy() *SystemAccountSpec

+ func (in *SystemAccountSpec) DeepCopyInto(out *SystemAccountSpec)

type TLSSecretRef

+ func (in *TLSSecretRef) DeepCopy() *TLSSecretRef

+ func (in *TLSSecretRef) DeepCopyInto(out *TLSSecretRef)

type TPLScriptTrigger

+ func (in *TPLScriptTrigger) DeepCopy() *TPLScriptTrigger

+ func (in *TPLScriptTrigger) DeepCopyInto(out *TPLScriptTrigger)

type TargetInstance

+ func (in *TargetInstance) DeepCopy() *TargetInstance

+ func (in *TargetInstance) DeepCopyInto(out *TargetInstance)

+ type ToolConfig struct

+ Command []string

+ Image string

+ Name string

+ func (in *ToolConfig) DeepCopy() *ToolConfig

+ func (in *ToolConfig) DeepCopyInto(out *ToolConfig)

+ type ToolsImageSpec struct

+ MountPoint string

+ ToolConfigs []ToolConfig

+ func (in *ToolsImageSpec) DeepCopy() *ToolsImageSpec

+ func (in *ToolsImageSpec) DeepCopyInto(out *ToolsImageSpec)

type UnixSignalTrigger

+ func (in *UnixSignalTrigger) DeepCopy() *UnixSignalTrigger

+ func (in *UnixSignalTrigger) DeepCopyInto(out *UnixSignalTrigger)

type UpdatedParameters

+ func (in *UpdatedParameters) DeepCopy() *UpdatedParameters

+ func (in *UpdatedParameters) DeepCopyInto(out *UpdatedParameters)

type Upgrade

+ func (in *Upgrade) DeepCopy() *Upgrade

+ func (in *Upgrade) DeepCopyInto(out *Upgrade)

type VersionsContext

+ func (in *VersionsContext) DeepCopy() *VersionsContext

+ func (in *VersionsContext) DeepCopyInto(out *VersionsContext)

type VerticalScaling

+ ClassDefRef *ClassDefRef

+ func (in *VerticalScaling) DeepCopy() *VerticalScaling

+ func (in *VerticalScaling) DeepCopyInto(out *VerticalScaling)

type VolumeExpansion

+ func (in *VolumeExpansion) DeepCopy() *VolumeExpansion

+ func (in *VolumeExpansion) DeepCopyInto(out *VolumeExpansion)

+ type VolumeProtectionSpec struct

+ HighWatermark int

+ Volumes []ProtectedVolume

+ func (in *VolumeProtectionSpec) DeepCopy() *VolumeProtectionSpec

+ func (in *VolumeProtectionSpec) DeepCopyInto(out *VolumeProtectionSpec)

type VolumeTypeSpec

+ func (in *VolumeTypeSpec) DeepCopy() *VolumeTypeSpec

+ func (in *VolumeTypeSpec) DeepCopyInto(out *VolumeTypeSpec)

May 25, 2023

Changes in this version

+ const APIVersion

+ const ClusterDefinitionKind

+ const ClusterKind

+ const ClusterVersionKind

+ const ConditionTypeApplyResources

+ const ConditionTypeExpose

+ const ConditionTypeFailed

+ const ConditionTypeHaltRecovery

+ const ConditionTypeHorizontalScaling

+ const ConditionTypeLatestOpsRequestProcessed

+ const ConditionTypeProgressing

+ const ConditionTypeProvisioningStarted

+ const ConditionTypeReady

+ const ConditionTypeReconfigure

+ const ConditionTypeReplicasReady

+ const ConditionTypeRestarting

+ const ConditionTypeStart

+ const ConditionTypeStop

+ const ConditionTypeSucceed

+ const ConditionTypeValidated

+ const ConditionTypeVersionUpgrading

+ const ConditionTypeVerticalScaling

+ const ConditionTypeVolumeExpanding

+ const DefaultRoleProbeTimeoutAfterPodsReady

+ const KBAccountAdmin

+ const KBAccountDataprotection

+ const KBAccountInvalid

+ const KBAccountMAX

+ const KBAccountMonitor

+ const KBAccountProbe

+ const KBAccountReplicator

+ const OpsRequestKind

+ const ReasonClusterNotFound

+ const ReasonClusterPhaseMismatch

+ const ReasonOpsRequestFailed

+ const ReasonOpsTypeNotSupported

+ const ReasonReconfigureFailed

+ const ReasonReconfigureMerged

+ const ReasonReconfigureMerging

+ const ReasonReconfigureNoChanged

+ const ReasonReconfigureRunning

+ const ReasonReconfigureSucceed

+ const ReasonValidateFailed

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var DefaultLeader = ConsensusMember

+ var GroupVersion = schema.GroupVersion

+ var OpsRequestBehaviourMapper = map[OpsType]OpsRequestBehaviour

+ var SchemeBuilder = &scheme.Builder

+ var WorkloadTypes = []string

+ func NewExposingCondition(ops *OpsRequest) *metav1.Condition

+ func NewFailedCondition(ops *OpsRequest, err error) *metav1.Condition

+ func NewHorizontalScalingCondition(ops *OpsRequest) *metav1.Condition

+ func NewProgressingCondition(ops *OpsRequest) *metav1.Condition

+ func NewReconfigureCondition(ops *OpsRequest) *metav1.Condition

+ func NewReconfigureFailedCondition(ops *OpsRequest, err error) *metav1.Condition

+ func NewReconfigureRunningCondition(ops *OpsRequest, conditionType string, configSpecName string, info ...string) *metav1.Condition

+ func NewRestartingCondition(ops *OpsRequest) *metav1.Condition

+ func NewStartCondition(ops *OpsRequest) *metav1.Condition

+ func NewStopCondition(ops *OpsRequest) *metav1.Condition

+ func NewSucceedCondition(ops *OpsRequest) *metav1.Condition

+ func NewUpgradingCondition(ops *OpsRequest) *metav1.Condition

+ func NewValidateFailedCondition(reason, message string) *metav1.Condition

+ func NewValidatePassedCondition(opsRequestName string) *metav1.Condition

+ func NewVerticalScalingCondition(ops *OpsRequest) *metav1.Condition

+ func NewVolumeExpandingCondition(ops *OpsRequest) *metav1.Condition

+ func RegisterWebhookManager(mgr manager.Manager)

+ type AccessMode string

+ const None

+ const ReadWrite

+ const Readonly

+ type AccountName string

+ const AdminAccount

+ const DataprotectionAccount

+ const MonitorAccount

+ const ProbeAccount

+ const ReplicatorAccount

+ func (r AccountName) GetAccountID() KBAccountType

+ type Affinity struct

+ NodeLabels map[string]string

+ PodAntiAffinity PodAntiAffinity

+ Tenancy TenancyType

+ TopologyKeys []string

+ type BackupPolicy struct

+ ComponentDefRef string

+ Datafile *CommonBackupPolicy

+ Logfile *CommonBackupPolicy

+ Retention *RetentionSpec

+ Schedule Schedule

+ Snapshot *SnapshotPolicy

+ type BackupPolicyHook struct

+ ContainerName string

+ Image string

+ PostCommands []string

+ PreCommands []string

+ type BackupPolicyTemplate struct

+ Spec BackupPolicyTemplateSpec

+ Status BackupPolicyTemplateStatus

+ type BackupPolicyTemplateList struct

+ Items []BackupPolicyTemplate

+ type BackupPolicyTemplateSpec struct

+ BackupPolicies []BackupPolicy

+ ClusterDefRef string

+ Identifier string

+ type BackupPolicyTemplateStatus struct

+ type BackupRefSpec struct

+ Ref RefNamespaceName

+ type BackupStatusUpdate struct

+ ContainerName string

+ Path string

+ Script string

+ UpdateStage BackupStatusUpdateStage

+ type BackupStatusUpdateStage string

+ type BaseBackupType string

+ type BasePolicy struct

+ BackupStatusUpdates []BackupStatusUpdate

+ BackupsHistoryLimit int32

+ OnFailAttempted int32

+ Target TargetInstance

+ type CPUConstraint struct

+ Max *resource.Quantity

+ Min *resource.Quantity

+ Slots []resource.Quantity

+ Step *resource.Quantity

+ type CfgFileFormat string

+ const Dotenv

+ const HCL

+ const Ini

+ const JSON

+ const Properties

+ const RedisCfg

+ const TOML

+ const XML

+ const YAML

+ type CfgReloadType string

+ const HTTPType

+ const SQLType

+ const ShellType

+ const TPLScriptType

+ const UnixSignalType

+ type ClassDefRef struct

+ Class string

+ Name string

+ type Cluster struct

+ Spec ClusterSpec

+ Status ClusterStatus

+ func (r *Cluster) Default()

+ func (r *Cluster) GetVolumeClaimNames(compName string, claimNames ...string) []string

+ func (r *Cluster) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Cluster) ValidateCreate() error

+ func (r *Cluster) ValidateDelete() error

+ func (r *Cluster) ValidateUpdate(old runtime.Object) error

+ type ClusterComponentDefinition struct

+ CharacterType string

+ ConfigSpecs []ComponentConfigSpec

+ ConsensusSpec *ConsensusSetSpec

+ CustomLabelSpecs []CustomLabelSpec

+ Description string

+ HorizontalScalePolicy *HorizontalScalePolicy

+ LogConfigs []LogConfig

+ MaxUnavailable *intstr.IntOrString

+ Monitor *MonitorConfig

+ Name string

+ PodSpec *corev1.PodSpec

+ Probes *ClusterDefinitionProbes

+ ReplicationSpec *ReplicationSpec

+ ScriptSpecs []ComponentTemplateSpec

+ Service *ServiceSpec

+ SystemAccounts *SystemAccountSpec

+ VolumeTypes []VolumeTypeSpec

+ WorkloadType WorkloadType

+ type ClusterComponentPhase string

+ const AbnormalClusterCompPhase

+ const CreatingClusterCompPhase

+ const FailedClusterCompPhase

+ const RunningClusterCompPhase

+ const SpecReconcilingClusterCompPhase

+ const StoppedClusterCompPhase

+ func GetComponentTerminalPhases() []ClusterComponentPhase

+ type ClusterComponentService struct

+ Annotations map[string]string

+ Name string

+ ServiceType corev1.ServiceType

+ type ClusterComponentSpec struct

+ Affinity *Affinity

+ ClassDefRef *ClassDefRef

+ ComponentDefRef string

+ EnabledLogs []string

+ Issuer *Issuer

+ Monitor bool

+ Name string

+ PrimaryIndex *int32

+ Replicas int32

+ Resources corev1.ResourceRequirements

+ ServiceAccountName string

+ Services []ClusterComponentService

+ SwitchPolicy *ClusterSwitchPolicy

+ TLS bool

+ Tolerations []corev1.Toleration

+ VolumeClaimTemplates []ClusterComponentVolumeClaimTemplate

+ func (r *ClusterComponentSpec) GetPrimaryIndex() int32

+ func (r *ClusterComponentSpec) ToVolumeClaimTemplates() []corev1.PersistentVolumeClaimTemplate

+ type ClusterComponentStatus struct

+ ConsensusSetStatus *ConsensusSetStatus

+ Message ComponentMessageMap

+ Phase ClusterComponentPhase

+ PodsReady *bool

+ PodsReadyTime *metav1.Time

+ ReplicationSetStatus *ReplicationSetStatus

+ func (r *ClusterComponentStatus) SetMessage(messageMap ComponentMessageMap)

+ func (r *ClusterComponentStatus) SetObjectMessage(objectKind, objectName, message string)

+ func (r ClusterComponentStatus) GetMessage() ComponentMessageMap

+ func (r ClusterComponentStatus) GetObjectMessage(objectKind, objectName string) string

+ type ClusterComponentVersion struct

+ ClientImage string

+ ComponentDefRef string

+ ConfigSpecs []ComponentConfigSpec

+ VersionsCtx VersionsContext

+ type ClusterComponentVolumeClaimTemplate struct

+ Name string

+ Spec PersistentVolumeClaimSpec

+ type ClusterDefinition struct

+ Spec ClusterDefinitionSpec

+ Status ClusterDefinitionStatus

+ func (r *ClusterDefinition) Default()

+ func (r *ClusterDefinition) GetComponentDefByName(compDefName string) *ClusterComponentDefinition

+ func (r *ClusterDefinition) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ClusterDefinition) ValidateCreate() error

+ func (r *ClusterDefinition) ValidateDelete() error

+ func (r *ClusterDefinition) ValidateEnabledLogConfigs(compDefName string, enabledLogs []string) []string

+ func (r *ClusterDefinition) ValidateUpdate(old runtime.Object) error

+ type ClusterDefinitionList struct

+ Items []ClusterDefinition

+ type ClusterDefinitionProbe struct

+ Commands *ClusterDefinitionProbeCMDs

+ FailureThreshold int32

+ PeriodSeconds int32

+ TimeoutSeconds int32

+ type ClusterDefinitionProbeCMDs struct

+ Queries []string

+ Writes []string

+ type ClusterDefinitionProbes struct

+ RoleProbe *ClusterDefinitionProbe

+ RoleProbeTimeoutAfterPodsReady int32

+ RunningProbe *ClusterDefinitionProbe

+ StatusProbe *ClusterDefinitionProbe

+ type ClusterDefinitionSpec struct

+ ComponentDefs []ClusterComponentDefinition

+ ConnectionCredential map[string]string

+ Type string

+ type ClusterDefinitionStatus struct

+ Message string

+ ObservedGeneration int64

+ Phase Phase

+ func (r ClusterDefinitionStatus) GetTerminalPhases() []Phase

+ type ClusterList struct

+ Items []Cluster

+ type ClusterPhase string

+ const AbnormalClusterPhase

+ const CreatingClusterPhase

+ const FailedClusterPhase

+ const RunningClusterPhase

+ const SpecReconcilingClusterPhase

+ const StoppedClusterPhase

+ func GetClusterFailedPhases() []ClusterPhase

+ func GetClusterTerminalPhases() []ClusterPhase

+ func GetClusterUpRunningPhases() []ClusterPhase

+ type ClusterSpec struct

+ Affinity *Affinity

+ ClusterDefRef string

+ ClusterVersionRef string

+ ComponentSpecs []ClusterComponentSpec

+ TerminationPolicy TerminationPolicyType

+ Tolerations []corev1.Toleration

+ func (r ClusterSpec) GetComponentByName(componentName string) *ClusterComponentSpec

+ func (r ClusterSpec) GetComponentDefRefName(componentName string) string

+ func (r ClusterSpec) GetDefNameMappingComponents() map[string][]ClusterComponentSpec

+ func (r ClusterSpec) ValidateEnabledLogs(cd *ClusterDefinition) error

+ type ClusterStatus struct

+ ClusterDefGeneration int64

+ Components map[string]ClusterComponentStatus

+ Conditions []metav1.Condition

+ Message string

+ ObservedGeneration int64

+ Phase ClusterPhase

+ func (r *ClusterStatus) SetComponentStatus(name string, status ClusterComponentStatus)

+ type ClusterSwitchPolicy struct

+ Type SwitchPolicyType

+ type ClusterVersion struct

+ Spec ClusterVersionSpec

+ Status ClusterVersionStatus

+ func (r *ClusterVersion) GetInconsistentComponentsInfo(clusterDef *ClusterDefinition) ([]string, []string)

+ func (r *ClusterVersion) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ClusterVersion) ValidateCreate() error

+ func (r *ClusterVersion) ValidateDelete() error

+ func (r *ClusterVersion) ValidateUpdate(old runtime.Object) error

+ type ClusterVersionList struct

+ Items []ClusterVersion

+ type ClusterVersionSpec struct

+ ClusterDefinitionRef string

+ ComponentVersions []ClusterComponentVersion

+ func (r ClusterVersionSpec) GetDefNameMappingComponents() map[string]*ClusterComponentVersion

+ type ClusterVersionStatus struct

+ ClusterDefGeneration int64

+ Message string

+ ObservedGeneration int64

+ Phase Phase

+ func (r ClusterVersionStatus) GetTerminalPhases() []Phase

+ type CmdExecutorConfig struct

+ type CommandExecutorEnvItem struct

+ Env []corev1.EnvVar

+ Image string

+ type CommandExecutorItem struct

+ Args []string

+ Command []string

+ type CommonBackupPolicy struct

+ BackupToolName string

+ type ComponentClass struct

+ Args []string

+ CPU resource.Quantity

+ Memory resource.Quantity

+ Name string

+ Variants []ProviderComponentClassDef

+ Volumes []Volume

+ func (r *ComponentClass) ToResourceRequirements() corev1.ResourceRequirements

+ type ComponentClassDefinition struct

+ Spec ComponentClassDefinitionSpec

+ Status ComponentClassDefinitionStatus

+ type ComponentClassDefinitionList struct

+ Items []ComponentClassDefinition

+ type ComponentClassDefinitionSpec struct

+ Groups []ComponentClassGroup

+ type ComponentClassDefinitionStatus struct

+ Classes []ComponentClassInstance

+ ObservedGeneration int64

+ type ComponentClassGroup struct

+ ResourceConstraintRef string

+ Series []ComponentClassSeries

+ Template string

+ Vars []string

+ type ComponentClassInstance struct

+ ResourceConstraintRef string

+ type ComponentClassSeries struct

+ Classes []ComponentClass

+ NamingTemplate string

+ type ComponentConfigSpec struct

+ ConfigConstraintRef string

+ Keys []string

+ type ComponentMessageMap map[string]string

+ func (r ComponentMessageMap) SetObjectMessage(objectKind, objectName, message string)

+ type ComponentNameSet map[string]struct

+ type ComponentOps struct

+ ComponentName string

+ type ComponentResourceConstraint struct

+ Spec ComponentResourceConstraintSpec

+ func (c *ComponentResourceConstraint) FindMatchingConstraints(r *corev1.ResourceRequirements) []ResourceConstraint

+ func (c *ComponentResourceConstraint) MatchClass(class *ComponentClassInstance) bool

+ type ComponentResourceConstraintList struct

+ Items []ComponentResourceConstraint

+ type ComponentResourceConstraintSpec struct

+ Constraints []ResourceConstraint

+ type ComponentResourceKey string

+ const PodsCompResourceKey

+ type ComponentTemplateSpec struct

+ DefaultMode *int32

+ Name string

+ Namespace string

+ TemplateRef string

+ VolumeName string

+ type ConfigConstraint struct

+ Spec ConfigConstraintSpec

+ Status ConfigConstraintStatus

+ type ConfigConstraintList struct

+ Items []ConfigConstraint

+ type ConfigConstraintPhase string

+ const CCAvailablePhase

+ const CCDeletingPhase

+ const CCUnavailablePhase

+ type ConfigConstraintSpec struct

+ CfgSchemaTopLevelName string

+ ConfigurationSchema *CustomParametersValidation

+ DynamicParameters []string

+ FormatterConfig *FormatterConfig

+ ImmutableParameters []string

+ ReloadOptions *ReloadOptions

+ Selector *metav1.LabelSelector

+ StaticParameters []string

+ type ConfigConstraintStatus struct

+ Message string

+ ObservedGeneration int64

+ Phase ConfigConstraintPhase

+ func (cs ConfigConstraintStatus) IsConfigConstraintTerminalPhases() bool

+ type Configuration struct

+ Keys []ParameterConfig

+ Name string

+ type ConfigurationStatus struct

+ ExpectedCount int32

+ LastAppliedConfiguration map[string]string

+ LastAppliedStatus string

+ Name string

+ Status string

+ SucceedCount int32

+ UpdatePolicy UpgradePolicy

+ UpdatedParameters UpdatedParameters

+ type ConnectionCredentialKey struct

+ PasswordKey *string

+ UsernameKey *string

+ type ConsensusMember struct

+ AccessMode AccessMode

+ Name string

+ Replicas *int32

+ type ConsensusMemberStatus struct

+ AccessMode AccessMode

+ Name string

+ Pod string

+ type ConsensusSetSpec struct

+ Followers []ConsensusMember

+ Leader ConsensusMember

+ Learner *ConsensusMember

+ UpdateStrategy UpdateStrategy

+ type ConsensusSetStatus struct

+ Followers []ConsensusMemberStatus

+ Leader ConsensusMemberStatus

+ Learner *ConsensusMemberStatus

+ type CustomLabelSpec struct

+ Key string

+ Resources []GVKResource

+ Value string

+ type CustomParametersValidation struct

+ CUE string

+ Schema *apiext.JSONSchemaProps

+ type ExporterConfig struct

+ ScrapePath string

+ ScrapePort intstr.IntOrString

+ type Expose struct

+ Services []ClusterComponentService

+ type FormatterConfig struct

+ Format CfgFileFormat

+ type FormatterOptions struct

+ IniConfig *IniConfig

+ type GVKResource struct

+ GVK string

+ Selector map[string]string

+ type HScaleDataClonePolicyType string

+ const HScaleDataClonePolicyFromBackup

+ const HScaleDataClonePolicyFromSnapshot

+ const HScaleDataClonePolicyNone

+ type HorizontalScalePolicy struct

+ BackupPolicyTemplateName string

+ Type HScaleDataClonePolicyType

+ VolumeMountsName string

+ type HorizontalScaling struct

+ Replicas int32

+ type IniConfig struct

+ SectionName string

+ type Issuer struct

+ Name IssuerName

+ SecretRef *TLSSecretRef

+ type IssuerName string

+ const IssuerKubeBlocks

+ const IssuerUserProvided

+ type KBAccountType uint8

+ type LastComponentConfiguration struct

+ Class string

+ Replicas *int32

+ Services []ClusterComponentService

+ TargetResources map[ComponentResourceKey][]string

+ VolumeClaimTemplates []OpsRequestVolumeClaimTemplate

+ type LastConfiguration struct

+ ClusterVersionRef string

+ Components map[string]LastComponentConfiguration

+ type LetterCase string

+ const LowerCases

+ const MixedCases

+ const UpperCases

+ type LogConfig struct

+ FilePathPattern string

+ Name string

+ type MemoryConstraint struct

+ MaxPerCPU *resource.Quantity

+ MinPerCPU *resource.Quantity

+ SizePerCPU *resource.Quantity

+ type MonitorConfig struct

+ BuiltIn bool

+ Exporter *ExporterConfig

+ type OpsPhase string

+ const OpsCreatingPhase

+ const OpsFailedPhase

+ const OpsPendingPhase

+ const OpsRunningPhase

+ const OpsSucceedPhase

+ type OpsRecorder struct

+ Name string

+ Type OpsType

+ type OpsRequest struct

+ Spec OpsRequestSpec

+ Status OpsRequestStatus

+ func (r *OpsRequest) GetComponentNameSet() ComponentNameSet

+ func (r *OpsRequest) GetUpgradeComponentNameSet() ComponentNameSet

+ func (r *OpsRequest) SetStatusCondition(condition metav1.Condition)

+ func (r *OpsRequest) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *OpsRequest) Validate(ctx context.Context, k8sClient client.Client, cluster *Cluster, isCreate bool) error

+ func (r *OpsRequest) ValidateCreate() error

+ func (r *OpsRequest) ValidateDelete() error

+ func (r *OpsRequest) ValidateUpdate(old runtime.Object) error

+ type OpsRequestBehaviour struct

+ FromClusterPhases []ClusterPhase

+ ProcessingReasonInClusterCondition string

+ ToClusterPhase ClusterPhase

+ type OpsRequestComponentStatus struct

+ Phase ClusterComponentPhase

+ ProgressDetails []ProgressStatusDetail

+ WorkloadType WorkloadType

+ type OpsRequestList struct

+ Items []OpsRequest

+ type OpsRequestSpec struct

+ ClusterRef string

+ ExposeList []Expose

+ HorizontalScalingList []HorizontalScaling

+ Reconfigure *Reconfigure

+ RestartList []ComponentOps

+ RestoreFrom *RestoreFromSpec

+ TTLSecondsAfterSucceed int32

+ Type OpsType

+ Upgrade *Upgrade

+ VerticalScalingList []VerticalScaling

+ VolumeExpansionList []VolumeExpansion

+ func (r OpsRequestSpec) GetExposeComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) GetHorizontalScalingComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) GetReconfiguringComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) GetRestartComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) GetVerticalScalingComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) GetVolumeExpansionComponentNameSet() ComponentNameSet

+ func (r OpsRequestSpec) ToExposeListToMap() map[string]Expose

+ func (r OpsRequestSpec) ToHorizontalScalingListToMap() map[string]HorizontalScaling

+ func (r OpsRequestSpec) ToVerticalScalingListToMap() map[string]VerticalScaling

+ func (r OpsRequestSpec) ToVolumeExpansionListToMap() map[string]VolumeExpansion

+ type OpsRequestStatus struct

+ ClusterGeneration int64

+ CompletionTimestamp metav1.Time

+ Components map[string]OpsRequestComponentStatus

+ Conditions []metav1.Condition

+ LastConfiguration LastConfiguration

+ Phase OpsPhase

+ Progress string

+ ReconfiguringStatus *ReconfiguringStatus

+ StartTimestamp metav1.Time

+ type OpsRequestVolumeClaimTemplate struct

+ Name string

+ Storage resource.Quantity

+ type OpsType string

+ const ExposeType

+ const HorizontalScalingType

+ const ReconfiguringType

+ const RestartType

+ const StartType

+ const StopType

+ const UpgradeType

+ const VerticalScalingType

+ const VolumeExpansionType

+ type ParameterConfig struct

+ Key string

+ Parameters []ParameterPair

+ type ParameterPair struct

+ Key string

+ Value *string

+ type PasswordConfig struct

+ Length int32

+ LetterCase LetterCase

+ NumDigits int32

+ NumSymbols int32

+ type PersistentVolumeClaimSpec struct

+ AccessModes []corev1.PersistentVolumeAccessMode

+ Resources corev1.ResourceRequirements

+ StorageClassName *string

+ func (r PersistentVolumeClaimSpec) GetStorageClassName(preferSC string) *string

+ func (r PersistentVolumeClaimSpec) ToV1PersistentVolumeClaimSpec() corev1.PersistentVolumeClaimSpec

+ type Phase string

+ const AvailablePhase

+ const UnavailablePhase

+ type PodAntiAffinity string

+ const Preferred

+ const Required

+ type PointInTimeRefSpec struct

+ Ref RefNamespaceName

+ Time *metav1.Time

+ type ProgressStatus string

+ const FailedProgressStatus

+ const PendingProgressStatus

+ const ProcessingProgressStatus

+ const SucceedProgressStatus

+ type ProgressStatusDetail struct

+ EndTime metav1.Time

+ Group string

+ Message string

+ ObjectKey string

+ StartTime metav1.Time

+ Status ProgressStatus

+ func (p *ProgressStatusDetail) SetStatusAndMessage(status ProgressStatus, message string)

+ type ProviderComponentClassDef struct

+ Args []string

+ Provider string

+ type ProvisionPolicy struct

+ Scope ProvisionScope

+ SecretRef *ProvisionSecretRef

+ Statements *ProvisionStatements

+ Type ProvisionPolicyType

+ type ProvisionPolicyType string

+ const CreateByStmt

+ const ReferToExisting

+ type ProvisionScope string

+ const AllPods

+ const AnyPods

+ type ProvisionSecretRef struct

+ Name string

+ Namespace string

+ type ProvisionStatements struct

+ CreationStatement string

+ DeletionStatement string

+ type Reconfigure struct

+ Configurations []Configuration

+ type ReconfiguringStatus struct

+ ConfigurationStatus []ConfigurationStatus

+ type RefNamespaceName struct

+ Name string

+ Namespace string

+ type ReloadOptions struct

+ ShellTrigger *ShellTrigger

+ TPLScriptTrigger *TPLScriptTrigger

+ UnixSignalTrigger *UnixSignalTrigger

+ type ReplicationMemberStatus struct

+ Pod string

+ type ReplicationSetStatus struct

+ Primary ReplicationMemberStatus

+ Secondaries []ReplicationMemberStatus

+ type ReplicationSpec struct

+ SwitchCmdExecutorConfig *SwitchCmdExecutorConfig

+ SwitchPolicies []SwitchPolicy

+ type ResourceConstraint struct

+ CPU CPUConstraint

+ Memory MemoryConstraint

+ func (m ResourceConstraint) ValidateCPU(cpu resource.Quantity) bool

+ func (m ResourceConstraint) ValidateMemory(cpu *resource.Quantity, memory *resource.Quantity) bool

+ func (m ResourceConstraint) ValidateResourceRequirements(r *corev1.ResourceRequirements) bool

+ type RestoreFromSpec struct

+ Backup []BackupRefSpec

+ PointInTime *PointInTimeRefSpec

+ type RetentionSpec struct

+ TTL *string

+ type Schedule struct

+ Datafile *SchedulePolicy

+ Logfile *SchedulePolicy

+ Snapshot *SchedulePolicy

+ type SchedulePolicy struct

+ CronExpression string

+ Enable bool

+ type ServicePort struct

+ AppProtocol *string

+ Name string

+ Port int32

+ Protocol corev1.Protocol

+ TargetPort intstr.IntOrString

+ type ServiceSpec struct

+ Ports []ServicePort

+ func (r ServiceSpec) ToSVCSpec() corev1.ServiceSpec

+ type ShellTrigger struct

+ Exec string

+ Namespace string

+ ScriptConfigMapRef string

+ type SignalType string

+ const SIGABRT

+ const SIGALRM

+ const SIGBUS

+ const SIGCHLD

+ const SIGCONT

+ const SIGFPE

+ const SIGHUP

+ const SIGILL

+ const SIGINT

+ const SIGIO

+ const SIGKILL

+ const SIGPIPE

+ const SIGPROF

+ const SIGPWR

+ const SIGQUIT

+ const SIGSEGV

+ const SIGSTKFLT

+ const SIGSTOP

+ const SIGSYS

+ const SIGTERM

+ const SIGTRAP

+ const SIGTSTP

+ const SIGTTIN

+ const SIGTTOU

+ const SIGURG

+ const SIGUSR1

+ const SIGUSR2

+ const SIGVTALRM

+ const SIGWINCH

+ const SIGXCPU

+ const SIGXFSZ

+ type SnapshotPolicy struct

+ Hooks *BackupPolicyHook

+ type SwitchCmdExecutorConfig struct

+ SwitchSteps []SwitchStep

+ type SwitchPolicy struct

+ SwitchStatements *SwitchStatements

+ Type SwitchPolicyType

+ type SwitchPolicyType string

+ const MaximumAvailability

+ const MaximumDataProtection

+ const Noop

+ type SwitchStatements struct

+ Demote []string

+ Follow []string

+ Promote []string

+ type SwitchStep struct

+ Role SwitchStepRole

+ type SwitchStepRole string

+ const NewPrimary

+ const OldPrimary

+ const Secondaries

+ type SystemAccountConfig struct

+ Name AccountName

+ ProvisionPolicy ProvisionPolicy

+ type SystemAccountSpec struct

+ Accounts []SystemAccountConfig

+ CmdExecutorConfig *CmdExecutorConfig

+ PasswordConfig PasswordConfig

+ type TLSSecretRef struct

+ CA string

+ Cert string

+ Key string

+ Name string

+ type TPLScriptTrigger struct

+ Namespace string

+ ScriptConfigMapRef string

+ Sync *bool

+ type TargetInstance struct

+ Account string

+ ConnectionCredentialKey ConnectionCredentialKey

+ Role string

+ type TenancyType string

+ const DedicatedNode

+ const SharedNode

+ type TerminationPolicyType string

+ const Delete

+ const DoNotTerminate

+ const Halt

+ const WipeOut

+ type UnixSignalTrigger struct

+ ProcessName string

+ Signal SignalType

+ type UpdateStrategy string

+ const BestEffortParallelStrategy

+ const ParallelStrategy

+ const SerialStrategy

+ type UpdatedParameters struct

+ AddedKeys map[string]string

+ DeletedKeys map[string]string

+ UpdatedKeys map[string]string

+ type Upgrade struct

+ ClusterVersionRef string

+ type UpgradePolicy string

+ const AutoReload

+ const NonePolicy

+ const NormalPolicy

+ const OperatorSyncUpdate

+ const RestartPolicy

+ const RollingPolicy

+ type VersionsContext struct

+ Containers []corev1.Container

+ InitContainers []corev1.Container

+ type VerticalScaling struct

+ Class string

+ type Volume struct

+ Name string

+ Size resource.Quantity

+ StorageClassName *string

+ type VolumeExpansion struct

+ VolumeClaimTemplates []OpsRequestVolumeClaimTemplate

+ type VolumeType string

+ const VolumeTypeData

+ const VolumeTypeLog

+ type VolumeTypeSpec struct

+ Name string

+ Type VolumeType

+ type WorkloadType string

+ const Consensus

+ const Replication

+ const Stateful

+ const Stateless