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

var infiniteTimeCh …

func newEvents(number int) []*auditinternal.Event { … }

func testBatchConfig() BatchConfig { … }

func TestBatchedBackendCollectEvents(t *testing.T) { … }

func TestUnbatchedBackendCollectEvents(t *testing.T) { … }

func TestBufferedBackendProcessEventsAfterStop(t *testing.T) { … }

func TestBufferedBackendProcessEventsBufferFull(t *testing.T) { … }

func TestBufferedBackendShutdownWaitsForDelegatedCalls(t *testing.T) { … }

func TestDelegateProcessEvents(t *testing.T) { … }