insertion

Documentation

Index

• Variables
• func ProcessK8sSecretQueue()
• func ProcessSecretQueue(rootKeyTriplet []string)

Variables

var K8sSecretUpsertQueue = make(chan entity.SecretStored, env.K8sSecretBufferSizeForSafe())

K8sSecretUpsertQueue has the secrets to be synced with their Kubernetes `Secret` counterparts.

var SecretUpsertQueue = make(chan entity.SecretStored, env.SecretBufferSizeForSafe())

SecretUpsertQueue items are persisted to files. They are buffered, so that they can be written in the order they are queued and there are no concurrent writes to the same file at a time. An alternative approach would be to have a map of queues of `SecretsStored`s per file name but that feels like an overkill.

Functions

func ProcessK8sSecretQueue

func ProcessK8sSecretQueue()

ProcessK8sSecretQueue continuously processes a queue of Kubernetes secrets (K8sSecretUpsertQueue), attempting to persist each secret into the Kubernetes cluster, specifically into etcd as a Kubernetes Secret. The function employs asynchronous error handling and is designed to operate continuously within a dedicated goroutine.

func ProcessSecretQueue

func ProcessSecretQueue(rootKeyTriplet []string)

ProcessSecretQueue manages a continuous loop that processes secrets from the SecretUpsertQueue, persisting each secret to disk storage. This function is crucial for ensuring that changes to secrets are reliably stored, supporting both new secrets and updates to existing ones. The operations of this function is critical for maintaining the integrity and consistency of secret data within the system.