util

package

Go to main page

Versions in this module

v0

v0.8.1

Apr 8, 2024

Changes in this version

+ func GetManagedSolrNodeNames(solrCloud *solr.SolrCloud, currentlyConfiguredPodCount int) map[string]bool

v0.8.0

Oct 16, 2023

Changes in this version

+ const ClusterOpsLockAnnotation

+ const ClusterOpsRetryQueueAnnotation

+ const DefaultLivenessProbePath

+ const DefaultReadinessProbePath

+ const DefaultStartupProbePath

+ const InitdbInitContainer

+ const SysPropLibPlaceholder

+ func BalanceReplicasForCluster(ctx context.Context, solrCloud *solr.SolrCloud, ...) (balanceComplete bool, requestInProgress bool, retryLaterDuration time.Duration, ...)

+ func MaintainPreservedStatefulSetFields(expected, found *appsv1.StatefulSet)

+ type NodeReplicaState struct

+ AllManagedPodsLive bool

+ NodeContents map[string]*SolrNodeContents

+ ShardReplicasNotActive map[string]int

+ TotalShardReplicas map[string]int

+ func GetNodeReplicaState(ctx context.Context, cloud *solr.SolrCloud, hasReadyPod bool, ...) (state NodeReplicaState, retryLater bool, err error)

+ func (state NodeReplicaState) PodContents(cloud *solr.SolrCloud, podName string) (contents *SolrNodeContents, isInClusterState bool)

+ func (state NodeReplicaState) PodHasReplicas(cloud *solr.SolrCloud, podName string) bool

type OutOfDatePodSegmentation

+ func (seg OutOfDatePodSegmentation) IsEmpty() bool

v0.7.1

Jul 17, 2023

v0.7.0

Apr 19, 2023

Changes in this version

+ const SolrIsNotStoppedReadinessCondition

+ const SolrPrometheusExporterContainer

+ const SolrReplicasNotEvictedReadinessCondition

+ func CopyPodDisruptionBudgetFields(from, to *policyv1.PodDisruptionBudget, logger logr.Logger) bool

+ func GeneratePodDisruptionBudget(cloud *solr.SolrCloud, selector map[string]string) *policyv1.PodDisruptionBudget

+ func ListAllSolrCollections(ctx context.Context, cloud *solr.SolrCloud, logger logr.Logger) (collections []string, err error)

+ type OutOfDatePodSegmentation struct

+ NotStarted []corev1.Pod

+ Running []corev1.Pod

+ ScheduledForDeletion []corev1.Pod

v0.6.0

Aug 7, 2022

Changes in this version

+ const SolrDataVolumeName

+ var DefaultSolrVolumePrepInitContainerCPU = resource.NewMilliQuantity(50, resource.DecimalExponent)

+ var DefaultSolrVolumePrepInitContainerMemory = resource.NewScaledQuantity(50, 6)

+ var DefaultSolrZKPrepInitContainerCPU = resource.NewMilliQuantity(400, resource.DecimalExponent)

+ var DefaultSolrZKPrepInitContainerMemory = resource.NewScaledQuantity(200, 6)

+ func EvictReplicasForPodIfNecessary(ctx context.Context, solrCloud *solr.SolrCloud, pod *corev1.Pod, ...) (err error, canDeletePod bool)

v0.5.1

Mar 15, 2022

Changes in this version

+ func CopyContainerResourceList(fromPtr, toPtr *corev1.ResourceList, basePath string, logger logr.Logger) (requireUpdate bool)

+ func CopyResources(from, to *corev1.ResourceRequirements, basePath string, logger logr.Logger) (requireUpdate bool)

v0.5.0

Nov 11, 2021

Changes in this version

+ const ContribLibs

+ const DefaultSolrXML

+ const DistLibs

+ const GCSCredentialSecretKey

+ const S3CredentialFileName

+ const SolrBackupRepositoriesAnnotation

+ var PublicReadOnlyPermissions int32 = 444

+ var SecretReadOnlyPermissions int32 = 440

+ func AddAuthToContext(ctx context.Context, client *client.Client, solrCloud *solr.SolrCloud) (context.Context, error)

+ func AdditionalRepoLibs(repo *solrv1beta1.SolrBackupRepository) (libs []string)

+ func BackupLocationPath(repo *solrv1beta1.SolrBackupRepository, backupLocation string) string

+ func BasicAuthEnvVars(secretName string) []corev1.EnvVar

+ func CopyPodVolumes(fromPtr, toPtr *[]corev1.Volume, basePath string, logger logr.Logger) (requireUpdate bool)

