k8skeystore

Documentation

Index

• func Factoryk8s(keystoreNamespace string, ks8client k8s.Interface, logger *logp.Logger) (keystore.Keystore, error)
• func NewKubernetesKeystoresRegistry(logger *logp.Logger, client k8s.Interface) bus.KeystoreProvider
• func NewKubernetesSecretsKeystore(keystoreNamespace string, ks8client k8s.Interface, logger *logp.Logger) (keystore.Keystore, error)
• type KubernetesKeystoresRegistry
  • func (kr *KubernetesKeystoresRegistry) GetKeystore(event bus.Event) keystore.Keystore
• type KubernetesSecretsKeystore
  • func (k *KubernetesSecretsKeystore) GetConfig() (*config.C, error)
  • func (k *KubernetesSecretsKeystore) IsPersisted() bool
  • func (k *KubernetesSecretsKeystore) Retrieve(key string) (*keystore.SecureString, error)

Functions

func Factoryk8s

func Factoryk8s(keystoreNamespace string, ks8client k8s.Interface, logger *logp.Logger) (keystore.Keystore, error)

Factoryk8s Create the right keystore with the configured options

func NewKubernetesKeystoresRegistry

func NewKubernetesKeystoresRegistry(logger *logp.Logger, client k8s.Interface) bus.KeystoreProvider

NewKubernetesKeystoresRegistry initializes a KubernetesKeystoresRegistry

func NewKubernetesSecretsKeystore

func NewKubernetesSecretsKeystore(keystoreNamespace string, ks8client k8s.Interface, logger *logp.Logger) (keystore.Keystore, error)

NewKubernetesSecretsKeystore returns an new k8s Keystore

Types

type KubernetesKeystoresRegistry

type KubernetesKeystoresRegistry struct {
	// contains filtered or unexported fields
}

KubernetesKeystoresRegistry implements a Provider for Keystore.

func (*KubernetesKeystoresRegistry) GetKeystore

func (kr *KubernetesKeystoresRegistry) GetKeystore(event bus.Event) keystore.Keystore

GetKeystore return a KubernetesSecretsKeystore if it already exists for a given namespace or creates a new one.

type KubernetesSecretsKeystore

type KubernetesSecretsKeystore struct {
	// contains filtered or unexported fields
}

KubernetesSecretsKeystore allows to retrieve passwords from Kubernetes secrets for a given namespace

func (*KubernetesSecretsKeystore) GetConfig

func (k *KubernetesSecretsKeystore) GetConfig() (*config.C, error)

GetConfig returns config.C representation of the key / secret pair to be merged with other loaded configuration.

func (*KubernetesSecretsKeystore) IsPersisted

func (k *KubernetesSecretsKeystore) IsPersisted() bool

IsPersisted return if the keystore is physically persisted on disk.

func (*KubernetesSecretsKeystore) Retrieve

func (k *KubernetesSecretsKeystore) Retrieve(key string) (*keystore.SecureString, error)

Retrieve return a SecureString instance that will contains both the key and the secret.