Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/clastix/kamaji
/ functions
Functions
1,102 in github.com/clastix/kamaji
⨍
Functions
1,102
◇
Types & classes
203
↓ 249 callers
Method
Error
()
internal/errors/errors.go:20
↓ 176 callers
Method
GetName
()
internal/resources/resource.go:36
↓ 138 callers
Method
DeepCopyInto
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 callers
Method
Delete
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:44
↓ 52 callers
Function
MergeMaps
(maps ...map[string]string)
internal/utilities/utilities.go:31
↓ 36 callers
Function
LazyLoadHistogramFromResource
(collector prometheus.Histogram, resource Resource)
internal/resources/metrics.go:46
↓ 35 callers
Function
CreateOrUpdateWithConflict
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 callers
Function
GetObjectChecksum
GetObjectChecksum returns the annotation checksum in case this is set, otherwise, an empty string.
internal/utilities/checksum.go:18
↓ 29 callers
Method
CreateOrUpdate
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:35
↓ 23 callers
Function
HasNamedContainer
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 callers
Method
GetClient
()
internal/resources/resource.go:48
↓ 22 callers
Function
StatusMustEqualTo
(tcp *kamajiv1alpha1.TenantControlPlane, status kamajiv1alpha1.KubernetesVersionStatus)
e2e/utils_test.go:127
↓ 21 callers
Function
KamajiLabels
(tcpName, resourceName string)
internal/utilities/utilities.go:23
↓ 20 callers
Method
Fprintln
(io.Writer, ...interface{})
internal/kubeadm/printers/discard.go:22
↓ 20 callers
Method
String
()
api/v1alpha1/types.go:26
↓ 19 callers
Method
Define
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:32
↓ 19 callers
Method
OnCreate
(obj runtime.Object)
internal/webhook/handlers/handler.go:17
↓ 19 callers
Method
String
()
internal/resources/kubeadm_phases.go:41
↓ 18 callers
Function
HasNamedVolume
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 callers
Method
Build
(ctx context.Context, deployment *appsv1.Deployment, tenantControlPlane kamajiv1alpha1.TenantControlPlane)
internal/builders/controlplane/deployment.go:116
↓ 16 callers
Function
NilOp
()
internal/webhook/utils/nil_op.go:13
↓ 15 callers
Function
UpdateOperationResult
(current controllerutil.OperationResult, op controllerutil.OperationResult)
internal/resources/utils/utils.go:14
↓ 13 callers
Function
AddTenantPrefix
(name string, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/utilities.go:43
↓ 13 callers
Function
DecodeFromYAML
(o string, to runtime.Object)
internal/utilities/utilities.go:66
↓ 13 callers
Function
SetObjectChecksum
SetObjectChecksum calculates the checksum for the given map and store it in the object annotations.
internal/utilities/checksum.go:28
↓ 13 callers
Function
gaugeValueByLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels map[string]string)
internal/metrics/metrics_test.go:369
↓ 12 callers
Function
BuildGatewayAccessPointsStatus
BuildGatewayAccessPointsStatus builds access points from route statuses. Per the Gateway API specification, ParentReference.SectionName is optional:
internal/resources/k8s_gateway_utils.go:189
↓ 12 callers
Method
Close
()
internal/datastore/connection.go:60
↓ 12 callers
Function
IsRotationRequested
(obj client.Object)
internal/utilities/certs_rotation.go:20
↓ 12 callers
Function
applyProbeOverrides
(probe *corev1.Probe, spec *kamajiv1alpha1.ProbeSpec)
internal/builders/controlplane/deployment.go:54
↓ 11 callers
Method
GetContent
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 callers
Function
SetLastRotationTimestamp
(obj client.Object)
internal/utilities/certs_rotation.go:33
↓ 11 callers
Method
ensureVolumeMount
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 callers
Function
getTmpDirectory
(base string, tenantControlPlane kamajiv1alpha1.TenantControlPlane)
controllers/resources.go:341
↓ 11 callers
Method
retrieveTenantControlPlane
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 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Transport.
internal/resources/konnectivity/zz_generated.deepcopy.go:112
↓ 10 callers
Function
getStoredKubeadmConfiguration
(ctx context.Context, client client.Client, tmpDirectory string, tenantControlPlane *kamajiv1alpha1.TenantCont
internal/resources/resource.go:117
↓ 9 callers
Function
CalculateMapChecksum
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 callers
Function
HasNamedVolumeMount
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 callers
Function
NewGrantPrivilegesError
(err error)
internal/datastore/errors/errors.go:16
↓ 9 callers
Function
ParseCertificateBytes
ParseCertificateBytes takes the certificate bytes returning a x509 certificate by parsing it.
internal/crypto/crypto.go:102
↓ 9 callers
Function
defaultProbe
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 callers
Method
AssignedControlPlaneAddress
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 callers
Function
GetTenantClient
(ctx context.Context, c client.Client, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/tenant_client.go:22
↓ 8 callers
Function
Handle
Handle handles the given resource and returns a boolean to say if the tenantControlPlane has been modified.
internal/resources/resource.go:69
↓ 8 callers
Method
String
()
internal/datastore/datastore.go:24
↓ 8 callers
Function
containerSecurityContextMustEqualTo
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 callers
Function
gaugeValueByLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels map[string]string)
controllers/datastore_controller_metrics_test.go:94
↓ 8 callers
Function
mustMetricFamily
(t *testing.T, name string)
internal/metrics/metrics_test.go:344
↓ 8 callers
Function
testRecorder
()
internal/metrics/metrics_test.go:16
↓ 7 callers
Function
ArgsFromSliceToMap
ArgsFromSliceToMap transforms a slice of string into a map, simplifying the subsequent mangling.
internal/utilities/args.go:13
↓ 7 callers
Function
EncodeToYaml
EncodeToYaml returns the given object in yaml format and the error.
internal/utilities/utilities.go:48
↓ 7 callers
Function
FindMatchingListener
FindMatchingListener finds a listener in the given list that matches the parent reference.
internal/resources/k8s_gateway_utils.go:58
↓ 7 callers
Function
GetEffectiveCIDRs
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 callers
Method
SetupWithManager
(mgr manager.Manager)
controllers/soot/manager.go:428
↓ 7 callers
Method
ShouldCleanup
(tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:33
↓ 7 callers
Function
getControlPlanePods
getControlPlanePods returns all pods that belong to the given tenant control plane.
e2e/utils_test.go:353
↓ 7 callers
Function
mergeAPIServerArgs
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 callers
Method
mutate
(ctx context.Context, nonFilledStatement string, args ...any)
internal/datastore/mysql.go:293
↓ 7 callers
Method
shouldHaveGateway
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 callers
Function
CalculateStringSliceChecksum
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 callers
Function
DefaultRecorder
()
internal/metrics/metrics.go:139
↓ 6 callers
Method
GetName
()
internal/resources/konnectivity/agent.go:153
↓ 6 callers
Function
NewRefreshContextFrom
(ctx context.Context)
internal/metrics/metrics.go:79
↓ 6 callers
Method
OnUpdate
(newObject runtime.Object, prevObject runtime.Object)
internal/webhook/handlers/handler.go:19
↓ 6 callers
Method
ShouldStatusBeUpdated
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/resources/resource.go:37
↓ 6 callers
Method
Start
(ctx context.Context)
controllers/telemetry_controller.go:40
↓ 6 callers
Method
namespacedName
(ref SecretReference)
api/v1alpha1/indexer_datastore_usedsecret.go:70
↓ 6 callers
Method
secretProjection
(secretName, certKeyName, keyName string)
internal/builders/controlplane/deployment.go:831
↓ 6 callers
Method
validateContentReference
(ctx context.Context, ref kamajiv1alpha1.ContentRef)
controllers/datastore_controller.go:417
↓ 5 callers
Function
ArgsFromMapToSlice
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 callers
Function
CheckCertificateAndPrivateKeyPairValidity
CheckCertificateAndPrivateKeyPairValidity checks if the certificate and private key pair are valid.
internal/crypto/crypto.go:76
↓ 5 callers
Method
DBExists
(ctx context.Context, dbName string)
internal/datastore/connection.go:54
↓ 5 callers
Method
GetName
()
internal/resources/kubeconfig.go:93
↓ 5 callers
Method
GetName
()
internal/resources/konnectivity/kubeconfig_resource.go:83
↓ 5 callers
Method
GetName
()
internal/resources/konnectivity/certificate_resource.go:86
↓ 5 callers
Function
GetTenantKubeconfig
(ctx context.Context, client client.Client, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/tenant_client.go:41
↓ 5 callers
Function
IsPaused
(obj client.Object)
controllers/utils/is_paused.go:12
↓ 5 callers
Function
IsValidCertificateKeyPairBytes
IsValidCertificateKeyPairBytes checks if the certificate matches the private key bounded to it.
internal/crypto/crypto.go:161
↓ 5 callers
Function
UpdateStatus
(ctx context.Context, client client.Client, tcp *kamajiv1alpha1.TenantControlPlane, resource resources.Resourc
controllers/utils/update_status.go:18
↓ 5 callers
Function
assertMetricFamilyDoesNotHaveLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels ...string)
internal/metrics/metrics_test.go:325
↓ 5 callers
Function
assertMetricFamilyHasLabels
(t *testing.T, family *io_prometheus_client.MetricFamily, labels ...string)
internal/metrics/metrics_test.go:306
↓ 5 callers
Method
checkDataStoreOverrides
(ctx context.Context, tcp *kamajiv1alpha1.TenantControlPlane)
internal/webhook/handlers/tcp_datastore.go:65
↓ 5 callers
Method
cleanup
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 callers
Method
normalizeKubernetesVersion
(input string)
internal/webhook/handlers/tcp_version.go:47
↓ 4 callers
Function
AreGatewayResourcesAvailable
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 callers
Method
Check
(ctx context.Context)
internal/datastore/connection.go:61
↓ 4 callers
Function
DecodeKubeconfig
(secret corev1.Secret, key string)
internal/utilities/kubeconfig.go:16
↓ 4 callers
Function
DecodeKubeconfigYAML
(bytes []byte)
internal/utilities/kubeconfig.go:25
↓ 4 callers
Method
DeepCopy
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProbeSet.
api/v1alpha1/zz_generated.deepcopy.go:1630
↓ 4 callers
Method
DeepCopyInto
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 callers
Function
GetControlPlaneAddressAndPortFromHostname
(hostname string, defaultPort int32)
internal/utilities/ingress.go:11
↓ 4 callers
Method
GetName
()
internal/resources/front-proxy-client-certificate.go:81
↓ 4 callers
Method
GetName
()
internal/resources/k8s_gateway_resource.go:202
↓ 4 callers
Method
GetName
()
internal/resources/api_server_kubelet_client_certificate.go:81
↓ 4 callers
Method
GetName
()
internal/resources/api_server_certificate.go:86
↓ 4 callers
Method
GetName
()
internal/resources/datastore/datastore_certificate.go:76
↓ 4 callers
Method
GetName
()
internal/resources/konnectivity/gateway_resource.go:229
↓ 4 callers
Method
GetName
()
internal/resources/addons/coredns.go:205
↓ 4 callers
Function
GetTenantClientSet
(ctx context.Context, client client.Client, tenantControlPlane *kamajiv1alpha1.TenantControlPlane)
internal/utilities/tenant_client.go:32
next →
1–100 of 1,102, ranked by callers