kubeobjects

Oct 13, 2023

Changes in this version

+ const EdgeConnectComponentLabel

+ func AddHashAnnotation(object metav1.Object) error

+ func AffinityNodeRequirementForSupportedArches() []corev1.NodeSelectorRequirement

+ func CreateOrUpdateDeployment(c client.Client, logger logr.Logger, desiredDeployment *appsv1.Deployment) (bool, error)

type AppLabels

+ func NewAnnotations(appName, name, component, ver string) *AppLabels

Jun 22, 2023

Changes in this version

+ func GetPlatformFromEnv() string

+ func GetVolumeMountByName(mounts []corev1.VolumeMount, volumeName string) (*corev1.VolumeMount, error)

Apr 17, 2023

Changes in this version

+ const EnvPodName

+ const EnvPodNamespace

+ const SyntheticComponentLabel

+ func AddOrUpdate(envVars []corev1.EnvVar, desiredEnvVar corev1.EnvVar) []corev1.EnvVar

+ func CreateConfigMap(scheme *runtime.Scheme, owner metav1.Object, mods ...configMapModifier) (*corev1.ConfigMap, error)

+ func CreateSecret(scheme *runtime.Scheme, owner metav1.Object, mods ...secretBuilderModifier) (*corev1.Secret, error)

+ func DefaultNamespace() string

+ func ExtractField(configMap *corev1.ConfigMap, key string) (string, error)

+ func GetPodName(pod corev1.Pod) string

+ func NewQuantity(serialized string) *resource.Quantity

+ func NewResources(cpu, memory string) corev1.ResourceList

+ func VolumeClaimIsDefined(claims []corev1.PersistentVolumeClaim, claimNameToCheck string) bool

+ type ConfigMapDataModifier struct

+ func NewConfigMapDataModifier(data map[string]string) ConfigMapDataModifier

+ func (mod ConfigMapDataModifier) Enabled() bool

+ func (mod ConfigMapDataModifier) Modify(configMap *corev1.ConfigMap) error

+ type ConfigMapNameModifier struct

+ func NewConfigMapNameModifier(name string) ConfigMapNameModifier

+ func (mod ConfigMapNameModifier) Enabled() bool

+ func (mod ConfigMapNameModifier) Modify(configMap *corev1.ConfigMap) error

+ type ConfigMapNamespaceModifier struct

+ func NewConfigMapNamespaceModifier(namespaceName string) ConfigMapNamespaceModifier

+ func (mod ConfigMapNamespaceModifier) Enabled() bool

+ func (mod ConfigMapNamespaceModifier) Modify(configMap *corev1.ConfigMap) error

type ConfigMapQuery

+ func (query ConfigMapQuery) Delete(configMap corev1.ConfigMap) error

+ type Platform int

+ const Kubernetes

+ const Openshift

+ func ResolvePlatformFromEnv() Platform

+ type SecretDataModifier struct

+ func NewSecretDataModifier(data map[string][]byte) SecretDataModifier

+ func (mod SecretDataModifier) Enabled() bool

+ func (mod SecretDataModifier) Modify(secret *corev1.Secret) error

+ type SecretLabelsModifier struct

+ func NewSecretLabelsModifier(labels map[string]string) SecretLabelsModifier

+ func (mod SecretLabelsModifier) Enabled() bool

+ func (mod SecretLabelsModifier) Modify(secret *corev1.Secret) error

+ type SecretNameModifier struct

+ func NewSecretNameModifier(name string) SecretNameModifier

+ func (mod SecretNameModifier) Enabled() bool

+ func (mod SecretNameModifier) Modify(secret *corev1.Secret) error

+ type SecretNamespaceModifier struct

+ func NewSecretNamespaceModifier(namespaceName string) SecretNamespaceModifier

+ func (mod SecretNamespaceModifier) Enabled() bool

+ func (mod SecretNamespaceModifier) Modify(secret *corev1.Secret) error

type SecretQuery

+ func (query SecretQuery) CreateOrUpdateForNamespacesList(newSecret corev1.Secret, namespaces []corev1.Namespace) error

+ func (query SecretQuery) GetAllFromNamespaces(secretName string) ([]corev1.Secret, error)

+ type SecretTypeModifier struct

+ func NewSecretTypeModifier(secretType corev1.SecretType) SecretTypeModifier

+ func (mod SecretTypeModifier) Enabled() bool

