v1beta1

package
v0.0.0-...-173a242 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 26, 2025 License: Apache-2.0 Imports: 24 Imported by: 1

Documentation

Overview

Package v1beta1 contains API Schema definitions for the asdb v1beta1 API group +kubebuilder:object:generate=true +groupName=asdb.aerospike.com

Index

Constants

View Source 
const (
	ServiceKey              = "service"
	AerospikeClustersKey    = "aerospike-clusters"
	AerospikeClusterKey     = "aerospike-cluster"
	StorageKey              = "storage"
	BackupRoutinesKey       = "backup-routines"
	BackupPoliciesKey       = "backup-policies"
	SecretAgentsKey         = "secret-agents"
	SourceClusterKey        = "source-cluster"
	BackupServiceConfigYAML = "aerospike-backup-service.yml"
)

Backup Config relate keys

View Source 
const (
	RoutineKey        = "routine"
	TimeKey           = "time"
	SourceKey         = "source"
	BackupDataPathKey = "backup-data-path"
)

Restore config fields

View Source 
const (
	HTTPKey                   = "http"
	AerospikeBackupServiceKey = "aerospike-backup-service"
	RefreshTimeKey            = AerospikeBackupServiceKey + "/last-refresh"
)
View Source 
const MinSupportedVersion = "3.0.0"

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "asdb.aerospike.com", Version: "v1beta1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

func SetupAerospikeBackupServiceWebhookWithManager 

func SetupAerospikeBackupServiceWebhookWithManager(mgr ctrl.Manager) error

SetupAerospikeBackupServiceWebhookWithManager registers the webhook for AerospikeBackupService in the manager.

func SetupAerospikeBackupWebhookWithManager 

func SetupAerospikeBackupWebhookWithManager(mgr ctrl.Manager) error

SetupAerospikeBackupWebhookWithManager registers the webhook for AerospikeBackup in the manager.

func SetupAerospikeRestoreWebhookWithManager 

func SetupAerospikeRestoreWebhookWithManager(mgr ctrl.Manager) error

SetupAerospikeRestoreWebhookWithManager registers the webhook for AerospikeRestore in the manager.

func ValidateBackupSvcSupportedVersion 

func ValidateBackupSvcSupportedVersion(k8sClient client.Client, name, namespace string) error

ValidateBackupSvcSupportedVersion validates the supported backup service version. It returns an error if the backup service version is less than 3.0.0.

func ValidateBackupSvcVersion 

func ValidateBackupSvcVersion(image string) error

Types

type AerospikeBackup 

type AerospikeBackup struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AerospikeBackupSpec   `json:"spec,omitempty"`
	Status AerospikeBackupStatus `json:"status,omitempty"`
}

AerospikeBackup is the Schema for the aerospikebackup API

func (*AerospikeBackup) DeepCopy 

func (in *AerospikeBackup) DeepCopy() *AerospikeBackup

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackup.

func (*AerospikeBackup) DeepCopyInto 

func (in *AerospikeBackup) DeepCopyInto(out *AerospikeBackup)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AerospikeBackup) DeepCopyObject 

func (in *AerospikeBackup) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*AerospikeBackup) NamePrefix 

func (r *AerospikeBackup) NamePrefix() string

type AerospikeBackupCustomDefaulter 

type AerospikeBackupCustomDefaulter struct {
}

+kubebuilder:object:generate=false Above marker prevents controller-gen from generating DeepCopy methods, as it is used only for temporary operations and does not need to be deeply copied.

func (*AerospikeBackupCustomDefaulter) Default 

func (abd *AerospikeBackupCustomDefaulter) Default(_ context.Context, obj runtime.Object) error

Default implements webhook.CustomDefaulter so a webhook will be registered for the type

type AerospikeBackupCustomValidator 

type AerospikeBackupCustomValidator struct {
}

+kubebuilder:object:generate=false

func (*AerospikeBackupCustomValidator) ValidateCreate 

func (abv *AerospikeBackupCustomValidator) ValidateCreate(_ context.Context, obj runtime.Object,
) (admission.Warnings, error)

ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type

func (*AerospikeBackupCustomValidator) ValidateDelete 

func (abv *AerospikeBackupCustomValidator) ValidateDelete(_ context.Context, obj runtime.Object,
) (admission.Warnings, error)

ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type

