Method Run

internal/carrier/client.go:532–562

Run spawns c.numWorkers concurrent poll goroutines and blocks until ctx is canceled. Worker count scales with the number of configured endpoints so that adding more script URLs increases parallelism rather than spreading the same fixed pool thinner.

(ctx context.Context)

// adding more script URLs increases parallelism rather than spreading the same
// fixed pool thinner.
func (c *Client) Run(ctx context.Context) error {
	var wg sync.WaitGroup
	for i := 0; i < c.numWorkers; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			c.runWorker(ctx)
		}()
	}
	// Periodic stats line so an operator can spot trends without grepping.
	wg.Add(1)
	go func() {
		defer wg.Done()
		c.runStatsLoop(ctx)
	}()
	// Hourly fetch of each deployment's self-reported invocation count.
	// Logged in the next [stats] line as `script=N` next to the existing
	// client-side `today=N` so the user sees both perspectives.
	wg.Add(1)
	go func() {
		defer wg.Done()
		c.runScriptStatsLoop(ctx)
	}()
	wg.Add(1)
	go func() {
		defer wg.Done()
		c.runEndpointRecoveryLoop(ctx)
	}()
	wg.Wait()
	return ctx.Err()
}

func (c *Client) runWorker(ctx context.Context) {
	consecutiveIdle := 0