Method Start

internal/controller/runtime/ticker.go:42–72

Start is called by controller-runtime Controller and returns quickly. It cleans up when ctx is cancelled.

(
	ctx context.Context, q workqueue.TypedRateLimitingInterface[reconcile.Request],
)

// Start is called by controller-runtime Controller and returns quickly.
// It cleans up when ctx is cancelled.
func (t ticker) Start(
	ctx context.Context, q workqueue.TypedRateLimitingInterface[reconcile.Request],
) error {
	ticker := time.NewTicker(t.Duration)

	// Pass t.GenericEvent to h when it is not filtered out by p.
	// - https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg/source/internal#EventHandler
	emit := func() {
		t.Handler.Generic(ctx, t.GenericEvent, q)
	}

	if t.Immediate {
		emit()
	}

	// Repeat until ctx is cancelled.
	go func() {
		defer ticker.Stop()

		for {
			select {
			case <-ticker.C:
				emit()
			case <-ctx.Done():
				return
			}
		}
	}()

	return nil
}