func (*AerospikeBackupCustomValidator) ValidateUpdate 

func (abv *AerospikeBackupCustomValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object,
) (admission.Warnings, error)

ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type

type AerospikeBackupList 

type AerospikeBackupList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AerospikeBackup `json:"items"`
}

AerospikeBackupList contains a list of AerospikeBackup

func (*AerospikeBackupList) DeepCopy 

func (in *AerospikeBackupList) DeepCopy() *AerospikeBackupList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupList.

func (*AerospikeBackupList) DeepCopyInto 

func (in *AerospikeBackupList) DeepCopyInto(out *AerospikeBackupList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AerospikeBackupList) DeepCopyObject 

func (in *AerospikeBackupList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AerospikeBackupService 

type AerospikeBackupService struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AerospikeBackupServiceSpec   `json:"spec,omitempty"`
	Status AerospikeBackupServiceStatus `json:"status,omitempty"`
}

AerospikeBackupService is the Schema for the aerospikebackupservices API

func (*AerospikeBackupService) DeepCopy 

func (in *AerospikeBackupService) DeepCopy() *AerospikeBackupService

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupService.

func (*AerospikeBackupService) DeepCopyInto 

func (in *AerospikeBackupService) DeepCopyInto(out *AerospikeBackupService)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AerospikeBackupService) DeepCopyObject 

func (in *AerospikeBackupService) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AerospikeBackupServiceCustomDefaulter 

type AerospikeBackupServiceCustomDefaulter struct {
}

+kubebuilder:object:generate=false Above marker prevents controller-gen from generating DeepCopy methods, as it is used only for temporary operations and does not need to be deeply copied.

func (*AerospikeBackupServiceCustomDefaulter) Default 

func (absd *AerospikeBackupServiceCustomDefaulter) Default(_ context.Context, obj runtime.Object) error

Default implements webhook.CustomDefaulter so a webhook will be registered for the type

type AerospikeBackupServiceCustomValidator 

type AerospikeBackupServiceCustomValidator struct {
}

+kubebuilder:object:generate=false

func (*AerospikeBackupServiceCustomValidator) ValidateCreate 

func (absv *AerospikeBackupServiceCustomValidator) ValidateCreate(_ context.Context, obj runtime.Object,
) (admission.Warnings, error)

ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type

func (*AerospikeBackupServiceCustomValidator) ValidateDelete 

func (absv *AerospikeBackupServiceCustomValidator) ValidateDelete(_ context.Context, obj runtime.Object,
) (admission.Warnings, error)

ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type

func (*AerospikeBackupServiceCustomValidator) ValidateUpdate 

func (absv *AerospikeBackupServiceCustomValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object,
) (admission.Warnings, error)

ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type

type AerospikeBackupServiceList 

type AerospikeBackupServiceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AerospikeBackupService `json:"items"`
}

AerospikeBackupServiceList contains a list of AerospikeBackupService

func (*AerospikeBackupServiceList) DeepCopy 

func (in *AerospikeBackupServiceList) DeepCopy() *AerospikeBackupServiceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupServiceList.

func (*AerospikeBackupServiceList) DeepCopyInto 

func (in *AerospikeBackupServiceList) DeepCopyInto(out *AerospikeBackupServiceList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AerospikeBackupServiceList) DeepCopyObject 