+ func (mod SecretTypeModifier) Modify(secret *corev1.Secret) error

Dec 15, 2022

Changes in this version

+ func AreConfigMapsEqual(configMap corev1.ConfigMap, other corev1.ConfigMap) bool

+ func IsConfigMapDataEqual(currentConfigMap *corev1.ConfigMap, desired map[string]string) bool

+ func NewConfigMap(name string, namespace string, data map[string]string) *corev1.ConfigMap

+ type ConfigMapQuery struct

+ func NewConfigMapQuery(ctx context.Context, kubeClient client.Client, kubeReader client.Reader, ...) ConfigMapQuery

+ func (query ConfigMapQuery) Create(configMap corev1.ConfigMap) error

+ func (query ConfigMapQuery) CreateOrUpdate(configMap corev1.ConfigMap) error

+ func (query ConfigMapQuery) Get(objectKey client.ObjectKey) (corev1.ConfigMap, error)

+ func (query ConfigMapQuery) Update(configMap corev1.ConfigMap) error

Nov 29, 2022

Changes in this version

+ func FindContainerInPodSpec(podSpec *corev1.PodSpec, containerName string) *corev1.Container

+ func IsDifferent(a, b interface{}) (bool, error)

+ func IsHashAnnotationDifferent(a, b metav1.Object) bool

+ func IsOutdated(previous, current *metav1.Time, threshold time.Duration) bool

+ func IsVolumeMountPresent(volumeMounts []corev1.VolumeMount, neededMount corev1.VolumeMount) bool

type DynakubeQuery

+ func (query DynakubeQuery) List() (dynatracev1beta1.DynaKubeList, error)

+ type TimeProvider struct

+ func NewTimeProvider() *TimeProvider

+ func (timeProvider *TimeProvider) IsOutdated(previous *metav1.Time, threshold time.Duration) bool

+ func (timeProvider *TimeProvider) Now() *metav1.Time

+ func (timeProvider *TimeProvider) SetNow(now *metav1.Time)

Sep 28, 2022

Changes in this version

+ func Delete(ctx context.Context, client client.Client, obj client.Object) error

+ func GetPod(ctx context.Context, clt client.Reader, name, namespace string) (*corev1.Pod, error)

+ func MergeMap(maps ...map[string]string) map[string]string

+ func SwitchCapability(instance *dynatracev1beta1.DynaKube, ...)

+ func TolerationForAmd() []corev1.Toleration

type DynakubeQuery

+ func (query DynakubeQuery) Get(objectKey client.ObjectKey) (dynatracev1beta1.DynaKube, error)

+ type Reconciler interface

+ Reconcile func() (update bool, err error)

+ type StatefulSetEvent func(sts *v1.StatefulSet)

Aug 8, 2022

Changes in this version

+ const CustomImageLabelValue

+ func FindContainerInPod(pod corev1.Pod, name string) (*corev1.Container, error)

+ func NewEnvVarSourceForField(fieldPath string) *corev1.EnvVarSource

Jun 23, 2022

Changes in this version

+ func AreSecretsEqual(secret corev1.Secret, other corev1.Secret) bool

+ func FindEnvVar(envVarList []corev1.EnvVar, name string) *corev1.EnvVar

+ func GetDataFromSecretName(apiReader client.Reader, namespacedName types.NamespacedName, dataKey string) (string, error)

+ func IsSecretDataEqual(currentSecret *corev1.Secret, desired map[string][]byte) bool

+ func NewSecret(name string, namespace string, data map[string][]byte) *corev1.Secret

+ type DynakubeQuery struct

+ func NewDynakubeQuery(clt client.Client, namespace string) DynakubeQuery

+ func (query DynakubeQuery) Proxy(dynakube dynatracev1beta1.DynaKube) (string, error)

+ func (query DynakubeQuery) TlsCert(dynakube dynatracev1beta1.DynaKube) (string, error)

+ func (query DynakubeQuery) TrustedCAs(dynakube dynatracev1beta1.DynaKube) ([]byte, error)

+ func (query DynakubeQuery) WithContext(ctx context.Context) DynakubeQuery

+ type SecretQuery struct

+ func NewSecretQuery(ctx context.Context, kubeClient client.Client, kubeReader client.Reader, ...) SecretQuery

+ func (query SecretQuery) Create(secret corev1.Secret) error

+ func (query SecretQuery) CreateOrUpdate(secret corev1.Secret) error

