| 26 | } |
| 27 | |
| 28 | func (m *MockDistributor) QueryExemplars(ctx context.Context, from, to model.Time, matchers ...[]*labels.Matcher) (*client.ExemplarQueryResponse, error) { |
| 29 | args := m.Called(ctx, from, to, matchers) |
| 30 | return args.Get(0).(*client.ExemplarQueryResponse), args.Error(1) |
| 31 | } |
| 32 | func (m *MockDistributor) QueryStream(ctx context.Context, from, to model.Time, partialDataEnabled bool, matchers ...*labels.Matcher) (*client.QueryStreamResponse, error) { |
| 33 | args := m.Called(ctx, from, to, matchers) |
| 34 | return args.Get(0).(*client.QueryStreamResponse), args.Error(1) |