Skip to content

Commit d54cc11

Browse files
authored
unify query frontend instant and range protos (#6180)
Signed-off-by: Ben Ye <[email protected]>
1 parent dd03653 commit d54cc11

24 files changed

+4603
-7001
lines changed

pkg/querier/tripperware/custom.go

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
package tripperware
2+
3+
import (
4+
"fmt"
5+
6+
"github.com/gogo/protobuf/types"
7+
)
8+
9+
func (e *Extent) ToResponse() (Response, error) {
10+
msg, err := types.EmptyAny(e.Response)
11+
if err != nil {
12+
return nil, err
13+
}
14+
15+
if err := types.UnmarshalAny(e.Response, msg); err != nil {
16+
return nil, err
17+
}
18+
19+
resp, ok := msg.(Response)
20+
if !ok {
21+
return nil, fmt.Errorf("bad cached type")
22+
}
23+
return resp, nil
24+
}
25+
26+
func (m *Sample) GetTimestampMs() int64 {
27+
if m != nil {
28+
if m.Sample != nil {
29+
return m.Sample.TimestampMs
30+
} else if m.Histogram != nil {
31+
return m.Histogram.TimestampMs
32+
}
33+
}
34+
return 0
35+
}

pkg/querier/tripperware/instantquery/custom.go

Lines changed: 0 additions & 12 deletions
This file was deleted.

0 commit comments

Comments
 (0)