+ func (query SecretQuery) Get(objectKey client.ObjectKey) (corev1.Secret, error)

+ func (query SecretQuery) Update(secret corev1.Secret) error

May 5, 2022

Changes in this version

+ const ActiveGateComponentLabel

+ const AppComponentLabel

+ const AppCreatedByLabel

+ const AppManagedByLabel

+ const AppNameLabel

+ const AppVersionLabel

+ const OneAgentComponentLabel

+ const ReadOnlyMountPath

+ const ReadWriteMountPath

+ const UnprivilegedGroup

+ const UnprivilegedUser

+ const WebhookComponentLabel

+ func ConfigMapDataEqual(map1, map2 *corev1.ConfigMap) bool

+ func GetVolumeByName(volumes []corev1.Volume, volumeName string) (*corev1.Volume, error)

+ func IsSecretEqual(currentSecret *corev1.Secret, desired map[string][]byte) bool

+ func Key(object client.Object) client.ObjectKey

+ func LabelsNotEqual(currentLabels, desiredLabels map[string]string) bool

+ func MountPathIsReadOnlyOrReadWrite(volumeMounts []corev1.VolumeMount, mountPathToCheck string, mode bool) bool

+ func VolumeMountIsDefined(volumeMounts []corev1.VolumeMount, volumeMountNameToCheck string) bool

+ type AppLabels struct

+ Component string

+ Version string

+ func NewAppLabels(appName, dynakubeName, feature, featureVersion string) *AppLabels

+ func (labels *AppLabels) BuildLabels() map[string]string

+ func (labels *AppLabels) BuildMatchLabels() map[string]string

+ type ContainerBuilder interface

+ BuildContainer func() corev1.Container

+ BuildVolumes func() []corev1.Volume

+ type CoreLabels struct

+ Version string

+ func NewCoreLabels(dynakubeName, component string) *CoreLabels

+ func (labels *CoreLabels) BuildLabels() map[string]string

+ func (labels *CoreLabels) BuildMatchLabels() map[string]string

Mar 14, 2022

Changes in this version

+ func EnvVarIsIn(envVars []corev1.EnvVar, envVarToCheck string) bool

+ func MountPathIsIn(volumeMounts []corev1.VolumeMount, mountPathToCheck string) bool

+ func PortIsIn(ports []corev1.ContainerPort, portToCheck int32) bool

+ func ValidateCertificateExpiration(certData []byte, renewalThreshold time.Duration, now time.Time, ...) (bool, error)

+ func VolumeIsDefined(volumes []corev1.Volume, volumeMountNameToCheck string) bool

+ type ProbeResult int

+ const ProbeObjectFound

+ const ProbeObjectNotFound

+ const ProbeTypeFound

+ const ProbeTypeNotFound

+ const ProbeUnknown

+ func KubernetesObjectProbe(gvk schema.GroupVersionKind, namespace string, name string, ...) (ProbeResult, error)

+ func MapErrorToObjectProbeResult(err error) (ProbeResult, error)

Jan 25, 2022

Changes in this version

+ const AnnotationHash

+ func AffinityNodeRequirement() []corev1.NodeSelectorRequirement

+ func AffinityNodeRequirementWithARM64() []corev1.NodeSelectorRequirement

+ func CheckIfOneAgentAPMExists(cfg *rest.Config) (bool, error)

+ func CreateEmptySecret(name string, namespace string) *corev1.Secret

+ func CreateOrUpdateDaemonSet(c client.Client, logger logr.Logger, desiredDs *appsv1.DaemonSet) (bool, error)

+ func CreateOrUpdateSecretIfNotExists(c client.Client, r client.Reader, secretName string, targetNS string, ...) (bool, error)

+ func ExtractToken(secret *corev1.Secret, key string) (string, error)

+ func GenerateHash(ds interface{}) (string, error)

+ func GetDeployment(c client.Client, podName, namespace string) (*appsv1.Deployment, error)

+ func GetField(values map[string]string, key string, defaultValue string) string

+ func GetFieldBool(values map[string]string, key string, defaultValue bool) bool

+ func GetSecret(ctx context.Context, apiReader client.Reader, name string, namespace string) (*corev1.Secret, error)

+ func HasChanged(a, b metav1.Object) bool

+ func MergeLabels(labels ...map[string]string) map[string]string

+ type Tokens struct

+ ApiToken string

+ PaasToken string

+ func NewTokens(secret *corev1.Secret) (*Tokens, error)