Function NewController

runtime/controller.go:134–167

NewController creates a new Controller

(ctx context.Context, rt *Runtime, instanceID string, logger *zap.Logger, ac *activity.Client)

// NewController creates a new Controller
func NewController(ctx context.Context, rt *Runtime, instanceID string, logger *zap.Logger, ac *activity.Client) (*Controller, error) {
	c := &Controller{
		Runtime:        rt,
		InstanceID:     instanceID,
		Logger:         logger,
		Activity:       ac,
		closedCh:       make(chan struct{}),
		reconcilers:    make(map[string]Reconciler),
		subscribers:    make(map[int]SubscribeCallback),
		idleWaits:      make(map[int]idleWait),
		queue:          make(map[string]*runtimev1.ResourceName),
		queueUpdatedCh: make(chan struct{}, 1),
		timeline:       schedule.New[string, *runtimev1.ResourceName](nameStr),
		invocations:    make(map[string]*invocation),
		completed:      make(chan *invocation),
	}

	cc, err := newCatalogCache(ctx, c, c.InstanceID)
	if err != nil {
		return nil, fmt.Errorf("failed to create catalog cache: %w", err)
	}
	c.catalog = cc

	// Initialize all reconcilers
	for kind, initializer := range ReconcilerInitializers {
		reconciler, err := initializer(ctx, c)
		if err != nil {
			return nil, fmt.Errorf("failed to initialize reconciler for %q: %w", kind, err)
		}
		c.reconcilers[kind] = reconciler
	}

	return c, nil
}

// Run starts and runs the controller's event loop.
// It returns when ctx is cancelled or an unrecoverable error occurs. Before returning, it closes the controller, so it must only be called once.