util

package

Go to main page

Versions in this module

v5

v5.15.2

Apr 10, 2024

v5.15.1

Mar 21, 2024

v5.15.0

Mar 12, 2024

Changes in this version

+ var GlobalCARefreshingTransport = &http.Transport

+ func IsDevEnv() bool

v5.14.5

Jan 30, 2024

v5.14.4

Jan 16, 2024

v5.14.2

Dec 12, 2023

v5.14.1

Nov 20, 2023

v5.14.0

Oct 16, 2023

Changes in this version

+ func GetKubeVersion() (*semver.Version, error)

v5.13.5

Dec 6, 2023

v5.13.4

Sep 28, 2023

v5.13.3

Aug 27, 2023

v5.13.2

Aug 21, 2023

v5.13.1

Aug 21, 2023

v5.13.0

Jul 6, 2023

Changes in this version

+ func ContainsAny(arr []T, item T, eq func(T, T) bool) bool

+ func FilterSlice(slice []V, f func(V) bool) []V

+ func GetEndpointByBackingStoreType(bs *nbv1.BackingStore) (string, error)

+ func GetEndpointByNamespaceStoreType(ns *nbv1.NamespaceStore) (string, error)

+ func IgnoreIfNotInNamespace(ns string) *predicate.Funcs

+ func IsTestEnv() bool

+ func MapAlternateKeysValue(stringData map[string]string, key string) string

v5.12.4

Jun 29, 2023

Changes in this version

+ func IsSTSClusterNS(ns *nbv1.NamespaceStore) bool

+ func PrettyPrint(key string, strArray []string)

v5.11.0

Jul 5, 2022

Changes in this version

+ var MapStorTypeToMandatoryProperties = map[string][]string

+ func CheckForIdenticalSecretsCreds(secret *corev1.Secret, storeTypeStr string) *corev1.Secret

+ func GetBackingStoreSecret(bs *nbv1.BackingStore) (*corev1.SecretReference, error)

+ func GetBackingStoreSecretByType(bs *nbv1.BackingStore) (*corev1.SecretReference, error)

+ func GetBackingStoreTargetBucket(bs *nbv1.BackingStore) (string, error)

+ func GetNamespaceStoreSecret(ns *nbv1.NamespaceStore) (*corev1.SecretReference, error)

+ func GetNamespaceStoreSecretByType(ns *nbv1.NamespaceStore) (*corev1.SecretReference, error)

+ func GetNamespaceStoreTargetBucket(ns *nbv1.NamespaceStore) (string, error)

+ func GetSecretFromSecretReference(secretRef *corev1.SecretReference) (*corev1.Secret, error)

+ func IsOwnedByNoobaa(ownerReferences []metav1.OwnerReference) bool

+ func SetBackingStoreSecretRef(bs *nbv1.BackingStore, ref *corev1.SecretReference) error

+ func SetNamespaceStoreSecretRef(ns *nbv1.NamespaceStore, ref *corev1.SecretReference) error

+ func SetOwnerReference(owner, dependent metav1.Object, scheme *runtime.Scheme) error

v5.11.0-12052022

Apr 27, 2022

v5.10.1

May 12, 2022

Changes in this version

+ func GetAvailabeKubeCli() string

+ func GetFlagIntOrPrompt(cmd *cobra.Command, flag string) int

+ func IsAzurePlatformNonGovernment() bool

+ func IsSTSClusterBS(bs *nbv1.BackingStore) bool

+ func IsSTSClusterNB(nb *nbv1.NooBaa) bool

+ func IsStringArrayUnorderedEqual(stringsArrayA, stringsArrayB []string) bool

+ func IsValidationError(err error) bool

+ func NooBaaCondStatus(noobaa *nbv1.NooBaa, s corev1.ConditionStatus) bool

+ func NooBaaCondition(noobaa *nbv1.NooBaa, t conditionsv1.ConditionType, s corev1.ConditionStatus) bool

+ func NoobaaStatus(nb *nbv1.NooBaa, t conditionsv1.ConditionType, status corev1.ConditionStatus) bool

+ func ValidateQuotaConfig(name string, maxSize string, maxObjects string) error

+ type ValidationError struct

+ Msg string

+ func (e ValidationError) Error() string

v5.9.0

Dec 22, 2021

Changes in this version

+ var InsecureHTTPTransport = &http.Transport