+ func FullCollectionBackupName(collection string, backupName string) string

+ func GcsRepoSecretMountPath(repo *solrv1beta1.SolrBackupRepository) string

+ func GenerateAdditionalLibXMLPart(solrModules []string, additionalLibs []string) string

+ func GenerateBackupRepositoriesForSolrXml(backupRepos []solrv1beta1.SolrBackupRepository) (repoXML string, solrModules []string, additionalLibs []string)

+ func GenerateQueryParamsForBackup(backupRepository *solr.SolrBackupRepository, backup *solr.SolrBackup, ...) url.Values

+ func GenerateSolrXMLString(backupSection string, solrModules []string, additionalLibs []string) string

+ func GenerateSolrXMLStringForCloud(solrCloud *solr.SolrCloud) string

+ func GetAllManagedSolrNodeNames(solrCloud *solr.SolrCloud) map[string]bool

+ func GetAvailableBackupRepos(pod *corev1.Pod) (repos map[string]bool)

+ func GetBackupRepositoryByName(backupRepos []solr.SolrBackupRepository, repositoryName string) *solr.SolrBackupRepository

+ func IsRepoVolume(repo *solrv1beta1.SolrBackupRepository) bool

+ func Replicas(num int) *int32

+ func RepoEnvVars(repo *solrv1beta1.SolrBackupRepository) (envVars []corev1.EnvVar)

+ func RepoSolrModules(repo *solrv1beta1.SolrBackupRepository) (libs []string)

+ func RepoVolumeName(repo *solrv1beta1.SolrBackupRepository) string

+ func RepoVolumeSourceAndMount(repo *solrv1beta1.SolrBackupRepository, solrCloudName string) (source *corev1.VolumeSource, mount *corev1.VolumeMount)

+ func RepoXML(repo *solrv1beta1.SolrBackupRepository) (xml string)

+ func S3RepoSecretMountPath(repo *solrv1beta1.SolrBackupRepository) string

+ func ScheduleNextBackup(restartSchedule string, lastBackupTime time.Time) (nextBackup time.Time, err error)

+ func SetAvailableBackupRepos(solrCloud *solrv1beta1.SolrCloud, podAnnotations map[string]string) map[string]string

+ func UpdateStatusOfCollectionBackups(backupStatus *solr.IndividualSolrBackupStatus) (allFinished bool)

+ func VolumeRepoVolumeMountPath(repo *solrv1beta1.SolrBackupRepository) string

+ type SecurityConfig struct

+ CredentialsSecret *corev1.Secret

+ SecurityJson string

+ SecurityJsonSrc *corev1.EnvVarSource

+ SolrSecurity *solr.SolrSecurityOptions

+ func ReconcileSecurityConfig(ctx context.Context, client *client.Client, instance *solr.SolrCloud) (*SecurityConfig, error)

+ func (security *SecurityConfig) AddAuthToContext(ctx context.Context) (context.Context, error)

v0.4.0

Sep 7, 2021

Changes in this version

+ const DefaultClientKeyStorePath

+ const DefaultClientTrustStorePath

+ const DefaultKeystorePasswordFile

+ const DefaultPkcs12KeystoreFile

+ const DefaultPkcs12TruststoreFile

+ const InitdbPath

+ const SolrClientTlsCertMd5Annotation

+ const SolrScheduledRestartAnnotation

+ func ScheduleNextRestart(restartSchedule string, podTemplateAnnotations map[string]string) (nextRestart string, reconcileWaitDuration *time.Duration, err error)

+ type TLSCerts struct

+ ClientConfig *TLSConfig

+ InitContainerImage *solr.ContainerImage

+ ServerConfig *TLSConfig

+ func TLSCertsForExporter(prometheusExporter *solr.SolrPrometheusExporter) *TLSCerts

+ func TLSCertsForSolrCloud(instance *solr.SolrCloud) *TLSCerts

+ type TLSConfig struct

+ CertMd5 string

+ CertMd5Annotation string

+ KeystorePath string

+ Namespace string

+ NeedsPkcs12InitContainer bool

+ Options *solr.SolrTLSOptions

+ TruststorePath string

+ VolumePrefix string

+ func (tls *TLSConfig) VerifyKeystoreAndTruststoreSecretConfig(client *client.Client) (*corev1.Secret, error)

+ func (tls *TLSConfig) VerifyTruststoreOnly(client *client.Client) error

v0.3.0

Apr 23, 2021

Changes in this version

+ const AWSSecretDir

+ const BackupRestoreVolume

+ const BackupTarCommand

+ const BaseBackupRestorePath

+ const BasicAuthMd5Annotation

