internal

package

Go to main page

Versions in this module

v2

v2.14.0

Sep 19, 2025

Changes in this version

+ func IsBackupNotfound(err error) bool

v2.11.0

Aug 8, 2025

v2.10.0

Jul 25, 2025

v2.9.0

Jul 11, 2025

v2.8.0

Jun 27, 2025

v2.7.0

Jun 13, 2025

v2.6.0

May 28, 2025

v2.5.0

May 16, 2025

v2.4.0

May 2, 2025

v2.3.0

Apr 4, 2025

Changes in this version

+ func MergeAnnotations(target *metav1.ObjectMeta, desired metav1.ObjectMeta) bool

+ func MergeLabels(target *metav1.ObjectMeta, desired metav1.ObjectMeta) bool

+ func MetadataCorrect(desiredMetadata metav1.ObjectMeta, currentMetadata *metav1.ObjectMeta) bool

+ func MetadataMatches(currentMetadata metav1.ObjectMeta, desiredMetadata metav1.ObjectMeta) bool

+ func PodMetadataCorrect(cluster *fdbv1beta2.FoundationDBCluster, ...) (bool, error)

v2.2.0

Mar 21, 2025

Changes in this version

+ func GetIPFamily(pod *corev1.Pod) (*int, error)

v2.1.0

Mar 7, 2025

v2.0.0

Feb 24, 2025

Changes in this version

+ const MockUnreachableAnnotation

+ func BuildOwnerReference(ownerType metav1.TypeMeta, ownerMetadata metav1.ObjectMeta) []metav1.OwnerReference

+ func ContainsPod(cluster *fdbv1beta2.FoundationDBCluster, pod corev1.Pod) bool

+ func CreateDefaultBackup(cluster *fdbv1beta2.FoundationDBCluster) *fdbv1beta2.FoundationDBBackup

+ func CreateDefaultCluster() *fdbv1beta2.FoundationDBCluster

+ func CreatePVCMap(cluster *fdbv1beta2.FoundationDBCluster, ...) map[fdbv1beta2.ProcessGroupID]corev1.PersistentVolumeClaim

+ func GenerateRandomString(n int) string

+ func GetBackupDeployment(backup *fdbv1beta2.FoundationDBBackup) (*appsv1.Deployment, error)

+ func GetBackupDeploymentName(backup *fdbv1beta2.FoundationDBBackup) string

+ func GetConfigMap(cluster *fdbv1beta2.FoundationDBCluster) (*corev1.ConfigMap, error)

+ func GetConfigMapMonitorConfEntry(pClass fdbv1beta2.ProcessClass, imageType fdbv1beta2.ImageType, ...) string

+ func GetDynamicConfHash(configMap *corev1.ConfigMap, pClass fdbv1beta2.ProcessClass, ...) (string, error)

+ func GetEnvVars(container v1.Container) map[string]*v1.EnvVar

+ func GetHeadlessService(cluster *fdbv1beta2.FoundationDBCluster) *corev1.Service

+ func GetImage(image string, configs []fdbv1beta2.ImageConfig, versionString string, ...) (string, error)

+ func GetImageType(pod *corev1.Pod) fdbv1beta2.ImageType

+ func GetImageTypeFromAnnotation(annotations map[string]string) fdbv1beta2.ImageType

+ func GetJSONHash(object interface{}) (string, error)

+ func GetMonitorConf(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) (string, error)

+ func GetMonitorProcessConfiguration(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) monitorapi.ProcessConfiguration

+ func GetObjectMetadata(cluster *fdbv1beta2.FoundationDBCluster, base *metav1.ObjectMeta, ...) metav1.ObjectMeta

+ func GetPod(cluster *fdbv1beta2.FoundationDBCluster, ...) (*corev1.Pod, error)

+ func GetPodDNSName(cluster *fdbv1beta2.FoundationDBCluster, podName string) string

+ func GetPodLabels(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) map[string]string

+ func GetPodListOptions(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) []client.ListOption

+ func GetPodMatchLabels(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) map[string]string

+ func GetPodMetadata(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) metav1.ObjectMeta

