MCPcopy Create free account

hub / github.com/clastix/kamaji / functions

Functions1,102 in github.com/clastix/kamaji

↓ 249 callersMethodError
()
internal/errors/errors.go:20
↓ 176 callersMethodGetName
()
internal/resources/resource.go:36
↓ 138 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
api/v1alpha1/zz_generated.deepcopy.go:1610
↓ 52 callersMethodDelete
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:44
↓ 52 callersFunctionMergeMaps
(maps ...map[string]string)
internal/utilities/utilities.go:31
↓ 36 callersFunctionLazyLoadHistogramFromResource
(collector prometheus.Histogram, resource Resource)
internal/resources/metrics.go:46
↓ 35 callersFunctionCreateOrUpdateWithConflict
CreateOrUpdateWithConflict is a helper function that wraps the RetryOnConflict around the CreateOrUpdate function: this allows to fetch from the cache
internal/utilities/create_or_update_conflict.go:19
↓ 35 callersFunctionGetObjectChecksum
GetObjectChecksum returns the annotation checksum in case this is set, otherwise, an empty string.
internal/utilities/checksum.go:18
↓ 29 callersMethodCreateOrUpdate
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:35
↓ 23 callersFunctionHasNamedContainer
HasNamedContainer finds the Container in the provided slice by its name, returning a boolean if found, and its index.
internal/utilities/container.go:9
↓ 22 callersMethodGetClient
()
internal/resources/resource.go:48
↓ 22 callersFunctionStatusMustEqualTo
(tcp *kamajiv1alpha1.TenantControlPlane, status kamajiv1alpha1.KubernetesVersionStatus)
e2e/utils_test.go:127
↓ 21 callersFunctionKamajiLabels
(tcpName, resourceName string)
internal/utilities/utilities.go:23
↓ 20 callersMethodFprintln
(io.Writer, ...interface{})
internal/kubeadm/printers/discard.go:22
↓ 20 callersMethodString
()
api/v1alpha1/types.go:26
↓ 19 callersMethodDefine
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:32
↓ 19 callersMethodOnCreate
(obj runtime.Object)
internal/webhook/handlers/handler.go:17
↓ 19 callersMethodString
()
internal/resources/kubeadm_phases.go:41
↓ 18 callersFunctionHasNamedVolume
HasNamedVolume finds the Volume in the provided slice by its name, returning a boolean if found, and its index.
internal/utilities/volumes.go:9
↓ 16 callersMethodBuild
(ctx context.Context, deployment *appsv1.Deployment, tenantControlPlane kamajiv1alpha1.TenantControlPlane)
internal/builders/controlplane/deployment.go:116
↓ 16 callersFunctionNilOp
()
internal/webhook/utils/nil_op.go:13
↓ 15 callersFunctionUpdateOperationResult
(current controllerutil.OperationResult, op controllerutil.OperationResult)
internal/resources/utils/utils.go:14
↓ 13 callersFunctionAddTenantPrefix
(name string, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/utilities.go:43
↓ 13 callersFunctionDecodeFromYAML
(o string, to runtime.Object)
internal/utilities/utilities.go:66
↓ 13 callersFunctionSetObjectChecksum
SetObjectChecksum calculates the checksum for the given map and store it in the object annotations.
internal/utilities/checksum.go:28
↓ 13 callersFunctiongaugeValueByLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels map[string]string)
internal/metrics/metrics_test.go:369
↓ 12 callersFunctionBuildGatewayAccessPointsStatus
BuildGatewayAccessPointsStatus builds access points from route statuses. Per the Gateway API specification, ParentReference.SectionName is optional:
internal/resources/k8s_gateway_utils.go:189
↓ 12 callersMethodClose
()
internal/datastore/connection.go:60
↓ 12 callersFunctionIsRotationRequested
(obj client.Object)
internal/utilities/certs_rotation.go:20
↓ 12 callersFunctionapplyProbeOverrides
(probe *corev1.Probe, spec *kamajiv1alpha1.ProbeSpec)
internal/builders/controlplane/deployment.go:54
↓ 11 callersMethodGetContent
GetContent is the resolver for the container of the Secret. The bare content has priority over the external reference.
api/v1alpha1/datastore_funcs.go:17
↓ 11 callersFunctionSetLastRotationTimestamp
(obj client.Object)
internal/utilities/certs_rotation.go:33
↓ 11 callersMethodensureVolumeMount
ensureVolumeMount retrieve the index for the named volumeMount, in case of missing it's going to be appended.
internal/builders/controlplane/deployment.go:557
↓ 11 callersFunctiongetTmpDirectory
(base string, tenantControlPlane kamajiv1alpha1.TenantControlPlane)
controllers/resources.go:341
↓ 11 callersMethodretrieveTenantControlPlane
retrieveTenantControlPlane is the function used to let an underlying controller of the soot manager to retrieve its parent TenantControlPlane definiti
controllers/soot/manager.go:67
↓ 10 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transport.
internal/resources/konnectivity/zz_generated.deepcopy.go:112
↓ 10 callersFunctiongetStoredKubeadmConfiguration
(ctx context.Context, client client.Client, tmpDirectory string, tenantControlPlane *kamajiv1alpha1.TenantCont
internal/resources/resource.go:117
↓ 9 callersFunctionCalculateMapChecksum
CalculateMapChecksum orders the map according to its key, and calculating the overall md5 of the values. It's expected to work with ConfigMap (map[str
internal/utilities/checksum.go:60
↓ 9 callersFunctionHasNamedVolumeMount
HasNamedVolumeMount finds the VolumeMount in the provided slice by its name, returning a boolean if found, and its index.
internal/utilities/volumes.go:20
↓ 9 callersFunctionNewGrantPrivilegesError
(err error)
internal/datastore/errors/errors.go:16
↓ 9 callersFunctionParseCertificateBytes
ParseCertificateBytes takes the certificate bytes returning a x509 certificate by parsing it.
internal/crypto/crypto.go:102
↓ 9 callersFunctiondefaultProbe
defaultProbe builds the standard HTTPS probe shared by all control plane components; only the path and port differ between components and probe types.
internal/builders/controlplane/deployment.go:68
↓ 8 callersMethodAssignedControlPlaneAddress
AssignedControlPlaneAddress returns the announced address and port of a Tenant Control Plane. In case of non-well formed values, or missing announceme
api/v1alpha1/tenantcontrolplane_funcs.go:22
↓ 8 callersFunctionGetTenantClient
(ctx context.Context, c client.Client, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/tenant_client.go:22
↓ 8 callersFunctionHandle
Handle handles the given resource and returns a boolean to say if the tenantControlPlane has been modified.
internal/resources/resource.go:69
↓ 8 callersMethodString
()
internal/datastore/datastore.go:24
↓ 8 callersFunctioncontainerSecurityContextMustEqualTo
containerSecurityContextMustEqualTo verifies if the container with the given containerName in the control plane pods has the given security context.
e2e/utils_test.go:264
↓ 8 callersFunctiongaugeValueByLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels map[string]string)
controllers/datastore_controller_metrics_test.go:94
↓ 8 callersFunctionmustMetricFamily
(t *testing.T, name string)
internal/metrics/metrics_test.go:344
↓ 8 callersFunctiontestRecorder
()
internal/metrics/metrics_test.go:16
↓ 7 callersFunctionArgsFromSliceToMap
ArgsFromSliceToMap transforms a slice of string into a map, simplifying the subsequent mangling.
internal/utilities/args.go:13
↓ 7 callersFunctionEncodeToYaml
EncodeToYaml returns the given object in yaml format and the error.
internal/utilities/utilities.go:48
↓ 7 callersFunctionFindMatchingListener
FindMatchingListener finds a listener in the given list that matches the parent reference.
internal/resources/k8s_gateway_utils.go:58
↓ 7 callersFunctionGetEffectiveCIDRs
GetEffectiveCIDRs returns the CIDRs to use. If the new CIDRs field is populated, it is considered authoritative. The deprecated field is only used as
internal/utilities/utilities.go:121
↓ 7 callersMethodSetupWithManager
(mgr manager.Manager)
controllers/soot/manager.go:428
↓ 7 callersMethodShouldCleanup
(tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:33
↓ 7 callersFunctiongetControlPlanePods
getControlPlanePods returns all pods that belong to the given tenant control plane.
e2e/utils_test.go:353
↓ 7 callersFunctionmergeAPIServerArgs
mergeAPIServerArgs composes the final kube-apiserver argument slice from three layers: - Kamaji-managed flags always win and drop any user duplicate s
internal/builders/controlplane/deployment.go:751
↓ 7 callersMethodmutate
(ctx context.Context, nonFilledStatement string, args ...any)
internal/datastore/mysql.go:293
↓ 7 callersMethodshouldHaveGateway
shouldHaveGateway checks if Konnectivity gateway should be configured. Create when Konnectivity addon is enabled and control plane gateway is configur
internal/resources/konnectivity/gateway_resource.go:51
↓ 6 callersFunctionCalculateStringSliceChecksum
CalculateStringSliceChecksum calculates a checksum of slice, calculating the overall md5 of each values. It takes order into account, as in : Calcul
internal/utilities/checksum.go:43
↓ 6 callersFunctionDefaultRecorder
()
internal/metrics/metrics.go:139
↓ 6 callersMethodGetName
()
internal/resources/konnectivity/agent.go:153
↓ 6 callersFunctionNewRefreshContextFrom
(ctx context.Context)
internal/metrics/metrics.go:79
↓ 6 callersMethodOnUpdate
(newObject runtime.Object, prevObject runtime.Object)
internal/webhook/handlers/handler.go:19
↓ 6 callersMethodShouldStatusBeUpdated
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:37
↓ 6 callersMethodStart
(ctx context.Context)
controllers/telemetry_controller.go:40
↓ 6 callersMethodnamespacedName
(ref SecretReference)
api/v1alpha1/indexer_datastore_usedsecret.go:70
↓ 6 callersMethodsecretProjection
(secretName, certKeyName, keyName string)
internal/builders/controlplane/deployment.go:831
↓ 6 callersMethodvalidateContentReference
(ctx context.Context, ref kamajiv1alpha1.ContentRef)
controllers/datastore_controller.go:417
↓ 5 callersFunctionArgsFromMapToSlice
ArgsFromMapToSlice create the slice of args, and sorting the resulting output in order to make it idempotent. Along with that, if a flag doesn't have
internal/utilities/args.go:27
↓ 5 callersFunctionCheckCertificateAndPrivateKeyPairValidity
CheckCertificateAndPrivateKeyPairValidity checks if the certificate and private key pair are valid.
internal/crypto/crypto.go:76
↓ 5 callersMethodDBExists
(ctx context.Context, dbName string)
internal/datastore/connection.go:54
↓ 5 callersMethodGetName
()
internal/resources/kubeconfig.go:93
↓ 5 callersMethodGetName
()
internal/resources/konnectivity/kubeconfig_resource.go:83
↓ 5 callersMethodGetName
()
internal/resources/konnectivity/certificate_resource.go:86
↓ 5 callersFunctionGetTenantKubeconfig
(ctx context.Context, client client.Client, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/tenant_client.go:41
↓ 5 callersFunctionIsPaused
(obj client.Object)
controllers/utils/is_paused.go:12
↓ 5 callersFunctionIsValidCertificateKeyPairBytes
IsValidCertificateKeyPairBytes checks if the certificate matches the private key bounded to it.
internal/crypto/crypto.go:161
↓ 5 callersFunctionUpdateStatus
(ctx context.Context, client client.Client, tcp *kamajiv1alpha1.TenantControlPlane, resource resources.Resourc
controllers/utils/update_status.go:18
↓ 5 callersFunctionassertMetricFamilyDoesNotHaveLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels ...string)
internal/metrics/metrics_test.go:325
↓ 5 callersFunctionassertMetricFamilyHasLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels ...string)
internal/metrics/metrics_test.go:306
↓ 5 callersMethodcheckDataStoreOverrides
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/webhook/handlers/tcp_datastore.go:65
↓ 5 callersMethodcleanup
If the TenantControlPlane is deleted we have to free up memory by stopping the soot manager: this is made possible by retrieving the cancel function o
controllers/soot/manager.go:85
↓ 5 callersMethodnormalizeKubernetesVersion
(input string)
internal/webhook/handlers/tcp_version.go:47
↓ 4 callersFunctionAreGatewayResourcesAvailable
AreGatewayResourcesAvailable checks if Gateway API is available in the cluster through a discovery Client with fallback to client-based check.
internal/utilities/gateway_discovery.go:18
↓ 4 callersMethodCheck
(ctx context.Context)
internal/datastore/connection.go:61
↓ 4 callersFunctionDecodeKubeconfig
(secret corev1.Secret, key string)
internal/utilities/kubeconfig.go:16
↓ 4 callersFunctionDecodeKubeconfigYAML
(bytes []byte)
internal/utilities/kubeconfig.go:25
↓ 4 callersMethodDeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProbeSet.
api/v1alpha1/zz_generated.deepcopy.go:1630
↓ 4 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
internal/resources/konnectivity/zz_generated.deepcopy.go:97
↓ 4 callersFunctionGetControlPlaneAddressAndPortFromHostname
(hostname string, defaultPort int32)
internal/utilities/ingress.go:11
↓ 4 callersMethodGetName
()
internal/resources/front-proxy-client-certificate.go:81
↓ 4 callersMethodGetName
()
internal/resources/k8s_gateway_resource.go:202
↓ 4 callersMethodGetName
()
internal/resources/api_server_kubelet_client_certificate.go:81
↓ 4 callersMethodGetName
()
internal/resources/api_server_certificate.go:86
↓ 4 callersMethodGetName
()
internal/resources/datastore/datastore_certificate.go:76
↓ 4 callersMethodGetName
()
internal/resources/konnectivity/gateway_resource.go:229
↓ 4 callersMethodGetName
()
internal/resources/addons/coredns.go:205
↓ 4 callersFunctionGetTenantClientSet
(ctx context.Context, client client.Client, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/tenant_client.go:32
next →1–100 of 1,102, ranked by callers