Skip to content

Commit 397f2e8

Browse files
committed
Add cortex otlp converter
Signed-off-by: SungJin1212 <[email protected]>
1 parent 4cc3e14 commit 397f2e8

File tree

9 files changed

+1697
-146
lines changed

9 files changed

+1697
-146
lines changed
Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
package cortexotlpconverter
2+
3+
import "context"
4+
5+
// everyNTimes supports checking for context error every n times.
6+
type everyNTimes struct {
7+
n int
8+
i int
9+
err error
10+
}
11+
12+
// checkContext calls ctx.Err() every e.n times and returns an eventual error.
13+
func (e *everyNTimes) checkContext(ctx context.Context) error {
14+
if e.err != nil {
15+
return e.err
16+
}
17+
18+
e.i++
19+
if e.i >= e.n {
20+
e.i = 0
21+
e.err = ctx.Err()
22+
}
23+
24+
return e.err
25+
}

0 commit comments

Comments
 (0)