common

Documentation

Index

• Variables
• func GetBackupServicePodList(k8sClient client.Client, name, namespace string) (*corev1.PodList, error)
• func GetConfigSection(config map[string]interface{}, section string) (map[string]interface{}, error)
• func ReloadBackupServiceConfigInPods(k8sClient client.Client, log logr.Logger, backupSvc *v1beta1.BackupService) error
• type ReconcileResult
  • func ReconcileError(e error) ReconcileResult
  • func ReconcileRequeueAfter(secs int) ReconcileResult
  • func ReconcileSuccess() ReconcileResult
  • func (r ReconcileResult) GetResult() (reconcile.Result, error)

Variables

var (
	UpdateOption = &client.UpdateOptions{
		FieldManager: "aerospike-operator",
	}
	CreateOption = &client.CreateOptions{
		FieldManager: "aerospike-operator",
	}
)

var MaxConcurrentReconciles = runtime.NumCPU() * 2

MaxConcurrentReconciles is the Number of Reconcile threads to run Reconcile operations

Functions

func GetBackupServicePodList

func GetBackupServicePodList(k8sClient client.Client, name, namespace string) (*corev1.PodList, error)

func GetConfigSection

func GetConfigSection(config map[string]interface{}, section string) (map[string]interface{}, error)

GetConfigSection returns the section of the config with the given name.

func ReloadBackupServiceConfigInPods

func ReloadBackupServiceConfigInPods(
	k8sClient client.Client,
	log logr.Logger,
	backupSvc *v1beta1.BackupService,
) error

Types

type ReconcileResult

type ReconcileResult struct {
	Err       error
	Result    reconcile.Result
	IsSuccess bool
}

func ReconcileError

func ReconcileError(e error) ReconcileResult

func ReconcileRequeueAfter

func ReconcileRequeueAfter(secs int) ReconcileResult

func ReconcileSuccess

func ReconcileSuccess() ReconcileResult

func (ReconcileResult) GetResult

func (r ReconcileResult) GetResult() (reconcile.Result, error)