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 by setting max-scale=0. The KService CRD
	// is kept so the app can be restarted later.
	Stop(ctx context.Context, appID *flyteapp.Identifier) error

	// GetStatus reads the KService and maps its conditions to a DeploymentStatus.
	// Returns a not-found error (checkable with k8serrors.IsNotFound) if the KService does not exist.
	GetStatus(ctx context.Context, appID *flyteapp.Identifier) (*flyteapp.Status, error)

	// List returns apps for the given project/domain scope with optional pagination.
	// If appName is non-empty, only the app with that name is returned.
	// 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, appName 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

	// Watch returns a channel of WatchResponse events for KServices matching the
	// given project/domain scope. If appName is non-empty, only events for that
	// specific app are returned. The channel is closed when ctx is cancelled.
	Watch(ctx context.Context, project, domain, appName string) (<-chan *flyteapp.WatchResponse, error)
}