Skip to content

Commit b005563

Browse files
committed
Move querier to separate package
1 parent e91329e commit b005563

File tree

4 files changed

+9
-7
lines changed

4 files changed

+9
-7
lines changed

cmd/cortex/main.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ import (
3434
"github.com/weaveworks/cortex"
3535
"github.com/weaveworks/cortex/chunk"
3636
"github.com/weaveworks/cortex/ingester"
37+
"github.com/weaveworks/cortex/querier"
3738
"github.com/weaveworks/cortex/ring"
3839
"github.com/weaveworks/cortex/ui"
3940
"github.com/weaveworks/cortex/user"
@@ -207,10 +208,10 @@ func setupQuerier(
207208
prefix string,
208209
logSuccess bool,
209210
) {
210-
querier := cortex.MergeQuerier{
211-
Queriers: []cortex.Querier{
211+
querier := querier.MergeQuerier{
212+
Queriers: []querier.Querier{
212213
distributor,
213-
&cortex.ChunkQuerier{
214+
&querier.ChunkQuerier{
214215
Store: chunkStore,
215216
},
216217
},

iterator.go renamed to querier/iterator.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
// See the License for the specific language governing permissions and
1212
// limitations under the License.
1313

14-
package cortex
14+
package querier
1515

1616
import (
1717
"sort"

querier.go renamed to querier/querier.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
// See the License for the specific language governing permissions and
1212
// limitations under the License.
1313

14-
package cortex
14+
package querier
1515

1616
import (
1717
"fmt"

server.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ import (
2929
"golang.org/x/net/context"
3030

3131
"github.com/weaveworks/cortex/ingester"
32+
"github.com/weaveworks/cortex/querier"
3233
"github.com/weaveworks/cortex/user"
3334
)
3435

@@ -151,7 +152,7 @@ func AppenderHandler(appender SampleAppender) http.Handler {
151152

152153
// QueryHandler returns a http.Handler that accepts protobuf formatted
153154
// query requests and serves them.
154-
func QueryHandler(querier Querier) http.Handler {
155+
func QueryHandler(querier querier.Querier) http.Handler {
155156
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
156157
req := &ReadRequest{}
157158
ctx, abort := parseRequest(w, r, req)
@@ -217,7 +218,7 @@ func QueryHandler(querier Querier) http.Handler {
217218
}
218219

219220
// LabelValuesHandler handles label values
220-
func LabelValuesHandler(querier Querier) http.Handler {
221+
func LabelValuesHandler(querier querier.Querier) http.Handler {
221222
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
222223
req := &LabelValuesRequest{}
223224
ctx, abort := parseRequest(w, r, req)

0 commit comments

Comments
 (0)