cluster

Documentation

Index

• func Copy(dst, src interface{}) error
• func CreateDummyAerospikeCluster(clusterNamespacedName types.NamespacedName, size int32) *asdbv1.AerospikeCluster
• func DeleteCluster(k8sClient client.Client, ctx goctx.Context, ...) error
• func DeployCluster(k8sClient client.Client, ctx goctx.Context, ...) error
• func UpdateClusterImage(aerocluster *asdbv1.AerospikeCluster, image string) error
• func ValidateAttributes(actual []map[string]string, expected map[string]string) bool
• type AerospikeConfSpec
  • func NewAerospikeConfSpec(image string) (*AerospikeConfSpec, error)
• type CloudProvider
• type FromSecretPasswordProvider
  • func (pp FromSecretPasswordProvider) Get(_ string, userSpec *asdbv1.AerospikeUserSpec) (string, error)
  • func (pp FromSecretPasswordProvider) GetDefaultPassword(_ *asdbv1.AerospikeClusterSpec) string
• type RackState

Functions

func Copy

func Copy(dst, src interface{}) error

Copy makes a deep copy from src into dst.

func CreateDummyAerospikeCluster

func CreateDummyAerospikeCluster(
	clusterNamespacedName types.NamespacedName, size int32,
) *asdbv1.AerospikeCluster

CreateDummyAerospikeCluster func is a public variant of createDummyAerospikeCluster Remove this when createDummyAerospikeCluster will be made public

func DeleteCluster

func DeleteCluster(
	k8sClient client.Client, ctx goctx.Context,
	aeroCluster *asdbv1.AerospikeCluster,
) error

DeleteCluster is the public variant of deleteCluster Remove this when deleteCluster will be made public

func DeployCluster

func DeployCluster(
	k8sClient client.Client, ctx goctx.Context,
	aeroCluster *asdbv1.AerospikeCluster,
) error

DeployCluster is the public variant of deployCluster Remove this when deployCluster will be made public

func UpdateClusterImage

func UpdateClusterImage(
	aerocluster *asdbv1.AerospikeCluster, image string,
) error

func ValidateAttributes

func ValidateAttributes(
	actual []map[string]string, expected map[string]string,
) bool

Types

type AerospikeConfSpec

type AerospikeConfSpec struct {
	// contains filtered or unexported fields
}

func NewAerospikeConfSpec

func NewAerospikeConfSpec(image string) (*AerospikeConfSpec, error)

type CloudProvider

type CloudProvider int

const (
	CloudProviderUnknown CloudProvider = iota
	CloudProviderAWS
	CloudProviderGCP
)

type FromSecretPasswordProvider

type FromSecretPasswordProvider struct {
	// contains filtered or unexported fields
}

FromSecretPasswordProvider provides user password from the secret provided in AerospikeUserSpec. TODO duplicated from controller_helper

func (FromSecretPasswordProvider) Get

func (pp FromSecretPasswordProvider) Get(
	_ string, userSpec *asdbv1.AerospikeUserSpec,
) (string, error)

Get returns the password for the username using userSpec.

func (FromSecretPasswordProvider) GetDefaultPassword

func (pp FromSecretPasswordProvider) GetDefaultPassword(_ *asdbv1.AerospikeClusterSpec) string

This function is not used in the test code. This is just a dummy implementation. Tests do not make client call till cluster is up and reconciled. DefaultPassword only comes into play when the cluster is being created.

type RackState

type RackState struct {
	Rack asdbv1.Rack
	Size int
}