mirror of
https://github.com/hanzoai/otel-collector.git
synced 2026-10-30 18:26:25 +00:00
zeekay
df7d6cb470
- Go module: github.com/SigNoz/signoz-otel-collector → github.com/hanzoai/otel-collector - All signoz-prefixed packages → o11y-prefixed - Docker: signoz/* → ghcr.io/hanzoai/otel-collector - ClickHouse exporter → Hanzo Datastore - Env vars: SIGNOZ_* → HANZO_* - Directory renames for all processor/receiver/exporter packages
41 lines
797 B
Go
41 lines
797 B
Go
package opamp
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/hanzoai/otel-collector/o11ycol"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
type simpleClient struct {
|
|
baseClient
|
|
}
|
|
|
|
func NewSimpleClient(coll *o11ycol.WrappedCollector, logger *zap.Logger) *simpleClient {
|
|
return &simpleClient{
|
|
baseClient: baseClient{
|
|
coll: coll,
|
|
err: make(chan error),
|
|
stopped: make(chan bool),
|
|
logger: logger.With(zap.String("component", "simple-client")),
|
|
},
|
|
}
|
|
}
|
|
|
|
func (c *simpleClient) Start(ctx context.Context) error {
|
|
c.logger.Info("Starting simple client")
|
|
err := c.coll.Run(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
go c.ensureRunning()
|
|
return nil
|
|
}
|
|
|
|
func (c *simpleClient) Stop(ctx context.Context) error {
|
|
c.logger.Info("Stopping simple client")
|
|
close(c.stopped)
|
|
c.coll.Shutdown()
|
|
return <-c.coll.ErrorChan()
|
|
}
|