pkg

Documentation

Index

• Constants
• type Event
• type EventType
• type TreeStatus
• type Waitables
  • func NewWaitables(c *flags.ConfigFlags) *Waitables
  • func (w *Waitables) AddItem(kind string, namespace string, name string) error
  • func (w *Waitables) Done()
  • func (w *Waitables) GetAllNamespaces() []string
  • func (w *Waitables) HasJob(meta metav1.ObjectMeta) bool
  • func (w *Waitables) HasJobs() bool
  • func (w *Waitables) HasPod(meta metav1.ObjectMeta) bool
  • func (w *Waitables) HasPodDirect(meta metav1.ObjectMeta) bool
  • func (w *Waitables) HasPods() bool
  • func (w *Waitables) HasService(meta metav1.ObjectMeta) bool
  • func (w *Waitables) HasServices() bool
  • func (w *Waitables) IsDone() bool
  • func (w *Waitables) PrintStatus()
  • func (w *Waitables) ProcessEventAddJob(ctx context.Context, job *batchv1.Job) (bool, error)
  • func (w *Waitables) ProcessEventAddPod(ctx context.Context, pod *corev1.Pod) (bool, error)
  • func (w *Waitables) ProcessEventAddService(ctx context.Context, svc *corev1.Service) (bool, error)
  • func (w *Waitables) ProcessEventDeleteJob(ctx context.Context, job *batchv1.Job) (bool, error)
  • func (w *Waitables) ProcessEventDeletePod(ctx context.Context, pod *corev1.Pod) (bool, error)
  • func (w *Waitables) ProcessEventDeleteService(ctx context.Context, svc *corev1.Service) (bool, error)
  • func (w *Waitables) ProcessEventUpdateJob(ctx context.Context, job *batchv1.Job) (bool, error)
  • func (w *Waitables) ProcessEventUpdatePod(ctx context.Context, pod *corev1.Pod) (bool, error)
  • func (w *Waitables) ProcessEventUpdateService(ctx context.Context, svc *corev1.Service) (bool, error)
  • func (w *Waitables) ProcessOldPodEvents(ctx context.Context, pod *corev1.Pod) (bool, error)
  • func (w *Waitables) SetJobComplete(job *batchv1.Job)
  • func (w *Waitables) SetJobCompleteFromJob(job *batchv1.Job)
  • func (w *Waitables) SetPodReady(pod *corev1.Pod)
  • func (w *Waitables) SetPodReadyFromPod(pod *corev1.Pod)
  • func (w *Waitables) SetServiceChildren(meta *metav1.ObjectMeta, pods []corev1.Pod)
  • func (w *Waitables) Start()
  • func (w *Waitables) Ticker() bool
  • func (w *Waitables) TotalCount() int
  • func (w *Waitables) UnsetJobComplete(job *batchv1.Job)
  • func (w *Waitables) UnsetPodReady(pod *corev1.Pod)
  • func (w *Waitables) WithCache(c cache.Cache) *Waitables

Constants

const (
	TreeStatusDone    = "✅"
	TreeStatusIgnored = "☑️"
	TreeStatusNotDone = "❌"
	TreeStatusUnknown = "❔"
)

Types

type Event

type Event struct {
	EventType EventType
	Pod       *corev1.Pod
}

type EventType

type EventType string

const (
	EventTypeAdd    EventType = "add"
	EventTypeUpdate EventType = "update"
	EventTypeDelete EventType = "delete"
)

type TreeStatus

type TreeStatus string

type Waitables

type Waitables struct {
	cache.Cache

	LastPodEvents map[types.UID]Event

	Services items.NamespacedServiceCollection
	Pods     items.NamespacedPodCollection
	Jobs     items.NamespacedJobCollection
	// contains filtered or unexported fields
}

func NewWaitables

func NewWaitables(c *flags.ConfigFlags) *Waitables

func (*Waitables) AddItem

