Method ViewQuery

base/collection_view.go:249–255

(ctx context.Context, ddoc, name string, params map[string]interface{})

}

func (c *Collection) ViewQuery(ctx context.Context, ddoc, name string, params map[string]interface{}) (sgbucket.QueryResultIterator, error) {
	gocbViewResult, err := c.executeViewQuery(ctx, ddoc, name, params)
	if err != nil {
		return nil, err
	}
	return &gocbRawIterator{rawResult: gocbViewResult, concurrentQueryOpLimitChan: c.Bucket.queryOps}, nil
}

func (c *Collection) executeViewQuery(ctx context.Context, ddoc, name string, params map[string]interface{}) (*gocb.ViewResultRaw, error) {
	viewResult := sgbucket.ViewResult{}