Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Manager

type Manager interface {
	// Get secret by secret namespace and name.
	GetSecret(namespace, name string) (*v1.Secret, error)

	// RegisterPod registers all secrets from a given pod.
	RegisterPod(pod *v1.Pod)

	// UnregisterPod unregisters secrets from a given pod that are not
	// used by any other registered pod.
	UnregisterPod(pod *v1.Pod)
}

func NewCachingSecretManager

func NewCachingSecretManager(kubeClient clientset.Interface, getTTL manager.GetObjectTTLFunc) Manager

    NewCachingSecretManager creates a manager that keeps a cache of all secrets necessary for registered pods. It implements the following logic: - whenever a pod is created or updated, the cached versions of all secrets

    are invalidated
    

    - every GetObject() call tries to fetch the value from local cache; if it is

    not there, invalidated or too old, we fetch it from apiserver and refresh the
    value in cache; otherwise it is just fetched from cache
    

    func NewFakeManager

    func NewFakeManager() Manager

    func NewSimpleSecretManager

    func NewSimpleSecretManager(kubeClient clientset.Interface) Manager

    func NewWatchingSecretManager

    func NewWatchingSecretManager(kubeClient clientset.Interface) Manager

      NewWatchingSecretManager creates a manager that keeps a cache of all secrets necessary for registered pods. It implements the following logic: - whenever a pod is created or updated, we start inidvidual watches for all

      referenced objects that aren't referenced from other registered pods
      

      - every GetObject() returns a value from local cache propagated via watches