(docid string)
| 601 | } |
| 602 | |
| 603 | func (rt *RestTester) SequenceForDoc(docid string) (seq uint64, err error) { |
| 604 | collection, ctx := rt.GetSingleTestDatabaseCollection() |
| 605 | doc, err := collection.GetDocument(ctx, docid, db.DocUnmarshalAll) |
| 606 | if err != nil { |
| 607 | return 0, err |
| 608 | } |
| 609 | return doc.Sequence, nil |
| 610 | } |
| 611 | |
| 612 | // Wait for sequence to be buffered by the channel cache |
| 613 | func (rt *RestTester) WaitForSequence(seq uint64) { |