reconciler

Documentation

Index

• Constants
• func GetBackupName(ns, sourceVersion, targetVersion string) string
• type AerospikeClusterReconciler
  • func New(kubeclientset kubernetes.Interface, ...) *AerospikeClusterReconciler
  • func (r *AerospikeClusterReconciler) MaybeReconcile(aerospikeCluster *aerospikev1alpha2.AerospikeCluster) error

Constants

const (
	ServicePort = 3000

	HeartbeatPort = 3002

	// the name of the annotation that holds the name of the pod with which a
	// PVC is associated
	PodAnnotation = "aerospike.travelaudience.com/pod-name"
	// the name of the annotation that holds the persistentVolumeClaimTTL of a
	// PVC
	PVCTTLAnnotation = "aerospike.travelaudience.com/pvc-ttl"
	// the name of the annotation that holds the timestamp at which a PVC
	// was last unmounted from a pod
	LastUnmountedOnAnnotation = "aerospike.travelaudience.com/last-unmounted-on"

	// the value of the key that corresponds to the service.node-id property
	// (used for templating)
	ServiceNodeIdValue = "__SERVICE__NODE_ID__"

	HeartbeatAddressesValue = "__NETWORK__HEARTBEAT__MESH_SEED_ADDRESS_PORT__"

	// UpgradeStatusAnnotationKey is the name of the annotation added to
	// AerospikeCluster resources that are being upgraded.
	UpgradeStatusAnnotationKey = "aerospike.travelaudience.com/upgrade-status"
	// UpgradeStatusStartedAnnotationValue is the value of the annotation added
	// to AerospikeCluster resources that are being upgrade.
	UpgradeStatusStartedAnnotationValue = "started"
	// UpgradeStatusFailedAnnotationValue is the value of the annotation added
	// to AerospikeCluster resources that have not been successfully upgraded.
	UpgradeStatusFailedAnnotationValue = "failed"
	// UpgradeStatusBackupAnnotationValue is the value of the annotation added
	// to AerospikeCluster resources that are undergoing a pre-upgrade backup.
	UpgradeStatusBackupAnnotationValue = "backup"

	// terminal state reasons when pod status is Pending
	// container image pull failed
	ReasonImagePullBackOff = "ImagePullBackOff"
	// unable to inspect image
	ReasonImageInspectError = "ImageInspectError"
	// general image pull error
	ReasonErrImagePull = "ErrImagePull"
	// get http error when pulling image from registry
	ReasonRegistryUnavailable = "RegistryUnavailable"
)

Functions

func GetBackupName

func GetBackupName(ns, sourceVersion, targetVersion string) string

GetBackupName returns the name of a backup created automatically before upgrading

Types

type AerospikeClusterReconciler

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

func New

func New(kubeclientset kubernetes.Interface,
	aerospikeclientset aerospikeclientset.Interface,
	podsLister listersv1.PodLister,
	configMapsLister listersv1.ConfigMapLister,
	servicesLister listersv1.ServiceLister,
	pvcsLister listersv1.PersistentVolumeClaimLister,
	scsLister storagelistersv1.StorageClassLister,
	aerospikeBackupsLister aerospikelisters.AerospikeNamespaceBackupLister,
	recorder record.EventRecorder) *AerospikeClusterReconciler

func (*AerospikeClusterReconciler) MaybeReconcile

func (r *AerospikeClusterReconciler) MaybeReconcile(aerospikeCluster *aerospikev1alpha2.AerospikeCluster) error

MaybeReconcile checks if reconciliation is needed.