resolver

Documentation

Index

• func ResolveAuthRefAndPodIdentity(ctx context.Context, client client.Client, logger logr.Logger, ...) (map[string]string, kedav1alpha1.AuthPodIdentity, error)
• func ResolveContainerEnv(ctx context.Context, client client.Client, logger logr.Logger, ...) (map[string]string, error)
• func ResolveScaleTargetPodSpec(ctx context.Context, kubeClient client.Client, logger logr.Logger, ...) (*corev1.PodTemplateSpec, string, error)
• type AzureKeyVaultHandler
  • func NewAzureKeyVaultHandler(v *kedav1alpha1.AzureKeyVault) *AzureKeyVaultHandler
  • func (vh *AzureKeyVaultHandler) Initialize(ctx context.Context, client client.Client, logger logr.Logger, ...) error
  • func (vh *AzureKeyVaultHandler) Read(ctx context.Context, secretName string, version string) (string, error)
• type HashicorpVaultHandler
  • func NewHashicorpVaultHandler(v *kedav1alpha1.HashiCorpVault) *HashicorpVaultHandler
  • func (vh *HashicorpVaultHandler) Initialize(logger logr.Logger) error
  • func (vh *HashicorpVaultHandler) Read(path string) (*vaultapi.Secret, error)
  • func (vh *HashicorpVaultHandler) Stop()

Functions

func ResolveAuthRefAndPodIdentity

func ResolveAuthRefAndPodIdentity(ctx context.Context, client client.Client, logger logr.Logger,
	triggerAuthRef *kedav1alpha1.ScaledObjectAuthRef, podTemplateSpec *corev1.PodTemplateSpec,
	namespace string, secretsLister corev1listers.SecretLister) (map[string]string, kedav1alpha1.AuthPodIdentity, error)

ResolveAuthRefAndPodIdentity provides authentication parameters and pod identity needed authenticate scaler with the environment.

func ResolveContainerEnv

func ResolveContainerEnv(ctx context.Context, client client.Client, logger logr.Logger, podSpec *corev1.PodSpec, containerName, namespace string, secretsLister corev1listers.SecretLister) (map[string]string, error)

ResolveContainerEnv resolves all environment variables in a container. It returns either map of env variable key and value or error if there is any.

func ResolveScaleTargetPodSpec

func ResolveScaleTargetPodSpec(ctx context.Context, kubeClient client.Client, logger logr.Logger, scalableObject interface{}) (*corev1.PodTemplateSpec, string, error)

ResolveScaleTargetPodSpec for given scalableObject inspects the scale target workload, which could be almost any k8s resource (Deployment, StatefulSet, CustomResource...) and for the given resource returns *corev1.PodTemplateSpec and a name of the container which is being used for referencing environment variables

Types

type AzureKeyVaultHandler

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

func NewAzureKeyVaultHandler

func NewAzureKeyVaultHandler(v *kedav1alpha1.AzureKeyVault) *AzureKeyVaultHandler

func (*AzureKeyVaultHandler) Initialize

func (vh *AzureKeyVaultHandler) Initialize(ctx context.Context, client client.Client, logger logr.Logger, triggerNamespace string, secretsLister corev1listers.SecretLister) error

func (*AzureKeyVaultHandler) Read

func (vh *AzureKeyVaultHandler) Read(ctx context.Context, secretName string, version string) (string, error)

type HashicorpVaultHandler

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

HashicorpVaultHandler is specification of Hashi Corp Vault

func NewHashicorpVaultHandler

func NewHashicorpVaultHandler(v *kedav1alpha1.HashiCorpVault) *HashicorpVaultHandler

NewHashicorpVaultHandler creates a HashicorpVaultHandler object

func (*HashicorpVaultHandler) Initialize

func (vh *HashicorpVaultHandler) Initialize(logger logr.Logger) error

Initialize the Vault client

func (*HashicorpVaultHandler) Read

func (vh *HashicorpVaultHandler) Read(path string) (*vaultapi.Secret, error)

func (*HashicorpVaultHandler) Stop

func (vh *HashicorpVaultHandler) Stop()

Stop is responsible for stoping the renew token process