Method QueryTombstones

db/query.go:741–768

(ctx context.Context, olderThan time.Time, limit int)

}

func (c *DatabaseCollection) QueryTombstones(ctx context.Context, olderThan time.Time, limit int) (sgbucket.QueryResultIterator, error) {

	// View Query
	if c.useViews() {
		opts := Body{
			"stale":            false,
			QueryParamStartKey: 1,
			QueryParamEndKey:   olderThan.Unix(),
		}
		if limit != 0 {
			opts[QueryParamLimit] = limit
		}
		return c.dbCtx.ViewQueryWithStats(ctx, c.dataStore, DesignDocSyncHousekeeping(), ViewTombstones, opts)
	}

	// N1QL Query
	tombstoneQueryStatement := replaceSyncTokensQuery(QueryTombstones.statement, c.UseXattrs())
	tombstoneQueryStatement = replaceIndexTokensQuery(tombstoneQueryStatement, sgIndexes[IndexTombstones], c.UseXattrs(), c.numIndexPartitions())
	if limit != 0 {
		tombstoneQueryStatement = fmt.Sprintf("%s LIMIT %d", tombstoneQueryStatement, limit)
	}

	params := map[string]interface{}{
		QueryParamOlderThan: olderThan.Unix(),
	}

	return N1QLQueryWithStats(ctx, c.dataStore, QueryTypeTombstones, tombstoneQueryStatement, params, base.RequestPlus, QueryTombstones.adhoc, c.dbStats(), c.slowQueryWarningThreshold())
}

func changesViewOptions(channelName string, startSeq, endSeq uint64, limit int) map[string]interface{} {
	endKey := []interface{}{channelName, endSeq}