Method ViewQueryWithStats

db/query.go:403–425

ViewQueryWithStats is a wrapper for gocbBucket.Query that performs additional diagnostic processing (expvars, slow query logging)

(ctx context.Context, dataStore base.DataStore, ddoc string, viewName string, params map[string]interface{})

// ViewQueryWithStats is a wrapper for gocbBucket.Query that performs additional diagnostic processing (expvars, slow query logging)
func (context *DatabaseContext) ViewQueryWithStats(ctx context.Context, dataStore base.DataStore, ddoc string, viewName string, params map[string]interface{}) (results sgbucket.QueryResultIterator, err error) {

	startTime := time.Now()
	if threshold := context.Options.SlowQueryWarningThreshold; threshold > 0 {
		defer base.SlowQueryLog(ctx, startTime, threshold, "View Query (%s.%s)", ddoc, viewName)
	}

	queryStat := context.DbStats.Query(fmt.Sprintf(base.StatViewFormat, ddoc, viewName))

	viewStore, ok := base.AsViewStore(dataStore)
	if !ok {
		return results, fmt.Errorf("Datastore does not support views")
	}

	results, err = viewStore.ViewQuery(ctx, ddoc, viewName, params)
	if err != nil {
		queryStat.QueryErrorCount.Add(1)
	}
	queryStat.QueryCount.Add(1)
	queryStat.QueryTime.Add(time.Since(startTime).Nanoseconds())

	return results, err
}

// Query to compute the set of channels granted to the specified user via the Sync Function
func (c *DatabaseCollection) QueryAccess(ctx context.Context, username string) (sgbucket.QueryResultIterator, error) {