handler

Documentation

Index

• 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()
• type ScaleHandler
  • func NewScaleHandler(client client.Client, reconcilerScheme *runtime.Scheme) *ScaleHandler
  • func (h *ScaleHandler) GetDeploymentScalers(scaledObject *kedav1alpha1.ScaledObject) ([]scalers.Scaler, *appsv1.Deployment, error)
  • func (h *ScaleHandler) HandleScaleLoop(ctx context.Context, scaledObject *kedav1alpha1.ScaledObject)

Types

type HashicorpVaultHandler

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

func NewHashicorpVaultHandler

func NewHashicorpVaultHandler(v *kedav1alpha1.HashiCorpVault) *HashicorpVaultHandler

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 proccess

type ScaleHandler

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

ScaleHandler encapsulates the logic of calling the right scalers for each ScaledObject and making the final scale decision and operation

func NewScaleHandler

func NewScaleHandler(client client.Client, reconcilerScheme *runtime.Scheme) *ScaleHandler

NewScaleHandler creates a ScaleHandler object

func (*ScaleHandler) GetDeploymentScalers

func (h *ScaleHandler) GetDeploymentScalers(scaledObject *kedav1alpha1.ScaledObject) ([]scalers.Scaler, *appsv1.Deployment, error)

GetDeploymentScalers returns list of Scalers and Deployment for the specified ScaledObject

func (*ScaleHandler) HandleScaleLoop

func (h *ScaleHandler) HandleScaleLoop(ctx context.Context, scaledObject *kedav1alpha1.ScaledObject)

HandleScaleLoop blocks forever and checks the scaledObject based on its pollingInterval