Function genProcessedForTest

db/active_replicator_checkpointer_test.go:33–43

(t testing.TB, seqs ...string)

}

func genProcessedForTest(t testing.TB, seqs ...string) map[SequenceID]struct{} {
	result := make(map[SequenceID]struct{}, len(seqs))
	for _, seq := range seqs {
		s, err := ParsePlainSequenceID(seq)
		if err != nil {
			t.Fatalf("Error parsing sequence %q for test setup: %v", seq, err)
		}
		result[s] = struct{}{}
	}
	return result
}

func TestCheckpointerSafeSeq(t *testing.T) {