Function commitTransaction

worker/worker_test.go:44–57

(t *testing.T, edge *pb.DirectedEdge, l *posting.List)

}

func commitTransaction(t *testing.T, edge *pb.DirectedEdge, l *posting.List) {
	startTs := timestamp()
	txn := posting.Oracle().RegisterStartTs(startTs)
	l = txn.Store(l)
	l.SetTs(startTs)
	require.NoError(t, l.AddMutationWithIndex(context.Background(), edge, txn))

	commit := commitTs(startTs)

	txn.Update()
	writer := posting.NewTxnWriter(pstore)
	require.NoError(t, txn.CommitToDisk(writer, commit))
	require.NoError(t, writer.Flush())
}

func timestamp() uint64 {
	return atomic.AddUint64(&ts, 1)