Function NewController

workers/entity/controller.go:34–48

(ctx context.Context, store dbCommon.Store, providers map[string]common.Provider)

const retryLoopInterval = 5 * time.Second

func NewController(ctx context.Context, store dbCommon.Store, providers map[string]common.Provider) (*Controller, error) {
	consumerID := "entity-controller"
	ctx = garmUtil.WithSlogContext(
		ctx,
		slog.Any("worker", consumerID))
	ctx = auth.GetAdminContext(ctx)

	return &Controller{
		consumerID: consumerID,
		ctx:        ctx,
		store:      store,
		providers:  providers,
		backoff:    workersCommon.NewBackoff(workersCommon.DefaultBackoffConfig()),
	}, nil
}

type Controller struct {
	consumerID string