Function newDistributorQueryable

pkg/querier/distributor_queryable.go:45–55

(distributor Distributor, streamingMetdata bool, labelNamesWithMatchers bool, iteratorFn chunkIteratorFunc, queryIngestersWithin time.Duration, isPartialDataEnabled partialdata.IsCfgEnabledFunc, ingesterQueryMaxAttempts int)

}

func newDistributorQueryable(distributor Distributor, streamingMetdata bool, labelNamesWithMatchers bool, iteratorFn chunkIteratorFunc, queryIngestersWithin time.Duration, isPartialDataEnabled partialdata.IsCfgEnabledFunc, ingesterQueryMaxAttempts int) QueryableWithFilter {
	return distributorQueryable{
		distributor:              distributor,
		streamingMetdata:         streamingMetdata,
		labelNamesWithMatchers:   labelNamesWithMatchers,
		iteratorFn:               iteratorFn,
		queryIngestersWithin:     queryIngestersWithin,
		isPartialDataEnabled:     isPartialDataEnabled,
		ingesterQueryMaxAttempts: ingesterQueryMaxAttempts,
	}
}

type distributorQueryable struct {
	distributor              Distributor