pod

type ContainerError struct {
	Message       string
	ContainerName string
}

type ContainerErrorReport struct {
	ContainerError
	PodStatus PodStatus
}

type ContainerLogChunk struct {
	ContainerName string
	LogLines      []display.LogLine
}

type FailedReport struct {
	FailedReason string
	PodStatus    PodStatus
}

type Feed interface {
	OnAdded(func() error)
	OnSucceeded(func() error)
	OnFailed(func(string) error)
	OnReady(func() error)

	OnEventMsg(func(msg string) error)
	OnContainerLogChunk(func(*ContainerLogChunk) error)
	OnContainerError(func(ContainerError) error)
	OnStatus(func(PodStatus) error)

	GetStatus() PodStatus
	Track(name, namespace string, kube kubernetes.Interface, opts tracker.Options) error
}

type Options struct {
	IgnoreReadinessProbeFailsByContainerName map[string]time.Duration
}

type PodError struct {
	ContainerError
	PodName string
}

type PodLogChunk struct {
	*ContainerLogChunk
	PodName string
}

type PodStatus struct {
	corev1.PodStatus

	Name string

	StatusGeneration uint64

	StatusIndicator *indicators.StringEqualConditionIndicator
	Age             string
	Restarts        int32
	ReadyContainers int32
	TotalContainers int32

	IsReady      bool
	IsFailed     bool
	IsSucceeded  bool
	FailedReason string

	ContainersErrors []ContainerError
}

type PodsInformer struct {
	tracker.Tracker
	Controller utils.ControllerMetadata
	PodAdded   chan *corev1.Pod
	Errors     chan error
}

type ReadinessProbe struct {
	corev1.Probe
	// contains filtered or unexported fields
}

type Tracker struct {
	tracker.Tracker

	Added     chan PodStatus
	Deleted   chan PodStatus
	Succeeded chan PodStatus
	Ready     chan PodStatus
	Failed    chan FailedReport
	Status    chan PodStatus

	EventMsg          chan string
	ContainerLogChunk chan *ContainerLogChunk
	ContainerError    chan ContainerErrorReport

	// LastStatus struct is needed for the Job tracker.
	// LastStatus contains latest known and actual resource status.
	LastStatus PodStatus

	State                        tracker.TrackerState
	ContainerTrackerStates       map[string]tracker.TrackerState
	ContainerTrackerStateChanges map[string]chan tracker.TrackerState

	TrackedContainers []string
	LogsFromTime      time.Time
	// contains filtered or unexported fields
}