kubernetes/staging/src/k8s.io/apiserver/plugin/pkg/audit/webhook/webhook.go

const PluginName …

const DefaultInitialBackoffDelay …

func init() { … }

// retryOnError enforces the webhook client to retry requests
// on error regardless of its nature.
// The default implementation considers a very limited set of
// 'retriable' errors, assuming correct use of HTTP codes by
// external webhooks.
// That may easily lead to dropped audit events. In fact, there is
// hardly any error that could be a justified reason NOT to retry
// sending audit events if there is even a slight chance that the
// receiving service gets back to normal at some point.
func retryOnError(err error) bool { … }

func loadWebhook(configFile string, groupVersion schema.GroupVersion, retryBackoff wait.Backoff, customDial utilnet.DialFunc) (*webhook.GenericWebhook, error) { … }

type backend …

// NewDynamicBackend returns an audit backend configured from a REST client that
// sends events over HTTP to an external service.
func NewDynamicBackend(rc *rest.RESTClient, retryBackoff wait.Backoff) audit.Backend { … }

// NewBackend returns an audit backend that sends events over HTTP to an external service.
func NewBackend(kubeConfigFile string, groupVersion schema.GroupVersion, retryBackoff wait.Backoff, customDial utilnet.DialFunc) (audit.Backend, error) { … }

func (b *backend) Run(stopCh <-chan struct{ … }

func (b *backend) Shutdown() { … }

func (b *backend) ProcessEvents(ev ...*auditinternal.Event) bool { … }

func (b *backend) processEvents(ev ...*auditinternal.Event) error { … }

func (b *backend) String() string { … }