webhook

Documentation

Index

• Constants
• func GenerateCertificates(ctx context.Context, mgr manager.Manager, ...) ([]byte, error)
• type Webhook
  • func NewDefaultWebhook() (*Webhook, error)
  • func NewWebhook() *Webhook
  • func NewWebhookWithProcessorFactories(pfs []processorFactory) (*Webhook, error)
  • func (w *Webhook) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (w *Webhook) InjectAPIReader(r client.Reader) error
  • func (w *Webhook) InjectCache(c cache.Cache) error
  • func (w *Webhook) InjectDecoder(d *admission.Decoder) error
  • func (w *Webhook) SetupWithManager(mgr ctrl.Manager) error
  • func (w *Webhook) Start(ctx context.Context) error

Constants

const (
	// ModeService is a constant for the webhook mode indicating that the controller is running inside of the Kubernetes cluster it
	// is serving.
	ModeService = "service"
	// ModeURL is a constant for the webhook mode indicating that the controller is running outside of the Kubernetes cluster it
	// is serving. If this is set then a URL is required for configuration.
	ModeURL = "url"
	// ModeURLWithServiceName is a constant for the webhook mode indicating that the controller is running outside of the Kubernetes cluster it
	// is serving but in the same cluster like the kube-apiserver. If this is set then a URL is required for configuration.
	ModeURLWithServiceName = "url-service"
)

const WebhookPath = "/webhook"

WebhookPath is the path under which the webhook will be registered.

Functions

func GenerateCertificates

func GenerateCertificates(ctx context.Context, mgr manager.Manager, certDir, namespace, name, mode, url string) ([]byte, error)

GenerateCertificates generates the certificates that are required for a webhook. It returns the ca bundle, and it stores the server certificate and key locally on the file system.

Types

type Webhook

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

Webhook is the implementation for all the webhooks required for kupid.

func NewDefaultWebhook

func NewDefaultWebhook() (*Webhook, error)

NewDefaultWebhook creates a Webhook instance with the default eet of processor factories registered.

func NewWebhook

func NewWebhook() *Webhook

NewWebhook creates a bare Webhook instance.

func NewWebhookWithProcessorFactories

func NewWebhookWithProcessorFactories(pfs []processorFactory) (*Webhook, error)

NewWebhookWithProcessorFactories creates a Webhook instance with the supplied processor factories registered.

func (*Webhook) Handle

func (w *Webhook) Handle(ctx context.Context, req admission.Request) admission.Response

Handle handles admission requests.

func (*Webhook) InjectAPIReader

func (w *Webhook) InjectAPIReader(r client.Reader) error

InjectAPIReader injects a direct client.Reader into the webhook.

func (*Webhook) InjectCache

func (w *Webhook) InjectCache(c cache.Cache) error

InjectCache injects a cache into the webhook.

func (*Webhook) InjectDecoder

func (w *Webhook) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder into a webhook.

func (*Webhook) SetupWithManager

func (w *Webhook) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the webhook to inject applicable podschedulingpolicies and clusterpodschedulingpolicies.

func (*Webhook) Start

func (w *Webhook) Start(ctx context.Context) error

Start initializes the cache. The component will stop running when the channel is closed. Start blocks until the channel is closed or an error occurs.