Versions in this module Expand all Collapse all v1 v1.3.9 Jul 17, 2020 Changes in this version + const CephVersionLabelKey + const ConfigInitContainerName + const OperatorSettingConfigMapName + var ClusterResource = k8sutil.CustomResource + var ImmediateRetryResult = reconcile.Result + var OperatorCephBaseImageVersion string + var WaitForRequeueIfCephClusterNotReady = reconcile.Result + var WaitForRequeueIfFinalizerBlocked = reconcile.Result + func AddCephVersionLabelToDaemonSet(cephVersion version.CephVersion, d *apps.DaemonSet) + func AddCephVersionLabelToDeployment(cephVersion version.CephVersion, d *apps.Deployment) + func AddCephVersionLabelToJob(cephVersion version.CephVersion, j *batch.Job) + func AddCephVersionLabelToObjectMeta(cephVersion version.CephVersion, meta *metav1.ObjectMeta) + func AddFinalizerIfNotPresent(client client.Client, obj runtime.Object) error + func AddVolumeMountSubPath(podSpec *v1.PodSpec, volumeMountName string) + func AdminFlags(cluster *cephconfig.ClusterInfo) []string + func AppLabels(appName, namespace string) map[string]string + func CephVolumeMounts(dataPaths *config.DataPathMap, confGeneratedInPod bool) []v1.VolumeMount + func CheckPodMemory(resources v1.ResourceRequirements, cephPodMinimumMemory uint64) error + func ChownCephDataDirsInitContainer(dpm config.DataPathMap, containerImage string, volumeMounts []v1.VolumeMount, ...) v1.Container + func ClusterOwnerRef(clusterName, clusterID string) metav1.OwnerReference + func ContainerEnvVarReference(envVarName string) string + func CreateOrUpdateObject(client client.Client, obj runtime.Object) error + func DaemonEnvVars(image string) []v1.EnvVar + func DaemonFlags(cluster *cephconfig.ClusterInfo, daemonID string) []string + func DaemonVolumeMounts(dataPaths *config.DataPathMap, keyringResourceName string) []v1.VolumeMount + func DaemonVolumes(dataPaths *config.DataPathMap, keyringResourceName string) []v1.Volume + func DaemonVolumesBase(dataPaths *config.DataPathMap, keyringResourceName string) []v1.Volume + func DaemonVolumesContainsPVC(volumes []v1.Volume) bool + func DaemonVolumesDataHostPath(dataPaths *config.DataPathMap) []v1.Volume + func DaemonVolumesDataPVC(pvcName string) v1.Volume + func ExtractCephVersionFromLabel(labelVersion string) (*version.CephVersion, error) + func GenerateLivenessProbeExecDaemon(daemonType, daemonID string) *v1.Probe + func GenerateMinimalCephConfInitContainer(username, keyringPath string, containerImage string, ...) v1.Container + func GetCephVersionLabel(cephVersion version.CephVersion) string + func GetControllerObjectOwnerReference(object metav1.Object, scheme *runtime.Scheme) (*metav1.OwnerReference, error) + func GetImageVersion(cephCluster cephv1.CephCluster) (*cephver.CephVersion, error) + func IsReadyToReconcile(c client.Client, clustercontext *clusterd.Context, ...) (cephv1.CephCluster, bool, bool, reconcile.Result) + func ObjectToCRMapper(c client.Client, ro runtime.Object, scheme *runtime.Scheme) (handler.Mapper, error) + func PodLabels(appName, namespace, daemonType, daemonID string) map[string]string + func PodVolumes(dataPaths *config.DataPathMap, dataDirHostPath string, confGeneratedInPod bool) []v1.Volume + func RemoveFinalizer(client client.Client, obj runtime.Object) error + func RookVolumeMounts(dataPaths *config.DataPathMap, confGeneratedInPod bool) []v1.VolumeMount + func StoredLogAndCrashVolume(hostLogDir, hostCrashDir string) []v1.Volume + func StoredLogAndCrashVolumeMount(varLogCephDir, varLibCephCrashDir string) []v1.VolumeMount + func UpdateStatus(client client.Client, obj runtime.Object) error + func ValidateCephVersionsBetweenLocalAndExternalClusters(context *clusterd.Context, namespace string, localVersion cephver.CephVersion) (cephver.CephVersion, error) + func WatchControllerPredicate() predicate.Funcs + func WatchPredicateForNonCRDObject(owner runtime.Object, scheme *runtime.Scheme) predicate.Funcs + type OwnerMatcher struct + func NewOwnerReferenceMatcher(owner runtime.Object, scheme *runtime.Scheme) *OwnerMatcher + func (e *OwnerMatcher) Match(object runtime.Object) (bool, metav1.Object, error)
Go to main page