+ var SecureHTTPTransport = &http.Transport

+ func AddFinalizer(obj metav1.Object, finalizer string) bool

+ func AddToRootCAs(localCertFile string) error

+ func BuildExternalSecretPath(client *vaultApi.Client, kms nbv1.KeyManagementServiceSpec, uid string) (string, error)

+ func CombineErrors(errs ...error) error

+ func ComposePredicates(predicates ...predicate.Predicate) predicate.Predicate

+ func Contains(s string, arr []string) bool

+ func Context() context.Context

+ func CurrentNamespace() string

+ func DeleteSecret(client *vaultApi.Client, secretPath string) error

+ func DeleteStorageClass(sc *storagev1.StorageClass) error

+ func EnsureCommonMetaFields(object metav1.Object, finalizer string) bool

+ func GetAWSRegion() (string, error)

+ func GetCmDataHash(input map[string]string) string

+ func GetContainerStatusLine(cont *corev1.ContainerStatus) string

+ func GetEnvVariable(env *[]corev1.EnvVar, name string) *corev1.EnvVar

+ func GetFlagStringOrPrompt(cmd *cobra.Command, flag string) string

+ func GetFlagStringOrPromptPassword(cmd *cobra.Command, flag string) string

+ func GetIBMRegion() (string, error)

+ func GetPodLogs(pod corev1.Pod) (map[string]io.ReadCloser, error)

+ func GetPodStatusLine(pod *corev1.Pod) string

+ func GetSecret(client *vaultApi.Client, secretName, secretPath string, backendPath string) (string, error)

+ func GetVaultTLSConfig(config map[string]string, namespace string) (*api.TLSConfig, error)

+ func GetWatchNamespace() (string, error)

+ func HumanizeDuration(duration time.Duration) string

+ func IgnoreError(err error)

+ func InitLogger()

+ func InitVaultClient(config map[string]string, tokenSecretName string, namespace string) (*vaultApi.Client, error)

+ func IsAWSPlatform() bool

+ func IsAzurePlatform() bool

+ func IsGCPPlatform() bool

+ func IsIBMPlatform() bool

+ func IsPersistentError(err error) bool

+ func IsStringGraphicOrSpacesCharsOnly(s string) bool

+ func IsValidS3BucketName(name string) bool

+ func IsVaultKMS(provider string) bool

+ func KubeApply(obj client.Object) bool

+ func KubeCheck(obj client.Object) bool

+ func KubeCheckOptional(obj client.Object) bool

+ func KubeCheckQuiet(obj client.Object) bool

+ func KubeClient() client.Client

+ func KubeConfig() *rest.Config

+ func KubeCreateFailExisting(obj client.Object) bool

+ func KubeCreateOptional(obj client.Object) bool

+ func KubeCreateSkipExisting(obj client.Object) bool

+ func KubeDelete(obj client.Object, opts ...client.DeleteOption) bool

+ func KubeDeleteAllOf(obj client.Object, opts ...client.DeleteAllOfOption) bool

+ func KubeDeleteNoPolling(obj client.Object, opts ...client.DeleteOption) bool

+ func KubeGet(obj client.Object) (name string, kind string, err error)

+ func KubeList(list client.ObjectList, options ...client.ListOption) bool

+ func KubeObject(text string) runtime.Object

+ func KubeUpdate(obj client.Object) bool

+ func LoadBucketReplicationJSON(replicationJSONFilePath string) (string, error)

+ func LogError(err error)

+ func Logger() *logrus.Entry

+ func MapperProvider(config *rest.Config) (meta.RESTMapper, error)

+ func MergeEnvArrays(envA, envB *[]corev1.EnvVar)

+ func MergeVolumeList(existing, template *[]corev1.Volume)

+ func MergeVolumeMountList(existing, template *[]corev1.VolumeMount)

+ func NewFastRESTMapper(dc discovery.DiscoveryInterface, filter APIGroupFilterFunc) meta.RESTMapper

+ func NoGroupFilter(*metav1.APIGroup) bool

+ func ObjectKey(obj client.Object) client.ObjectKey

+ func Panic(err error)

+ func PrintThisNoteWhenFinishedApplyingAndStartWaitLoop()

+ func PutSecret(client *vaultApi.Client, secretName, secretValue, secretPath string, ...) error

+ func RandomBase64(numBytes int) string

+ func RandomHex(numBytes int) string

