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 {}