resolver

Documentation

Index

• func ResolveAuthRefAndPodIdentity(client client.Client, logger logr.Logger, ...) (map[string]string, kedav1alpha1.PodIdentityProvider, error)
• func ResolveContainerEnv(client client.Client, logger logr.Logger, podSpec *corev1.PodSpec, ...) (map[string]string, error)
• func ResolveScaleTargetPodSpec(kubeClient client.Client, logger logr.Logger, scalableObject interface{}) (*corev1.PodTemplateSpec, 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(client client.Client, logger logr.Logger, triggerAuthRef *kedav1alpha1.ScaledObjectAuthRef, podTemplateSpec *corev1.PodTemplateSpec, namespace string) (map[string]string, kedav1alpha1.PodIdentityProvider, error)

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

func ResolveContainerEnv

func ResolveContainerEnv(client client.Client, logger logr.Logger, podSpec *corev1.PodSpec, containerName, namespace string) (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(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 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