controller

type Controller struct {
	Options
	// contains filtered or unexported fields
}

type HandleKind string

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

type LogStreamOptions struct {
	Pod           *apicorev1.Pod
	Container     *apicorev1.Container
	Context       context.Context
	KubeClientSet kubernetes.Interface
	BasePath      string
	Timeout       time.Duration
}

type Options struct {
	BasePath       string
	ParentContext  context.Context
	Logger         *slog.Logger
	LogSyncTimeout time.Duration
	Resources      []schema.GroupVersionResource
}

type Stream interface {
	// Sync new data from stream source into stream destination.
	Sync() error

	// Close the streamer.
	Close() error
}