update debug log msg & internal pkg

uber-go · Aug 18, 2024 · 5d5ada1 · 5d5ada1
1 parent 2495592
commit 5d5ada1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/internal/debug/lifecycle.go b/internal/debug/lifecycle.go
@@ -47,6 +47,7 @@ type (
 		// PollerStart collects information on poller start up.
 		// consumers should provide a concurrency-safe implementation.
 		PollerStart(workerID string) Run
+		// ReadPollerCount return the number or running pollers
 		ReadPollerCount() int32
 	}
 
@@ -70,6 +71,7 @@ func (lc *lifeCycleImpl) ReadPollerCount() int32 {
 	return lc.pollerCount.Load()
 }
 
+// NewLifeCycle creates a new LifeCycle instance
 func NewLifeCycle() LifeCycle { return &lifeCycleImpl{} }
 
 var _ LifeCycle = &lifeCycleImpl{}

diff --git a/internal/internal_worker.go b/internal/internal_worker.go
@@ -191,7 +191,7 @@ func ensureRequiredParams(params *workerExecutionParameters) {
 	}
 	if params.EventMonitoring.LifeCycle == nil {
 		params.EventMonitoring.LifeCycle = debug.NewLifeCycle()
-		params.Logger.Debug("No PollerLifeCycle configured for cadence worker. Use default one.")
+		params.Logger.Debug("No LifeCycle configured for EventMonitoring option. Use default one.")
 	}
 }
 

diff --git a/internal/worker.go b/internal/worker.go
@@ -25,7 +25,7 @@ import (
 	"context"
 	"time"
 
-	"go.uber.org/cadence/debug"
+	"go.uber.org/cadence/internal/debug"
 
 	"github.com/opentracing/opentracing-go"
 	"github.com/uber-go/tally"