k8s

type AppK8sClient struct {
	// contains filtered or unexported fields
}

type AppK8sClientInterface interface {
	// Deploy creates or updates the KService for the given app. Idempotent — skips
	// the update if the spec SHA annotation is unchanged.
	Deploy(ctx context.Context, app *flyteapp.App) error

	// Stop scales the KService to zero and makes it cluster-local (not published to external gateway).
	// The KService CRD is kept so the app can be restarted later.
	Stop(ctx context.Context, appID *flyteapp.Identifier) error

	// GetApp reads the KService and returns the full App including reconstructed Spec and live Status.
	// Returns a not-found error (checkable with k8serrors.IsNotFound) if the KService does not exist.
	GetApp(ctx context.Context, appID *flyteapp.Identifier) (*flyteapp.App, error)

	// List returns apps for the given project/domain scope with optional pagination.
	// limit=0 means no limit. token is the K8s continue token from a previous call.
	// Returns the apps, the continue token for the next page (empty if last page), and any error.
	List(ctx context.Context, project, domain string, limit uint32, token string) ([]*flyteapp.App, string, error)

	// Delete removes the KService CRD entirely. The app must be re-created from scratch.
	// Use Stop to scale to zero while preserving the KService.
	Delete(ctx context.Context, appID *flyteapp.Identifier) error

	// GetReplicas lists the pods (replicas) currently backing the given app.
	GetReplicas(ctx context.Context, appID *flyteapp.Identifier) ([]*flyteapp.Replica, error)

	// DeleteReplica force-deletes a specific pod. Knative will replace it automatically.
	DeleteReplica(ctx context.Context, replicaID *flyteapp.ReplicaIdentifier) error

	// StartWatching starts the KService informer and begins dispatching events
	// to subscribers. Must be called before Subscribe.
	StartWatching(ctx context.Context) error

	// StopWatching stops the KService informer.
	StopWatching()

	// Subscribe creates a channel that receives WatchResponse events for the
	// given app name. Use empty string to receive events for all apps.
	Subscribe(appName string) chan *flyteapp.WatchResponse

	// Unsubscribe removes a subscription channel previously returned by Subscribe.
	Unsubscribe(appName string, ch chan *flyteapp.WatchResponse)

	// PublicIngress returns the deterministic public Ingress URL for the given app,
	// matching Knative's domain-template so Kourier routes traffic correctly.
	// Returns nil if BaseDomain is not configured.
	PublicIngress(id *flyteapp.Identifier) *flyteapp.Ingress
}