app

type App struct {
	// Name is the cobra command name (e.g. "flyte", "runs-service").
	Name string

	// Short is the short description shown in --help.
	Short string

	// Setup is called after config initialisation. It should populate the
	// SetupContext with shared resources and register HTTP handlers / workers.
	Setup func(ctx context.Context, sc *SetupContext) error
}

type K8sConfig struct {
	KubeConfig string // path to kubeconfig (empty → in-cluster → default)
	Namespace  string // namespace to ensure exists
	QPS        int    // API server QPS limit
	Burst      int    // API server burst limit
	Timeout    string // API server request timeout (e.g. "30s")
}

type ReadyCheckFunc func(r *http.Request) error

type SetupContext struct {
	// Server address. Defaults to "0.0.0.0" and 8080.
	Host string
	Port int

	// Mux is the HTTP serve mux to register handlers on.
	Mux *http.ServeMux

	// DB is the shared database connection (may be nil if service doesn't need it).
	DB *gorm.DB

	// K8sClient is the Kubernetes client with watch support (may be nil).
	K8sClient client.WithWatch

	// K8sConfig is the Kubernetes REST config (may be nil).
	K8sConfig *rest.Config

	// DataStore is the object storage client (may be nil).
	DataStore *storage.DataStore

	// Namespace is the Kubernetes namespace for CRs.
	Namespace string

	// BaseURL is the base URL for intra-service calls (e.g. "http://localhost:8090").
	// In unified mode the manager sets this so all services call each other
	// via the same mux. Standalone binaries leave it empty and use their own
	// per-service config for remote URLs.
	BaseURL string

	// Scope is the metrics scope.
	Scope promutils.Scope

	// Middleware wraps the final HTTP handler (e.g. CORS).
	Middleware func(http.Handler) http.Handler
	// contains filtered or unexported fields
}

type WorkerFunc func(ctx context.Context) error