func (in *AerospikeBackupServiceList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AerospikeBackupServicePhase 

type AerospikeBackupServicePhase string

+kubebuilder:validation:Enum=InProgress;Completed;Error 

const (
	// AerospikeBackupServiceInProgress means the AerospikeBackupService CR is being reconciled and operations are
	// in-progress state. This phase denotes that AerospikeBackupService resources are gradually getting deployed.
	AerospikeBackupServiceInProgress AerospikeBackupServicePhase = "InProgress"

	// AerospikeBackupServiceCompleted means the AerospikeBackupService CR has been reconciled.
	// This phase denotes that the AerospikeBackupService resources have been deployed/upgraded successfully and is
	// ready to use.
	AerospikeBackupServiceCompleted AerospikeBackupServicePhase = "Completed"

	// AerospikeBackupServiceError means the AerospikeBackupService operation is in error state because of some reason
	// like incorrect backup service config, incorrect image, etc.
	AerospikeBackupServiceError AerospikeBackupServicePhase = "Error"
)

These are the valid phases of Aerospike Backup Service reconcile flow.

type AerospikeBackupServiceSpec 

type AerospikeBackupServiceSpec struct {
	// Image is the image for the backup service.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Service Image"
	Image string `json:"image"`

	// Config is the free form configuration for the backup service in YAML format.
	// This config is used to start the backup service. The config is passed as a file to the backup service.
	// It includes: service, backup-policies, storage, secret-agent.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Service Config"
	Config runtime.RawExtension `json:"config"`

	// Specify additional configuration for the AerospikeBackupService pods
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Pod Configuration"
	// +optional
	PodSpec ServicePodSpec `json:"podSpec,omitempty"`

	// Resources defines the requests and limits for the backup service container.
	// Resources.Limits should be more than Resources.Requests.
	// Deprecated: Resources field is now part of spec.podSpec.serviceContainer
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Resources"
	// +optional
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`

	// SecretMounts is the list of secret to be mounted in the backup service.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Service SecretMounts"
	// +optional
	SecretMounts []SecretMount `json:"secrets,omitempty"`

	// Service defines the Kubernetes service configuration for the backup service.
	// It is used to expose the backup service deployment. By default, the service type is ClusterIP.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="K8s Service"
	// +optional
	Service *Service `json:"service,omitempty"`
}

AerospikeBackupServiceSpec defines the desired state of AerospikeBackupService +k8s:openapi-gen=true

func (*AerospikeBackupServiceSpec) DeepCopy 

func (in *AerospikeBackupServiceSpec) DeepCopy() *AerospikeBackupServiceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupServiceSpec.

func (*AerospikeBackupServiceSpec) DeepCopyInto 

func (in *AerospikeBackupServiceSpec) DeepCopyInto(out *AerospikeBackupServiceSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AerospikeBackupServiceStatus 

type AerospikeBackupServiceStatus struct {
	// Image is the image for the backup service.
	// +optional
	Image string `json:"image,omitempty"`

	// Config is the free form configuration for the backup service in YAML format.
	// This config is used to start the backup service. The config is passed as a file to the backup service.
	// It includes: service, backup-policies, storage, secret-agent.
	// +optional
	Config runtime.RawExtension `json:"config,omitempty"`

	// Specify additional configuration for the AerospikeBackupService pods
	// +optional
	PodSpec ServicePodSpec `json:"podSpec,omitempty"`

	// Resources define the requests and limits for the backup service container.
	// Resources.Limits should be more than Resources.Requests.
	// Deprecated: Resources field is now part of status.podSpec.serviceContainer
	// +optional
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`

	// SecretMounts is the list of secret to be mounted in the backup service.
	// +optional
	SecretMounts []SecretMount `json:"secrets,omitempty"`

	// Service defines the Kubernetes service configuration for the backup service.
	// It is used to expose the backup service deployment. By default, the service type is ClusterIP.
	// +optional
	Service *Service `json:"service,omitempty"`

	// ContextPath is the backup service API context path
	// +optional
	ContextPath string `json:"contextPath,omitempty"`

	// Phase denotes Backup service phase
	Phase AerospikeBackupServicePhase `json:"phase"`

	// Port is the listening port of backup service
	// +optional
	Port int32 `json:"port,omitempty"`
}

AerospikeBackupServiceStatus defines the observed state of AerospikeBackupService

func (*AerospikeBackupServiceStatus) DeepCopy 

func (in *AerospikeBackupServiceStatus) DeepCopy() *AerospikeBackupServiceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupServiceStatus.

func (*AerospikeBackupServiceStatus) DeepCopyInto 

func (in *AerospikeBackupServiceStatus) DeepCopyInto(out *AerospikeBackupServiceStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AerospikeBackupSpec 

type AerospikeBackupSpec struct {
	// BackupService is the backup service reference i.e. name and namespace.
	// It is used to communicate to the backup service to trigger backups. This field is immutable
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Service"
	BackupService BackupService `json:"backupService"`

	// Config is the free form configuration for the backup in YAML format.
	// This config is used to trigger backups. It includes: aerospike-cluster, backup-routines.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Config"
	Config runtime.RawExtension `json:"config"`

	// OnDemandBackups is the configuration for on-demand backups.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="On Demand Backups"
	// +kubebuilder:validation:MaxItems:=1
	// +optional
	OnDemandBackups []OnDemandBackupSpec `json:"onDemandBackups,omitempty"`
}

AerospikeBackupSpec defines the desired state of AerospikeBackup for a given AerospikeCluster +k8s:openapi-gen=true

func (*AerospikeBackupSpec) DeepCopy 

func (in *AerospikeBackupSpec) DeepCopy() *AerospikeBackupSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupSpec.

func (*AerospikeBackupSpec) DeepCopyInto 

func (in *AerospikeBackupSpec) DeepCopyInto(out *AerospikeBackupSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AerospikeBackupStatus 

type AerospikeBackupStatus struct {
	// BackupService is the backup service reference i.e. name and namespace.
	BackupService BackupService `json:"backupService"`

	// Config is the configuration for the backup in YAML format.
	// This config is used to trigger backups. It includes: aerospike-cluster, backup-routines.
	Config runtime.RawExtension `json:"config"`

	// OnDemandBackups is the configuration for on-demand backups.
	// +optional
	OnDemandBackups []OnDemandBackupSpec `json:"onDemandBackups,omitempty"`
}

AerospikeBackupStatus defines the observed state of AerospikeBackup

func (*AerospikeBackupStatus) DeepCopy 

func (in *AerospikeBackupStatus) DeepCopy() *AerospikeBackupStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeBackupStatus.

func (*AerospikeBackupStatus) DeepCopyInto 

func (in *AerospikeBackupStatus) DeepCopyInto(out *AerospikeBackupStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AerospikeObjectMeta 

type AerospikeObjectMeta struct {
	// Key - Value pair that may be set by external tools to store and retrieve arbitrary metadata
	// +optional
	Annotations map[string]string `json:"annotations,omitempty"`

	// Key - Value pairs that can be used to organize and categorize scope and select objects
	// +optional
	Labels map[string]string `json:"labels,omitempty"`
}

func (*AerospikeObjectMeta) DeepCopy 

func (in *AerospikeObjectMeta) DeepCopy() *AerospikeObjectMeta

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeObjectMeta.

func (*AerospikeObjectMeta) DeepCopyInto 

func (in *AerospikeObjectMeta) DeepCopyInto(out *AerospikeObjectMeta)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AerospikeRestore 

type AerospikeRestore struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   AerospikeRestoreSpec   `json:"spec,omitempty"`
	Status AerospikeRestoreStatus `json:"status,omitempty"`
}

AerospikeRestore is the Schema for the aerospikerestores API

func (*AerospikeRestore) DeepCopy 

func (in *AerospikeRestore) DeepCopy() *AerospikeRestore

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeRestore.

func (*AerospikeRestore) DeepCopyInto 

func (in *AerospikeRestore) DeepCopyInto(out *AerospikeRestore)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AerospikeRestore) DeepCopyObject 

func (in *AerospikeRestore) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AerospikeRestoreCustomDefaulter 

type AerospikeRestoreCustomDefaulter struct {
}

+kubebuilder:object:generate=false Above marker prevents controller-gen from generating DeepCopy methods, as it is used only for temporary operations and does not need to be deeply copied.

func (*AerospikeRestoreCustomDefaulter) Default 

func (ard *AerospikeRestoreCustomDefaulter) Default(_ context.Context, obj runtime.Object) error

Default implements webhook.CustomDefaulter so a webhook will be registered for the type

type AerospikeRestoreCustomValidator 

type AerospikeRestoreCustomValidator struct {
}

+kubebuilder:object:generate=false

func (*AerospikeRestoreCustomValidator) ValidateCreate 

func (arv *AerospikeRestoreCustomValidator) ValidateCreate(_ context.Context, obj runtime.Object,
) (admission.Warnings, error)

ValidateCreate implements webhook.CustomValidator so a webhook will be registered for the type

func (*AerospikeRestoreCustomValidator) ValidateDelete 

func (arv *AerospikeRestoreCustomValidator) ValidateDelete(_ context.Context, obj runtime.Object,
) (admission.Warnings, error)

ValidateDelete implements webhook.CustomValidator so a webhook will be registered for the type

func (*AerospikeRestoreCustomValidator) ValidateUpdate 

func (arv *AerospikeRestoreCustomValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object,
) (admission.Warnings, error)

ValidateUpdate implements webhook.CustomValidator so a webhook will be registered for the type

type AerospikeRestoreList 

type AerospikeRestoreList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []AerospikeRestore `json:"items"`
}

AerospikeRestoreList contains a list of AerospikeRestore

func (*AerospikeRestoreList) DeepCopy 

func (in *AerospikeRestoreList) DeepCopy() *AerospikeRestoreList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeRestoreList.

func (*AerospikeRestoreList) DeepCopyInto 

func (in *AerospikeRestoreList) DeepCopyInto(out *AerospikeRestoreList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*AerospikeRestoreList) DeepCopyObject 

func (in *AerospikeRestoreList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type AerospikeRestorePhase 

type AerospikeRestorePhase string

+kubebuilder:validation:Enum=InProgress;Completed;Failed 

const (
	// AerospikeRestoreInProgress means the AerospikeRestore CR is being reconciled and restore operation is going on.
	AerospikeRestoreInProgress AerospikeRestorePhase = "InProgress"

	// AerospikeRestoreCompleted means the AerospikeRestore CR has been reconciled and restore operation is completed.
	AerospikeRestoreCompleted AerospikeRestorePhase = "Completed"

	// AerospikeRestoreFailed means the AerospikeRestore CR has been reconciled and restore operation is failed.
	AerospikeRestoreFailed AerospikeRestorePhase = "Failed"
)

These are the valid phases of Aerospike restore operation.

type AerospikeRestoreSpec 

type AerospikeRestoreSpec struct {
	// BackupService is the backup service reference i.e. name and namespace.
	// It is used to communicate to the backup service to trigger restores. This field is immutable
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Backup Service"
	BackupService BackupService `json:"backupService"`

	// Type is the type of restore. It can of type Full, Incremental, and Timestamp.
	// Based on the restore type, the relevant restore config should be given.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Restore Type"
	// +kubebuilder:validation:Enum=Full;Incremental;Timestamp
	Type RestoreType `json:"type"`

	// Config is the free form configuration for the restore in YAML format.
	// This config is used to trigger restores. It includes: destination, policy, source, secret-agent, time and routine.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Restore Config"
	Config runtime.RawExtension `json:"config"`

	// PollingPeriod is the polling period for restore operation status.
	// It is used to poll the restore service to fetch restore operation status.
	// Default is 60 seconds.
	// +operator-sdk:csv:customresourcedefinitions:type=spec,displayName="Restore Service Polling Period"
	// +optional
	PollingPeriod metav1.Duration `json:"pollingPeriod,omitempty"`
}

AerospikeRestoreSpec defines the desired state of AerospikeRestore +k8s:openapi-gen=true

func (*AerospikeRestoreSpec) DeepCopy 

func (in *AerospikeRestoreSpec) DeepCopy() *AerospikeRestoreSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeRestoreSpec.

func (*AerospikeRestoreSpec) DeepCopyInto 

func (in *AerospikeRestoreSpec) DeepCopyInto(out *AerospikeRestoreSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AerospikeRestoreStatus 

type AerospikeRestoreStatus struct {
	// JobID is the restore operation job id.
	// +optional
	JobID *int64 `json:"job-id,omitempty"`

	// RestoreResult is the result of the restore operation.
	// +optional
	RestoreResult runtime.RawExtension `json:"restoreResult,omitempty"`

	// Phase denotes the current phase of Aerospike restore operation.
	Phase AerospikeRestorePhase `json:"phase"`
}

AerospikeRestoreStatus defines the observed state of AerospikeRestore

func (*AerospikeRestoreStatus) DeepCopy 

func (in *AerospikeRestoreStatus) DeepCopy() *AerospikeRestoreStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AerospikeRestoreStatus.

func (*AerospikeRestoreStatus) DeepCopyInto 

func (in *AerospikeRestoreStatus) DeepCopyInto(out *AerospikeRestoreStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BackupService 

type BackupService struct {
	// Backup service name
	Name string `json:"name"`

	// Backup service namespace
	Namespace string `json:"namespace"`
}

func (*BackupService) DeepCopy 

func (in *BackupService) DeepCopy() *BackupService

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BackupService.

func (*BackupService) DeepCopyInto 

func (in *BackupService) DeepCopyInto(out *BackupService)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BackupService) String 

func (b *BackupService) String() string

type OnDemandBackupSpec 

type OnDemandBackupSpec struct {
	// ID is the unique identifier for the on-demand backup.
	// +kubebuilder:validation:MinLength=1
	ID string `json:"id"`

	// RoutineName is the routine name used to trigger on-demand backup.
	RoutineName string `json:"routineName"`

	// Delay is the interval before starting the on-demand backup.
	// +optional
	Delay metav1.Duration `json:"delay,omitempty"`
}

func (*OnDemandBackupSpec) DeepCopy 

func (in *OnDemandBackupSpec) DeepCopy() *OnDemandBackupSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OnDemandBackupSpec.

func (*OnDemandBackupSpec) DeepCopyInto 

func (in *OnDemandBackupSpec) DeepCopyInto(out *OnDemandBackupSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RestoreType 

type RestoreType string
const (
	Full        RestoreType = "Full"
	Incremental RestoreType = "Incremental"
	Timestamp   RestoreType = "Timestamp"
)

type SchedulingPolicy 

type SchedulingPolicy struct {
	// Affinity rules for pod placement.
	// +optional
	Affinity *corev1.Affinity `json:"affinity,omitempty"`

	// Tolerations for this pod.
	// +optional
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`

	// NodeSelector constraints for this pod.
	// +optional
	NodeSelector map[string]string `json:"nodeSelector,omitempty"`
}

SchedulingPolicy controls pod placement on Kubernetes nodes.

func (*SchedulingPolicy) DeepCopy 

func (in *SchedulingPolicy) DeepCopy() *SchedulingPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SchedulingPolicy.

func (*SchedulingPolicy) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SecretMount 

type SecretMount struct {
	// SecretName is the name of the secret to be mounted.
	SecretName string `json:"secretName"`

	// VolumeMount is the volume mount options for the secret.
	VolumeMount corev1.VolumeMount `json:"volumeMount"`
}

SecretMount specifies the secret and its corresponding volume mount options.

func (*SecretMount) DeepCopy 

func (in *SecretMount) DeepCopy() *SecretMount

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SecretMount.

func (*SecretMount) DeepCopyInto 

func (in *SecretMount) DeepCopyInto(out *SecretMount)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Service 

type Service struct {
	// Type is the Kubernetes service type.
	Type corev1.ServiceType `json:"type"`
}

Service specifies the Kubernetes service related configuration.

func (*Service) DeepCopy 

func (in *Service) DeepCopy() *Service

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Service.

func (*Service) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServiceContainerSpec 

type ServiceContainerSpec struct {
	// SecurityContext defines the security context for the backup service container.
	SecurityContext *corev1.SecurityContext `json:"securityContext,omitempty"`

	// Resources defines the requests and limits for the backup service container.
	// Resources.Limits should be more than Resources.Requests.
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`
}

func (*ServiceContainerSpec) DeepCopy 

func (in *ServiceContainerSpec) DeepCopy() *ServiceContainerSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceContainerSpec.

func (*ServiceContainerSpec) DeepCopyInto 

func (in *ServiceContainerSpec) DeepCopyInto(out *ServiceContainerSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ServicePodSpec 

type ServicePodSpec struct {
	// ServiceContainerSpec configures the backup service container
	// created by the operator.
	// +optional
	ServiceContainerSpec ServiceContainerSpec `json:"serviceContainer,omitempty"`

	// MetaData to add to the pod.
	// +optional
	ObjectMeta AerospikeObjectMeta `json:"metadata,omitempty"`

	// SchedulingPolicy controls pods placement on Kubernetes nodes.
	SchedulingPolicy `json:",inline"`

	// ServiceAccountName is the name of the ServiceAccount to use to run the backup service pod.
	// Defaults to "aerospike-backup-service" if not provided.
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty"`

	// ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of
	// the images used by this PodSpec.
	// +optional
	ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
}

func (*ServicePodSpec) DeepCopy 

func (in *ServicePodSpec) DeepCopy() *ServicePodSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServicePodSpec.

func (*ServicePodSpec) DeepCopyInto 

func (in *ServicePodSpec) DeepCopyInto(out *ServicePodSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.