+ func GetPodSpec(cluster *fdbv1beta2.FoundationDBCluster, ...) (*corev1.PodSpec, error)

+ func GetPodSpecHash(cluster *fdbv1beta2.FoundationDBCluster, ...) (string, error)

+ func GetProcessClassFromMeta(cluster *fdbv1beta2.FoundationDBCluster, metadata v1.ObjectMeta) fdbv1beta2.ProcessClass

+ func GetProcessGroup(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) *fdbv1beta2.ProcessGroupStatus

+ func GetProcessGroupIDFromMeta(cluster *fdbv1beta2.FoundationDBCluster, metadata metav1.ObjectMeta) fdbv1beta2.ProcessGroupID

+ func GetProcessGroupIDFromPodName(cluster *fdbv1beta2.FoundationDBCluster, podName string) fdbv1beta2.ProcessGroupID

+ func GetPublicIPSource(pod *corev1.Pod) (fdbv1beta2.PublicIPSource, error)

+ func GetPublicIPsForPod(pod *corev1.Pod, log logr.Logger) []string

+ func GetPvc(cluster *fdbv1beta2.FoundationDBCluster, ...) (*corev1.PersistentVolumeClaim, error)

+ func GetPvcMetadata(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) metav1.ObjectMeta

+ func GetServersPerPodForPod(pod *corev1.Pod, pClass fdbv1beta2.ProcessClass) (int, error)

+ func GetService(cluster *fdbv1beta2.FoundationDBCluster, ...) (*corev1.Service, error)

+ func GetSidecarImage(cluster *fdbv1beta2.FoundationDBCluster, pClass fdbv1beta2.ProcessClass) (string, error)

+ func GetSinglePodListOptions(cluster *fdbv1beta2.FoundationDBCluster, ...) []client.ListOption

+ func GetStartCommand(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) (string, error)

+ func GetStartCommandWithSubstitutions(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) (string, error)

+ func GetSubstitutionsFromClusterAndPod(logger logr.Logger, cluster *fdbv1beta2.FoundationDBCluster, pod *corev1.Pod) (map[string]string, error)

+ func IsNetworkError(err error) bool

+ func IsQuotaExceeded(err error) bool

+ func IsResourceNotDeleted(err error) bool

+ func IsTimeoutError(err error) bool

+ func NewFdbPodClient(cluster *fdbv1beta2.FoundationDBCluster, pod *corev1.Pod, log logr.Logger, ...) (podclient.FdbPodClient, error)

+ func NormalizeClusterSpec(cluster *fdbv1beta2.FoundationDBCluster, options DeprecationOptions) error

+ func PickProcessGroups(cluster *fdbv1beta2.FoundationDBCluster, processClass fdbv1beta2.ProcessClass, ...) []*fdbv1beta2.ProcessGroupStatus

+ func PodHasSidecarTLS(pod *corev1.Pod) bool

+ func ProcessClassFromLabels(cluster *fdbv1beta2.FoundationDBCluster, labels map[string]string) fdbv1beta2.ProcessClass

+ func SetupClusterForTest(cluster *fdbv1beta2.FoundationDBCluster, k8sClient ctrlClient.Client) error

+ type CliLogFileCleaner struct

+ func NewCliLogFileCleaner(log logr.Logger, minFileAge time.Duration) *CliLogFileCleaner

+ func (c CliLogFileCleaner) CleanupOldCliLogs()

+ type DeprecationOptions struct

+ OnlyShowChanges bool

+ UseFutureDefaults bool

+ type NodeTaintChangedPredicate struct

+ Logger logr.Logger

+ func (n NodeTaintChangedPredicate) Create(_ event.CreateEvent) bool

+ func (n NodeTaintChangedPredicate) Delete(_ event.DeleteEvent) bool

+ func (n NodeTaintChangedPredicate) Generic(_ event.GenericEvent) bool

+ func (n NodeTaintChangedPredicate) Update(event event.UpdateEvent) bool

+ type ResourceNotDeleted struct

+ Resource client.Object

+ func (err ResourceNotDeleted) Error() string

Other modules containing this package

github.com/FoundationDB/fdb-kubernetes-operator

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL