kubernetes/staging/src/k8s.io/apiserver/pkg/server/options/audit.go

const defaultBatchBufferSize …

const defaultBatchMaxSize …

const defaultBatchMaxWait …

const defaultBatchThrottleQPS …

const defaultBatchThrottleBurst …

func appendBackend(existing, newBackend audit.Backend) audit.Backend { … }

type AuditOptions …

const ModeBatch …

const ModeBlocking …

const ModeBlockingStrict …

var AllowedModes …

type AuditBatchOptions …

type AuditTruncateOptions …

type AuditLogOptions …

type AuditWebhookOptions …

func NewAuditOptions() *AuditOptions { … }

func NewAuditTruncateOptions() AuditTruncateOptions { … }

// Validate checks invalid config combination
func (o *AuditOptions) Validate() []error { … }

func validateBackendMode(pluginName string, mode string) error { … }

func validateBackendBatchOptions(pluginName string, options AuditBatchOptions) error { … }

var knownGroupVersions …

func validateGroupVersionString(groupVersion string) error { … }

func knownGroupVersion(gv schema.GroupVersion) bool { … }

func (o *AuditOptions) AddFlags(fs *pflag.FlagSet) { … }

func (o *AuditOptions) ApplyTo(
	c *server.Config,
) error { … }

func (o *AuditOptions) newPolicyRuleEvaluator() (audit.PolicyRuleEvaluator, error) { … }

func (o *AuditBatchOptions) AddFlags(pluginName string, fs *pflag.FlagSet) { … }

type ignoreErrorsBackend …

func (i *ignoreErrorsBackend) ProcessEvents(ev ...*auditinternal.Event) bool { … }

func (i *ignoreErrorsBackend) String() string { … }

func (o *AuditBatchOptions) wrapBackend(delegate audit.Backend) audit.Backend { … }

func (o *AuditTruncateOptions) Validate(pluginName string) error { … }

func (o *AuditTruncateOptions) AddFlags(pluginName string, fs *pflag.FlagSet) { … }

func (o *AuditTruncateOptions) wrapBackend(delegate audit.Backend, gv schema.GroupVersion) audit.Backend { … }

func (o *AuditLogOptions) AddFlags(fs *pflag.FlagSet) { … }

func (o *AuditLogOptions) Validate() []error { … }

// Check whether the log backend is enabled based on the options.
func (o *AuditLogOptions) enabled() bool { … }

func (o *AuditLogOptions) getWriter() (io.Writer, error) { … }

func (o *AuditLogOptions) ensureLogFile() error { … }

func (o *AuditLogOptions) newBackend(w io.Writer) audit.Backend { … }

func (o *AuditWebhookOptions) AddFlags(fs *pflag.FlagSet) { … }

func (o *AuditWebhookOptions) Validate() []error { … }

func (o *AuditWebhookOptions) enabled() bool { … }

// newUntruncatedBackend returns a webhook backend without the truncate options applied
// this is done so that the same trucate backend can wrap both the webhook and dynamic backends
func (o *AuditWebhookOptions) newUntruncatedBackend(customDial utilnet.DialFunc) (audit.Backend, error) { … }

// defaultWebhookBatchConfig returns the default BatchConfig used by the Webhook backend.
func defaultWebhookBatchConfig() pluginbuffered.BatchConfig { … }

// defaultLogBatchConfig returns the default BatchConfig used by the Log backend.
func defaultLogBatchConfig() pluginbuffered.BatchConfig { … }