kubernetes/staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact_test.go

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

// TestCompactConflict tests that two compactors (Let's use C1, C2) are trying to compact etcd cluster with the same
// logical time.
// - C1 compacts first. It will succeed.
// - C2 compacts after. It will fail. But it will get latest logical time, which should be larger by one.
func TestCompactConflict(t *testing.T) { … }