From 96c841cd41df220491c69ac65339a72741d55d75 Mon Sep 17 00:00:00 2001 From: Srikanth Chekuri Date: Thu, 3 Aug 2023 14:34:27 +0530 Subject: [PATCH] more conflicts --- signozcol/collector.go | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/signozcol/collector.go b/signozcol/collector.go index 2c9502a6..a9dbb299 100644 --- a/signozcol/collector.go +++ b/signozcol/collector.go @@ -31,7 +31,7 @@ type WrappedCollector struct { wg sync.WaitGroup errChan chan error mux sync.Mutex - svc *service.Collector + svc *otelcol.Collector logger *zap.Logger PollInterval time.Duration } @@ -45,7 +45,7 @@ type WrappedCollectorSettings struct { Logger *zap.Logger } -var StateUknown = service.State(-1) +var StateUknown = otelcol.State(-1) // New returns a new collector. func New(settings WrappedCollectorSettings) *WrappedCollector { @@ -116,12 +116,8 @@ func (wCol *WrappedCollector) Run(ctx context.Context) error { go func() { for { state := svc.GetState() -<<<<<<< HEAD - if state == service.StateRunning { - wCol.logger.Info("Collector service is running") -======= if state == otelcol.StateRunning { ->>>>>>> glue-up + wCol.logger.Info("Collector service is running") // TODO: collector may panic or exit unexpectedly, need to handle that colErrorChannel <- nil break @@ -182,11 +178,7 @@ func (wCol *WrappedCollector) GetState() otelcol.State { if wCol.svc != nil { return wCol.svc.GetState() } -<<<<<<< HEAD return StateUknown -======= - return otelcol.StateClosed ->>>>>>> glue-up } func newOtelColSettings(configPaths []string, version string, desc string, loggingOpts []zap.Option) (*otelcol.CollectorSettings, error) {