INNER CODE UNIT · Go

createReconcilerWithDB

theopenlane/core · cmd/catalog/reconcile/main.go:165

func createReconcilerWithDB(c *cli.Command) (*reconciler.Reconciler, error) {
	cfgLoc := c.Root().String("config")
	cfg, err := config.Load(&cfgLoc)
	if err != nil {
		return nil, fmt.Errorf("load config: %w", err)
	}

	// Validate job queue config
	if cfg.JobQueue.ConnectionURI == "" {
		return nil, fmt.Errorf("missing required job queue connection URI in config")
	}

	// Create database client
	jobOpts := []riverqueue.Option{
		riverqueue.WithConnectionURI(cfg.JobQueue.ConnectionURI),
	}

	// Create basic context for database client creation

View source record →