webhook

Documentation

Index

• func GenCacheKey(kind, name, namespace string) string
• type ScaleMutatingHandler
  • func NewScaleMutatingHandler() (h *ScaleMutatingHandler, err error)
  • func (h *ScaleMutatingHandler) Close()
  • func (h *ScaleMutatingHandler) Handle(ctx context.Context, req kubeadmission.Request) kubeadmission.Response
  • func (h *ScaleMutatingHandler) Sync()
• type WebhookResourceCacheItem
  • func (w *WebhookResourceCacheItem) String() string

Functions

func GenCacheKey

func GenCacheKey(kind, name, namespace string) string

Types

type ScaleMutatingHandler

type ScaleMutatingHandler struct {
	Client runtimeclient.Client

	// Decoder decodes objects
	Decoder *kubeadmission.Decoder

	// cache for the resource
	CacheResource *sync.Map

	Ctx context.Context
	// contains filtered or unexported fields
}

MutatingHandler handles Component

func NewScaleMutatingHandler

func NewScaleMutatingHandler() (h *ScaleMutatingHandler, err error)

func (*ScaleMutatingHandler) Close

func (h *ScaleMutatingHandler) Close()

func (*ScaleMutatingHandler) Handle

func (h *ScaleMutatingHandler) Handle(ctx context.Context, req kubeadmission.Request) kubeadmission.Response

Handle handles admission requests.

func (*ScaleMutatingHandler) Sync

func (h *ScaleMutatingHandler) Sync()

type WebhookResourceCacheItem

type WebhookResourceCacheItem struct {
	Name                 string
	SimpleAutoScalerName string
	Resources            autoscalev1alpha1.SimpleAutoScalerResources
}

resource cache is use to filter requests

func (*WebhookResourceCacheItem) String

func (w *WebhookResourceCacheItem) String() string