v1

Documentation

Index

• func GetNonPVsVolumesFromStorage(storage *asdbv1.AerospikeStorageSpec) (nonPVs []asdbv1.VolumeSpec)
• func GetPVsVolumesFromStorage(storage *asdbv1.AerospikeStorageSpec) (pVs []asdbv1.VolumeSpec)
• func GetVolumeForAerospikePath(storage *asdbv1.AerospikeStorageSpec, path string) *asdbv1.VolumeSpec
• func SetupAerospikeClusterWebhookWithManager(mgr ctrl.Manager) error
• func ValidateAerospikeObjectMeta(aerospikeObjectMeta *asdbv1.AerospikeObjectMeta) error
• func ValidateTLSAuthenticateClient(serviceConf map[string]interface{}) ([]string, error)
• type AerospikeClusterCustomDefaulter
  • func (acd *AerospikeClusterCustomDefaulter) Default(_ context.Context, obj runtime.Object) error
• type AerospikeClusterCustomValidator
  • func (acv *AerospikeClusterCustomValidator) ValidateCreate(_ context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (acv *AerospikeClusterCustomValidator) ValidateDelete(_ context.Context, obj runtime.Object) (admission.Warnings, error)
  • func (acv *AerospikeClusterCustomValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error)

Functions

func GetNonPVsVolumesFromStorage

func GetNonPVsVolumesFromStorage(storage *asdbv1.AerospikeStorageSpec) (nonPVs []asdbv1.VolumeSpec)

GetNonPVsVolumesFromStorage returns the non PV volumes from the storage spec.

func GetPVsVolumesFromStorage

func GetPVsVolumesFromStorage(storage *asdbv1.AerospikeStorageSpec) (pVs []asdbv1.VolumeSpec)

GetPVsVolumesFromStorage returns the PV volumes from the storage spec.

func GetVolumeForAerospikePath

func GetVolumeForAerospikePath(storage *asdbv1.AerospikeStorageSpec, path string) *asdbv1.VolumeSpec

GetVolumeForAerospikePath returns volume defined for given path for Aerospike server container.

func SetupAerospikeClusterWebhookWithManager

func SetupAerospikeClusterWebhookWithManager(mgr ctrl.Manager) error

SetupAerospikeClusterWebhookWithManager registers the webhook for AerospikeCluster in the manager.

func ValidateAerospikeObjectMeta

func ValidateAerospikeObjectMeta(aerospikeObjectMeta *asdbv1.AerospikeObjectMeta) error

func ValidateTLSAuthenticateClient

func ValidateTLSAuthenticateClient(serviceConf map[string]interface{}) (
	[]string, error,
)

ValidateTLSAuthenticateClient validate the tls-authenticate-client field in the service configuration.

Types

type AerospikeClusterCustomDefaulter

type AerospikeClusterCustomDefaulter 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 (*AerospikeClusterCustomDefaulter) Default

func (acd *AerospikeClusterCustomDefaulter) Default(_ context.Context, obj runtime.Object) error

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

type AerospikeClusterCustomValidator

type AerospikeClusterCustomValidator struct {
}

+kubebuilder:object:generate=false

func (*AerospikeClusterCustomValidator) ValidateCreate

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

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

func (*AerospikeClusterCustomValidator) ValidateDelete

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

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

func (*AerospikeClusterCustomValidator) ValidateUpdate

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

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