pod

Documentation

Index

• func NewWebhookPod(ctx context.Context, webhookCtx *katalystbase.GenericContext, ...) (kubewebhook.Webhook, webhookconsts.GenericStartFunc, error)
• type WebhookPod
  • func (wp *WebhookPod) Mutate(ctx context.Context, obj metav1.Object) (bool, error)
  • func (wp *WebhookPod) Run() bool
• type WebhookPodMutator
• type WebhookPodResourceMutator
  • func NewWebhookPodResourceMutator(ctx context.Context, vpaIndexer cache.Indexer, ...) *WebhookPodResourceMutator
  • func (r *WebhookPodResourceMutator) MutatePod(pod *core.Pod, namespace string) (mutated bool, err error)
• type WebhookPodSPDReferenceMutator
  • func NewWebhookPodSPDReferenceMutator(ctx context.Context, spdIndexer cache.Indexer, ...) *WebhookPodSPDReferenceMutator
  • func (s *WebhookPodSPDReferenceMutator) MutatePod(pod *core.Pod, namespace string) (mutated bool, err error)

Functions

func NewWebhookPod

func NewWebhookPod(
	ctx context.Context,
	webhookCtx *katalystbase.GenericContext,
	generic *webhookconfig.GenericWebhookConfiguration,
	_ *webhookconfig.WebhooksConfiguration,
) (kubewebhook.Webhook, webhookconsts.GenericStartFunc, error)

NewWebhookPod makes the webhook pf Pod

Types

type WebhookPod

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

WebhookPod is the implementation of Kubernetes Webhook any implementation should at least implement the interface of mutating.Mutator of validating.Validator

func (*WebhookPod) Mutate

func (wp *WebhookPod) Mutate(ctx context.Context, obj metav1.Object) (bool, error)

func (*WebhookPod) Run

func (wp *WebhookPod) Run() bool

type WebhookPodMutator

type WebhookPodMutator interface {
	MutatePod(pod *core.Pod, namespace string) (allowed bool, err error)
}

type WebhookPodResourceMutator

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

func NewWebhookPodResourceMutator

func NewWebhookPodResourceMutator(
	ctx context.Context,
	vpaIndexer cache.Indexer,
	vpaLister autoscalelister.KatalystVerticalPodAutoscalerLister,
	workloadLister map[schema.GroupVersionKind]cache.GenericLister,
) *WebhookPodResourceMutator

NewWebhookPodResourceMutator will mutate pod resource according to vpa

func (*WebhookPodResourceMutator) MutatePod

func (r *WebhookPodResourceMutator) MutatePod(pod *core.Pod, namespace string) (mutated bool, err error)

type WebhookPodSPDReferenceMutator

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

func NewWebhookPodSPDReferenceMutator

func NewWebhookPodSPDReferenceMutator(
	ctx context.Context,
	spdIndexer cache.Indexer,
	spdLister workloadlister.ServiceProfileDescriptorLister,
	workloadLister map[schema.GroupVersionKind]cache.GenericLister,
) *WebhookPodSPDReferenceMutator

NewWebhookPodSPDReferenceMutator will maintain spd reference annotations for pod

func (*WebhookPodSPDReferenceMutator) MutatePod

func (s *WebhookPodSPDReferenceMutator) MutatePod(pod *core.Pod, namespace string) (mutated bool, err error)