kubernetes

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

type EventType string

type ICluster interface {
	Connect() error
	GetContext() string
}

type ILogService interface {
	SendLogsToChannel(ctx context.Context, nameSpace string, podName string, ch chan string) error
}

type INamespaceService interface {
	GetNamespaces() (*v1.NamespaceList, error)
	GetNamespaceEvent() NamespaceEvent
	WatchNamespaces(resourceVersion string) error
}

type IPodService interface {
	GetPods(namespace string) (*v1.PodList, error)
	GetPodEvent() PodEvent
	WatchPods(ctx context.Context, namespace string, resourceVersion string) error
	StopWatchingPods()
	RunK8mpassCondition(fn api.K8mpassCondition, namespace string) bool
	RunK8mpassCommand(fn api.K8mpassCommand, namespace string) tea.Cmd
}

type NamespaceEvent struct {
	Type      EventType
	Namespace *v1.Namespace
}

type PodEvent struct {
	Type EventType
	Pod  *v1.Pod
}