func (w *Waitables) AddItem(kind string, namespace string, name string) error

func (*Waitables) Done

func (w *Waitables) Done()

func (*Waitables) GetAllNamespaces

func (w *Waitables) GetAllNamespaces() []string

func (*Waitables) HasJob

func (w *Waitables) HasJob(meta metav1.ObjectMeta) bool

func (*Waitables) HasJobs

func (w *Waitables) HasJobs() bool

func (*Waitables) HasPod

func (w *Waitables) HasPod(meta metav1.ObjectMeta) bool

func (*Waitables) HasPodDirect

func (w *Waitables) HasPodDirect(meta metav1.ObjectMeta) bool

func (*Waitables) HasPods

func (w *Waitables) HasPods() bool

func (*Waitables) HasService

func (w *Waitables) HasService(meta metav1.ObjectMeta) bool

func (*Waitables) HasServices

func (w *Waitables) HasServices() bool

func (*Waitables) IsDone

func (w *Waitables) IsDone() bool

func (*Waitables) PrintStatus

func (w *Waitables) PrintStatus()

func (*Waitables) ProcessEventAddJob

func (w *Waitables) ProcessEventAddJob(ctx context.Context, job *batchv1.Job) (bool, error)

func (*Waitables) ProcessEventAddPod

func (w *Waitables) ProcessEventAddPod(ctx context.Context, pod *corev1.Pod) (bool, error)

func (*Waitables) ProcessEventAddService

func (w *Waitables) ProcessEventAddService(ctx context.Context, svc *corev1.Service) (bool, error)

func (*Waitables) ProcessEventDeleteJob

func (w *Waitables) ProcessEventDeleteJob(ctx context.Context, job *batchv1.Job) (bool, error)

func (*Waitables) ProcessEventDeletePod

func (w *Waitables) ProcessEventDeletePod(ctx context.Context, pod *corev1.Pod) (bool, error)

func (*Waitables) ProcessEventDeleteService

func (w *Waitables) ProcessEventDeleteService(ctx context.Context, svc *corev1.Service) (bool, error)

func (*Waitables) ProcessEventUpdateJob

func (w *Waitables) ProcessEventUpdateJob(ctx context.Context, job *batchv1.Job) (bool, error)

func (*Waitables) ProcessEventUpdatePod

func (w *Waitables) ProcessEventUpdatePod(ctx context.Context, pod *corev1.Pod) (bool, error)

func (*Waitables) ProcessEventUpdateService

func (w *Waitables) ProcessEventUpdateService(ctx context.Context, svc *corev1.Service) (bool, error)

func (*Waitables) ProcessOldPodEvents

func (w *Waitables) ProcessOldPodEvents(ctx context.Context, pod *corev1.Pod) (bool, error)

func (*Waitables) SetJobComplete

func (w *Waitables) SetJobComplete(job *batchv1.Job)

func (*Waitables) SetJobCompleteFromJob

func (w *Waitables) SetJobCompleteFromJob(job *batchv1.Job)

func (*Waitables) SetPodReady

func (w *Waitables) SetPodReady(pod *corev1.Pod)

func (*Waitables) SetPodReadyFromPod

func (w *Waitables) SetPodReadyFromPod(pod *corev1.Pod)

func (*Waitables) SetServiceChildren

func (w *Waitables) SetServiceChildren(meta *metav1.ObjectMeta, pods []corev1.Pod)

func (*Waitables) Start

func (w *Waitables) Start()

func (*Waitables) Ticker

func (w *Waitables) Ticker() bool

func (*Waitables) TotalCount

func (w *Waitables) TotalCount() int

func (*Waitables) UnsetJobComplete

func (w *Waitables) UnsetJobComplete(job *batchv1.Job)

func (*Waitables) UnsetPodReady

func (w *Waitables) UnsetPodReady(pod *corev1.Pod)

func (*Waitables) WithCache

func (w *Waitables) WithCache(c cache.Cache) *Waitables