clients

type KubernetesClient interface {
	AttachablePodFromService(ctx context.Context, svcKey types.NamespacedName) (*corev1.Pod, error)
	StreamPodLogs(ctx context.Context, pod *corev1.Pod, logOpts PodLogStreamOptions) (<-chan *LogStreamObject, error)
	BuildPodForJob(ctx context.Context, namespace string, jobName string) (*corev1.Pod, error)

	GetNamespaceMetrics(ctx context.Context, namespace string) (*MetricsStreamObject, error)
	StreamNamespaceMetrics(ctx context.Context, namespace string, metricsStreamOpts MetricsStreamOptions) (<-chan *MetricsStreamObject, error)
}

type KubernetesClientSpec struct {
	RestConfig              *rest.Config
	ControllerRuntimeClient client.Client
	Logger                  logger.Logger
}

type LogStreamObject struct {
	Data  string
	Error error
}

type MetricsStreamObject struct {
	NamespaceMetrics []metricsv1beta1.PodMetrics
	NodeCapacityMap  map[string]corev1.ResourceList
	Error            error
}

type MetricsStreamOptions interface {
	// PollInterval specifies how often to poll for metrics updates.
	PollInterval() time.Duration
	// MaxErrors returns the maximum number of errors to log before stopping the stream.
	MaxErrors() int
}

type PodLogStreamOptions interface {
	Follow() bool
	TailLines() int
	Since() string
	// Previous asks for the logs of the previously terminated container, which
	// is where a crash-looping workload's real error lives.
	Previous() bool
	// MaxErrors returns the maximum number of errors to log before stopping the stream.
	MaxErrors() int
}

type RegistryClient interface {
	CheckImage(ctx context.Context, imageRef string) (bool, error)
	// CheckPushAccess verifies that the client's credentials can authorize a
	// push to repoRef. It requests a push-scoped token and opens (then
	// cancels) a blob upload; it never pushes any content.
	CheckPushAccess(ctx context.Context, repoRef string) error
}