+ const CleanupCommand

+ const DefaultKeyStorePath

+ const DefaultLivenessProbeFailureThreshold

+ const DefaultLivenessProbeInitialDelaySeconds

+ const DefaultLivenessProbePeriodSeconds

+ const DefaultLivenessProbeSuccessThreshold

+ const DefaultLivenessProbeTimeoutSeconds

+ const DefaultMaxPodsUnavailable

+ const DefaultMaxShardReplicasUnavailable

+ const DefaultProbePath

+ const DefaultPrometheusExporterEntrypoint

+ const DefaultReadinessProbeFailureThreshold

+ const DefaultReadinessProbeInitialDelaySeconds

+ const DefaultReadinessProbePeriodSeconds

+ const DefaultReadinessProbeSuccessThreshold

+ const DefaultReadinessProbeTimeoutSeconds

+ const DefaultSolrGroup

+ const DefaultSolrUser

+ const DefaultStartupProbeFailureThreshold

+ const DefaultStartupProbeInitialDelaySeconds

+ const DefaultStartupProbePeriodSeconds

+ const DefaultStartupProbeSuccessThreshold

+ const DefaultStartupProbeTimeoutSeconds

+ const DefaultStatefulSetPodManagementPolicy

+ const DefaultTrustStorePath

+ const DefaultWritableKeyStorePath

+ const ExtSolrMetricsPort

+ const JobTTLSeconds

+ const LogXmlFile

+ const LogXmlMd5Annotation

+ const Pkcs12KeystoreFile

+ const PrometheusExporterConfigMapKey

+ const PrometheusExporterConfigXmlMd5Annotation

+ const SecurityJsonFile

+ const SolrClientPortName

+ const SolrCloudPVCDataStorage

+ const SolrCloudPVCTechnology

+ const SolrMetricsPort

+ const SolrMetricsPortName

+ const SolrNodeContainer

+ const SolrPVCInstanceLabel

+ const SolrPVCStorageLabel

+ const SolrPVCTechnologyLabel

+ const SolrStorageFinalizer

+ const SolrTlsCertMd5Annotation

+ const SolrXmlFile

+ const SolrXmlMd5Annotation

+ const SolrZKConnectionStringAnnotation

+ const TLSCertKey

+ const TLSKeyKey

+ const TarredFile

+ func AddACLsToEnv(allACL *solr.ZookeeperACL, readOnlyACL *solr.ZookeeperACL) (hasACLs bool, envVars []corev1.EnvVar)

+ func AsyncIdForCollectionBackup(collection string, backupName string) string

+ func BackupPath(backupName string) string

+ func BackupRestoreSubPathForCloud(directoryOverride string, cloud string) string

+ func BackupSubPathForCloud(directoryOverride string, cloud string, backupName string) string

+ func BasicAuthHeader(basicAuthSecret *corev1.Secret) string

+ func CheckBackupForCollection(cloud *solr.SolrCloud, collection string, backupName string, ...) (finished bool, success bool, asyncStatus string, err error)

+ func CheckStatusOfCollectionBackups(backup *solr.SolrBackup) (allFinished bool)

+ func ContainsString(slice []string, s string) bool

+ func CopyConfigMapFields(from, to *corev1.ConfigMap, logger logr.Logger) bool

+ func CopyDeploymentFields(from, to *appsv1.Deployment, logger logr.Logger) bool

+ func CopyIngressFields(from, to *netv1.Ingress, logger logr.Logger) bool

+ func CopyLabelsAndAnnotations(from, to *metav1.ObjectMeta, logger logr.Logger) (requireUpdate bool)

+ func CopyPodContainers(fromPtr, toPtr *[]corev1.Container, basePath string, logger logr.Logger) (requireUpdate bool)

+ func CopyPodTemplates(from, to *corev1.PodTemplateSpec, basePath string, logger logr.Logger) (requireUpdate bool)

+ func CopyServiceFields(from, to *corev1.Service, logger logr.Logger) bool

+ func CopyStatefulSetFields(from, to *appsv1.StatefulSet, logger logr.Logger) bool

+ func CopyZookeeperClusterFields(from, to *zk.ZookeeperCluster, logger logr.Logger) bool

+ func CreateCommonIngressRule(solrCloud *solr.SolrCloud, domainName string) (ingressRule netv1.IngressRule)

+ func CreateMetricsIngressRule(solrPrometheusExporter *solr.SolrPrometheusExporter, ingressBaseDomain string) netv1.IngressRule

+ func CreateNodeIngressRule(solrCloud *solr.SolrCloud, nodeName string, domainName string) (ingressRule netv1.IngressRule)

