forked from grafana/loki
/
tail.go
45 lines (37 loc) · 1.06 KB
/
tail.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package marshal
import (
"github.com/grafana/loki/pkg/loghttp"
legacy "github.com/grafana/loki/pkg/loghttp/legacy"
)
// NewTailResponse constructs a TailResponse from a legacy.TailResponse
func NewTailResponse(r legacy.TailResponse) (loghttp.TailResponse, error) {
var err error
ret := loghttp.TailResponse{
Streams: make([]loghttp.Stream, len(r.Streams)),
DroppedStreams: make([]loghttp.DroppedStream, len(r.DroppedEntries)),
}
for i, s := range r.Streams {
ret.Streams[i], err = NewStream(s)
if err != nil {
return loghttp.TailResponse{}, err
}
}
for i, d := range r.DroppedEntries {
ret.DroppedStreams[i], err = NewDroppedStream(&d)
if err != nil {
return loghttp.TailResponse{}, err
}
}
return ret, nil
}
// NewDroppedStream constructs a DroppedStream from a legacy.DroppedEntry
func NewDroppedStream(s *legacy.DroppedEntry) (loghttp.DroppedStream, error) {
l, err := NewLabelSet(s.Labels)
if err != nil {
return loghttp.DroppedStream{}, err
}
return loghttp.DroppedStream{
Timestamp: s.Timestamp,
Labels: l,
}, nil
}