(index, startTs uint64)
| 19 | ) |
| 20 | |
| 21 | func getEntryForMutation(index, startTs uint64) raftpb.Entry { |
| 22 | proposal := &pb.Proposal{Mutations: &pb.Mutations{StartTs: startTs}} |
| 23 | sz := proto.Size(proposal) |
| 24 | data := make([]byte, 8+sz) |
| 25 | x.Check2(x.MarshalToSizedBuffer(data[8:], proposal)) |
| 26 | data = data[:8+sz] |
| 27 | return raftpb.Entry{Index: index, Term: 1, Type: raftpb.EntryNormal, Data: data} |
| 28 | } |
| 29 | |
| 30 | func getEntryForCommit(index, startTs, commitTs uint64) raftpb.Entry { |
| 31 | delta := &pb.OracleDelta{} |
no test coverage detected