inject

Documentation

Index

• type Config
  • func (cfg *Config) BindFlags(fs *pflag.FlagSet)
• type PodReadinessGate
  • func NewPodReadinessGate(config Config, k8sClient client.Client, logger logr.Logger) *PodReadinessGate
  • func (m *PodReadinessGate) Mutate(ctx context.Context, pod *corev1.Pod) error

Types

type Config

type Config struct {
	EnablePodReadinessGateInject bool
}

func (*Config) BindFlags

func (cfg *Config) BindFlags(fs *pflag.FlagSet)

type PodReadinessGate

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

PodReadinessGate is a pod mutator that adds targetHealth readiness gates to pods matching the target group bindings

func NewPodReadinessGate

func NewPodReadinessGate(config Config, k8sClient client.Client, logger logr.Logger) *PodReadinessGate

NewPodReadinessGate constructs new PodReadinessGate

func (*PodReadinessGate) Mutate

func (m *PodReadinessGate) Mutate(ctx context.Context, pod *corev1.Pod) error

Mutate adds the targetHealth readiness gates to the pod if there are target group bindings on the same namespace as the pod and referring to existing services matching the pod labels