+ func ReflectEnvVariable(env *[]corev1.EnvVar, name string)

+ func RemoveFinalizer(obj metav1.Object, finalizer string) bool

+ func SaveCRsToFile(crs runtime.Object, path string) error

+ func SaveStreamToFile(body io.ReadCloser, path string) error

+ func SecretResetStringDataFromData(obj runtime.Object)

+ func SetAvailableCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func SetErrorCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func SetProgressingCondition(conditions *[]conditionsv1.Condition, reason string, message string)

+ func Tar(src string, writers ...io.Writer) error

+ func ValidateConnectionDetails(config map[string]string, tokenSecretName string, namespace string) error

+ func ValidateVaultConnectionDetails(config map[string]string, tokenName string, namespace string) error

+ func VerifyCredsInSecret(secretName string, namespace string, mandatoryProperties []string)

+ func VerifyExternalSecretsDeletion(kms nbv1.KeyManagementServiceSpec, namespace string, uid string) error

+ func WriteYamlFile(name string, obj runtime.Object, moreObjects ...runtime.Object) error

+ type APIGroupFilterFunc func(*metav1.APIGroup) bool

+ type FastRESTMapper struct

+ Discovery discovery.DiscoveryInterface

+ Filter APIGroupFilterFunc

+ Mapper meta.RESTMapper

+ func (m *FastRESTMapper) Discover() error

+ func (m *FastRESTMapper) DiscoverGroup(gr *restmapper.APIGroupResources) error

+ func (m *FastRESTMapper) DiscoverOnError(err error) bool

+ func (m *FastRESTMapper) KindFor(resource schema.GroupVersionResource) (schema.GroupVersionKind, error)

+ func (m *FastRESTMapper) KindsFor(resource schema.GroupVersionResource) ([]schema.GroupVersionKind, error)

+ func (m *FastRESTMapper) RESTMapping(gk schema.GroupKind, versions ...string) (*meta.RESTMapping, error)

+ func (m *FastRESTMapper) RESTMappings(gk schema.GroupKind, versions ...string) ([]*meta.RESTMapping, error)

+ func (m *FastRESTMapper) ResourceFor(input schema.GroupVersionResource) (schema.GroupVersionResource, error)

+ func (m *FastRESTMapper) ResourceSingularizer(resource string) (string, error)

+ func (m *FastRESTMapper) ResourcesFor(input schema.GroupVersionResource) ([]schema.GroupVersionResource, error)

+ type FilterForOwner struct

+ OwnerType runtime.Object

+ Scheme *runtime.Scheme

+ func (p FilterForOwner) Create(e event.CreateEvent) bool

+ func (p FilterForOwner) Delete(e event.DeleteEvent) bool

+ func (p FilterForOwner) Generic(e event.GenericEvent) bool

+ func (p FilterForOwner) Update(e event.UpdateEvent) bool

+ type FinalizersChangedPredicate struct

+ func (p FinalizersChangedPredicate) Update(e event.UpdateEvent) bool

+ type LabelsChangedPredicate struct

+ func (p LabelsChangedPredicate) Update(e event.UpdateEvent) bool

+ type LogEventsPredicate struct

+ func (p LogEventsPredicate) Create(e event.CreateEvent) bool

+ func (p LogEventsPredicate) Delete(e event.DeleteEvent) bool

+ func (p LogEventsPredicate) Generic(e event.GenericEvent) bool

+ func (p LogEventsPredicate) Update(e event.UpdateEvent) bool

+ type OAuth2Endpoints struct

+ AuthorizationEndpoint string

+ TokenEndpoint string

+ func DiscoverOAuthEndpoints() (*OAuth2Endpoints, error)

+ type PersistentError struct

+ Message string

+ Reason string

+ func NewPersistentError(reason string, message string) *PersistentError

+ func (e *PersistentError) Error() string

+ type PrintColumn struct

+ Items []string

+ Width int

+ func (c *PrintColumn) Pad(s string) string

+ func (c *PrintColumn) RecalcWidth()

+ type PrintTable struct

+ Columns []PrintColumn

+ NumRows int

+ func (t *PrintTable) AddRow(items ...string) *PrintTable

+ func (t *PrintTable) RecalcWidth() *PrintTable

+ func (t *PrintTable) String() string

Other modules containing this package

github.com/noobaa/noobaa-operator

github.com/noobaa/noobaa-operator/v2

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