k8s

func ApplyControllerPodSpecModifications ¶ added in v1.2.0

func ApplyControllerPodSpecModifications(
	podSpec *corev1.PodSpec,
	connection temporaliov1alpha1.ConnectionSpec,
	temporalNamespace string,
	workerDeploymentName string,
	buildID string,
)

ApplyControllerPodSpecModifications applies controller-managed environment variables and volume mounts to a pod spec. This is used both when creating new deployments and when updating existing deployments for drift detection.

func CleanStringForDNS ¶ added in v1.0.0

func CleanStringForDNS(s string) string

func ComputeBuildID ¶

func ComputeBuildID(w *temporaliov1alpha1.WorkerDeployment) string

func ComputeConnectionSpecHash ¶ added in v0.1.5

func ComputeConnectionSpecHash(connection temporaliov1alpha1.ConnectionSpec) string

TODO (Shivam): Change hash when secret name is updated as well.

func ComputePodTemplateSpecHash ¶ added in v1.2.0

func ComputePodTemplateSpecHash(template corev1.PodTemplateSpec) string

ComputePodTemplateSpecHash computes a SHA256 hash of the user-provided pod template spec. This hash is used to detect drift when the build ID is stable but the pod spec has changed. JSON marshaling is used so that new zero-value fields added in future k8s API versions (which carry omitempty) are excluded, keeping hashes stable across k8s upgrades.

func ComputeRenderedObjectHash ¶ added in v1.5.0

func ComputeRenderedObjectHash(resource *unstructured.Unstructured) string

ComputeRenderedObjectHash returns a stable, deterministic hash of a rendered Unstructured object. The hash is computed from the JSON representation of the object; encoding/json serialises map keys in sorted order, so the result is deterministic regardless of map iteration order. Returns an empty string (not an error) if marshalling fails — callers treat an empty hash as "always apply". When the returned hash is empty, the stored LastAppliedHash remains "" in status after a successful apply, so the "always apply" behaviour persists across reconcile cycles until marshalling succeeds.

func ComputeSelectorLabels ¶ added in v1.5.0

func ComputeSelectorLabels(twdName, buildID string) map[string]string

ComputeSelectorLabels returns the selector labels used by a versioned Deployment. These are the same labels set on the Deployment.Spec.Selector.MatchLabels.

func ComputeVersionedDeploymentName ¶

func ComputeVersionedDeploymentName(baseName, buildID string) string

ComputeVersionedDeploymentName generates a name for a versioned deployment Name will be <=47 characters and unique for that Worker Deployment Version within the namespace.

func ComputeWorkerDeploymentName ¶

func ComputeWorkerDeploymentName(w *temporaliov1alpha1.WorkerDeployment) string

ComputeWorkerDeploymentName generates the base worker deployment name

func ComputeWorkerResourceTemplateName ¶ added in v1.5.0

func ComputeWorkerResourceTemplateName(twdName, wrtName, buildID string) string

ComputeWorkerResourceTemplateName generates a deterministic, DNS-safe name for the worker resource template instance corresponding to a given (twdName, wrtName, buildID) triple.

The name has the form:

{human-readable-prefix}-{8-char-hash}

The 8-character hash is computed from the full untruncated triple BEFORE any length capping occurs. This guarantees that two different triples — including triples that differ only in the buildID — always produce different names, even if the human-readable prefix is truncated. The buildID is therefore always uniquely represented via the hash, regardless of how long twdName or wrtName are.

func HashString ¶ added in v1.3.0

func HashString(s string) string

func IsDeploymentHealthy ¶

func IsDeploymentHealthy(deployment *appsv1.Deployment) (bool, *metav1.Time)

IsDeploymentHealthy checks if a deployment is in the "Available" state

func NewDeploymentWithControllerRef ¶

func NewDeploymentWithControllerRef(
	w *temporaliov1alpha1.WorkerDeployment,
	buildID string,
	connection temporaliov1alpha1.ConnectionSpec,
	reconcilerScheme *runtime.Scheme,
) (*appsv1.Deployment, error)

func NewDeploymentWithOwnerRef ¶

func NewDeploymentWithOwnerRef(
	typeMeta *metav1.TypeMeta,
	objectMeta *metav1.ObjectMeta,
	spec *temporaliov1alpha1.WorkerDeploymentSpec,
	workerDeploymentName string,
	buildID string,
	connection temporaliov1alpha1.ConnectionSpec,
) *appsv1.Deployment

NewDeploymentWithOwnerRef creates a new deployment resource, including owner references

func NewObjectRef ¶

func NewObjectRef(obj client.Object) *corev1.ObjectReference

NewObjectRef creates a reference to a Kubernetes object

func RenderWorkerResourceTemplate ¶ added in v1.5.0

func RenderWorkerResourceTemplate(
	wrt *temporaliov1alpha1.WorkerResourceTemplate,
	deployment *appsv1.Deployment,
	buildID string,
	temporalNamespace string,
) (*unstructured.Unstructured, error)

RenderWorkerResourceTemplate produces the Unstructured object to apply via SSA for a given WorkerResourceTemplate and versioned Deployment.

Processing order:

1. Unmarshal spec.template into an Unstructured
2. Auto-inject scaleTargetRef and matchLabels (Layer 1)
3. Set metadata (name, namespace, labels, owner reference)

func TruncateString ¶ added in v1.0.0

func TruncateString(s string, n int) string

TruncateString truncates string to the first n characters. Pass n = -1 to skip truncation.

func WorkerResourceTemplateVersionStatusForBuildID ¶ added in v1.5.0

func WorkerResourceTemplateVersionStatusForBuildID(buildID, resourceName string, generation int64, hash, applyError string) temporaliov1alpha1.WorkerResourceTemplateVersionStatus

WorkerResourceTemplateVersionStatusForBuildID builds a per-Build-ID status entry. generation is the WRT metadata.generation at the time of the apply; pass 0 on error to preserve the last-known-good generation. hash is the controller-internal rendered-object hash used for the SSA skip optimisation (pass "" on error).