(ctx context.Context, vbID uint16, seqNo gocbcore.SeqNo)
| 489 | } |
| 490 | |
| 491 | func (dc *DCPClient) rollback(ctx context.Context, vbID uint16, seqNo gocbcore.SeqNo) { |
| 492 | if dc.dbStats != nil { |
| 493 | dc.dbStats.Add("dcp_rollback_count", 1) |
| 494 | } |
| 495 | dc.metadata.Rollback(ctx, vbID, seqNo) |
| 496 | } |
| 497 | |
| 498 | // openStreamRequest issues the OpenStream request, but doesn't perform any error handling. Callers |
| 499 | // should generally use openStream() for error and retry handling |
no test coverage detected