deletion

Documentation

Index

• Variables
• func ProcessK8sSecretDeleteQueue()
• func ProcessSecretDeleteQueue()

Variables

var K8sSecretDeleteQueue = make(chan entity.SecretStored, env.K8sSecretDeleteBufferSizeForSafe())

K8sSecretDeleteQueue contains k8s `Secret`s to be removed.

var SecretDeleteQueue = make(chan entity.SecretStored, env.SecretDeleteBufferSizeForSafe())

SecretDeleteQueue 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.

Functions

func ProcessK8sSecretDeleteQueue

func ProcessK8sSecretDeleteQueue()

ProcessK8sSecretDeleteQueue manages the deletion of Kubernetes secrets that have been marked for deletion and placed in a queue. This operation is controlled by an environment configuration that determines whether the deletion of linked K8s secrets is permitted. The function employs goroutines for concurrent deletion tasks and asynchronous error reporting, aiming to optimize the deletion process and handle potential errors effectively.

func ProcessSecretDeleteQueue

func ProcessSecretDeleteQueue()

ProcessSecretDeleteQueue continuously processes a queue of secrets scheduled for deletion, removing each secret from disk. This function plays a crucial role in the secure management of secrets by ensuring that outdated or unnecessary secrets are not left stored, potentially posing a security risk.

It operates in an endless loop, monitoring a global queue of secrets to be deleted.