Skip to content

Commit df4e82e

Browse files
committed
update otel chart image
1 parent a68d55b commit df4e82e

3 files changed

Lines changed: 10 additions & 3 deletions

File tree

charts/tinysystems-otel-collector/Chart.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,5 +2,5 @@ apiVersion: v2
22
name: tinysystems-otel-collector
33
description: A minimalistic Helm chart for OpenTelemetry Collector
44
type: application
5-
version: 0.1.0
5+
version: 0.1.1
66
appVersion: "1.0"

charts/tinysystems-otel-collector/values.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ replicaCount: 1
33
image:
44
repository: ghcr.io/tiny-systems/otel-collector
55
pullPolicy: Always
6-
tag: "main"
6+
tag: "0.5.0"
77

88
imagePullSecrets: []
99
nameOverride: ""

internal/scheduler/runner/runner.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -359,9 +359,12 @@ func (c *Runner) MsgHandler(ctx context.Context, msg *Msg, msgHandler Handler) (
359359
err = errorpanic.Wrap(func() error {
360360
// panic safe
361361

362-
ticker := time.NewTicker(time.Second * 2)
362+
ticker := time.NewTicker(time.Second * 3)
363363
defer ticker.Stop()
364364

365+
// send right away
366+
c.setGauge(time.Now().Unix(), msg.EdgeID, metrics.MetricEdgeBusy)
367+
365368
go func() {
366369
for {
367370
select {
@@ -542,6 +545,10 @@ func (c *Runner) outputHandler(ctx context.Context, port string, data interface{
542545
if er != nil {
543546
return er
544547
}
548+
if res == nil {
549+
// don't care about nil responses
550+
return nil
551+
}
545552

546553
resLock.Lock()
547554
defer resLock.Unlock()

0 commit comments

Comments
 (0)