+ func CreateSolrIngressRules(solrCloud *solr.SolrCloud, nodeNames []string, domainNames []string) []netv1.IngressRule

+ func DeepEqualWithNils(x, y interface{}) bool

+ func DeleteAsyncInfoForBackup(cloud *solr.SolrCloud, collection string, backupName string, ...) (err error)

+ func DeterminePodsSafeToUpdate(cloud *solr.SolrCloud, outOfDatePods []corev1.Pod, totalPods int, ...) (podsToUpdate []corev1.Pod, retryLater bool)

+ func DuplicateLabelsOrAnnotations(from map[string]string) map[string]string

+ func EnsureDirectoryForBackup(solrCloud *solr.SolrCloud, backup string, config *rest.Config) (err error)

+ func GenerateBackupPersistenceJob(solrBackup *solr.SolrBackup, solrBackupVolume corev1.VolumeSource, ...) *batchv1.Job

+ func GenerateBackupPersistenceJobForCloud(backup *solr.SolrBackup, solrCloud *solr.SolrCloud) *batchv1.Job

+ func GenerateBasicAuthSecretWithBootstrap(solrCloud *solr.SolrCloud) (*corev1.Secret, *corev1.Secret)

+ func GenerateCommonService(solrCloud *solr.SolrCloud) *corev1.Service

+ func GenerateConfigMap(solrCloud *solr.SolrCloud) *corev1.ConfigMap

+ func GenerateHeadlessService(solrCloud *solr.SolrCloud) *corev1.Service

+ func GenerateIngress(solrCloud *solr.SolrCloud, nodeNames []string) (ingress *netv1.Ingress)

+ func GenerateMetricsConfigMap(solrPrometheusExporter *solr.SolrPrometheusExporter) *corev1.ConfigMap

+ func GenerateNodeService(solrCloud *solr.SolrCloud, nodeName string) *corev1.Service

+ func GeneratePersistenceOptions(solrBackup *solr.SolrBackup, solrBackupVolume corev1.VolumeSource) (image solr.ContainerImage, envVars []corev1.EnvVar, command []string, ...)

+ func GenerateSolrMetricsService(solrPrometheusExporter *solr.SolrPrometheusExporter) *corev1.Service

+ func GenerateSolrPrometheusExporterDeployment(solrPrometheusExporter *solr.SolrPrometheusExporter, ...) *appsv1.Deployment

+ func GenerateStatefulSet(solrCloud *solr.SolrCloud, solrCloudStatus *solr.SolrCloudStatus, ...) *appsv1.StatefulSet

+ func GenerateZookeeperCluster(solrCloud *solr.SolrCloud, zkSpec *solr.ZookeeperSpec) *zk.ZookeeperCluster

+ func GetCustomProbePaths(solrCloud *solr.SolrCloud) []string

+ func IsPVCOrphan(pvcName string, replicas int32) bool

+ func MergeLabelsOrAnnotations(base, additional map[string]string) map[string]string

+ func OvertakeControllerRef(owner metav1.Object, controlled metav1.Object, scheme *runtime.Scheme) (needsUpdate bool, err error)

+ func RemoveString(slice []string, s string) (result []string)

+ func ResolveMaxPodsUnavailable(maxPodsUnavailable *intstr.IntOrString, desiredPods int) (int, error)

+ func ResolveMaxShardReplicasUnavailable(maxShardReplicasUnavailable *intstr.IntOrString, shard string, ...) (int, error)

+ func RestorePath(backupName string) string

+ func RestoreSubPathForCloud(directoryOverride string, cloud string, restoreName string) string

+ func RunExecForPod(podName string, namespace string, command []string, config rest.Config) (err error)

+ func SolrNodeName(solrCloud *solr.SolrCloud, pod corev1.Pod) string

+ func StartBackupForCollection(cloud *solr.SolrCloud, collection string, backupName string, ...) (success bool, err error)

+ func TLSEnvVars(opts *solr.SolrTLSOptions, createPkcs12InitContainer bool) []corev1.EnvVar

+ func ValidateBasicAuthSecret(basicAuthSecret *corev1.Secret) error

+ type SolrConnectionInfo struct

+ CloudZkConnnectionInfo *solr.ZookeeperConnectionInfo

+ StandaloneAddress string

+ type SolrNodeContents struct

+ func (nodeContents *SolrNodeContents) InClusterState() bool

+ type TLSClientOptions struct

+ NeedsPkcs12InitContainer bool

+ TLSCertMd5 string

+ TLSOptions *solr.SolrTLSOptions

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