server

Documentation

Index

• Variables
• func IndexReceiverWebhookPath(o client.Object) []string
• type EventServer
  • func NewEventServer(port string, logger logr.Logger, kubeClient client.Client, ...) *EventServer
  • func (s *EventServer) ListenAndServe(stopCh <-chan struct{}, mdlw middleware.Middleware, store limiter.Store)
• type ReceiverServer
  • func NewReceiverServer(port string, logger logr.Logger, kubeClient client.Client) *ReceiverServer
  • func (s *ReceiverServer) ListenAndServe(stopCh <-chan struct{}, mdlw middleware.Middleware)

Variables

var (
	WebhookPathIndexKey = ".metadata.webhookPath"
)

Functions

func IndexReceiverWebhookPath

func IndexReceiverWebhookPath(o client.Object) []string

IndexReceiverWebhookPath is a client.IndexerFunc that returns the Receiver's webhook path, if present in its status.

Types

type EventServer

type EventServer struct {
	kuberecorder.EventRecorder
	// contains filtered or unexported fields
}

EventServer handles event POST requests

func NewEventServer

func NewEventServer(port string, logger logr.Logger, kubeClient client.Client, eventRecorder kuberecorder.EventRecorder, noCrossNamespaceRefs bool) *EventServer

NewEventServer returns an HTTP server that handles events

func (*EventServer) ListenAndServe

func (s *EventServer) ListenAndServe(stopCh <-chan struct{}, mdlw middleware.Middleware, store limiter.Store)

ListenAndServe starts the HTTP server on the specified port

type ReceiverServer

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

ReceiverServer handles webhook POST requests

func NewReceiverServer

func NewReceiverServer(port string, logger logr.Logger, kubeClient client.Client) *ReceiverServer

NewReceiverServer returns an HTTP server that handles webhooks

func (*ReceiverServer) ListenAndServe

func (s *ReceiverServer) ListenAndServe(stopCh <-chan struct{}, mdlw middleware.Middleware)

ListenAndServe starts the HTTP server on the specified port