kubeobserver

Documentation

Index

• func AreReplicasReady(replicas, ready, updated int32) bool
• func MatchPodCondition(typ corev1.PodConditionType) func(corev1.PodStatus) (bool, error)
• func NewPodCondititionWaiter(namespace string, selector metav1.ListOptions, ...) *podWaiter
• func PickPod(name string) metav1.ListOptions
• func PrepareEvent(gvk kubeschema.GroupVersionKind, namespace, name, desc string, ...) *orchestration.Event
• func ResolvePod(ctx context.Context, client *k8s.Clientset, namespace string, ...) (v1.Pod, error)
• func StatusToDiagnostic(status v1.ContainerStatus) *runtime.Diagnostics
• func WaitForCondition[Client any](ctx context.Context, cli Client, action *tasks.ActionEvent, ...) error
• func WaiterFromPodStatus(ns, name string, ps v1.PodStatus) *orchestration.Event_WaitStatus
• func WatchDeployable[V any](ctx context.Context, actionName string, cli *k8s.Clientset, namespace string, ...) (V, error)
• func WatchPods[V any](ctx context.Context, cli *k8s.Clientset, namespace string, ...) (V, error)
• type ConditionWaiter
  • func WaitForPodConditition(namespace string, selector metav1.ListOptions, ...) ConditionWaiter[*k8s.Clientset]
  • func WaitForService(namespace, name string) ConditionWaiter[*k8s.Clientset]
• type PodObserver
  • func NewPodObserver(ctx context.Context, client *k8s.Clientset, namespace string, ...) *PodObserver
  • func (p *PodObserver) Resolve(ctx context.Context) (v1.Pod, error)
  • func (p *PodObserver) Watch(f func(*v1.Pod, int64, error)) func()
• type WaitOnGenerationCondition
  • func (w WaitOnGenerationCondition) WaitUntilReady(ctx context.Context, ch chan *orchestration.Event) error
• type WaitOnResource
  • func (w WaitOnResource) WaitUntilReady(ctx context.Context, ch chan *orchestration.Event) error

Functions

func AreReplicasReady

func AreReplicasReady(replicas, ready, updated int32) bool

func MatchPodCondition

func MatchPodCondition(typ corev1.PodConditionType) func(corev1.PodStatus) (bool, error)

func NewPodCondititionWaiter

func NewPodCondititionWaiter(namespace string, selector metav1.ListOptions, isOk func(corev1.PodStatus) (bool, error)) *podWaiter

func PickPod

func PickPod(name string) metav1.ListOptions

func PrepareEvent

func PrepareEvent(gvk kubeschema.GroupVersionKind, namespace, name, desc string, deployable runtime.Deployable) *orchestration.Event

func ResolvePod

func ResolvePod(ctx context.Context, client *k8s.Clientset, namespace string, labels map[string]string) (v1.Pod, error)

func StatusToDiagnostic

func StatusToDiagnostic(status v1.ContainerStatus) *runtime.Diagnostics

func WaitForCondition

func WaitForCondition[Client any](ctx context.Context, cli Client, action *tasks.ActionEvent, waiter ConditionWaiter[Client]) error

func WaiterFromPodStatus

func WaiterFromPodStatus(ns, name string, ps v1.PodStatus) *orchestration.Event_WaitStatus

func WatchDeployable

func WatchDeployable[V any](ctx context.Context, actionName string, cli *k8s.Clientset, namespace string, object runtime.Deployable, callback func(corev1.Pod) (V, bool)) (V, error)

func WatchPods

func WatchPods[V any](ctx context.Context, cli *k8s.Clientset, namespace string, labels map[string]string, callback func(corev1.Pod) (V, bool)) (V, error)

Types

type ConditionWaiter

type ConditionWaiter[Client any] interface {
	Prepare(context.Context, Client) error
	Poll(context.Context, Client) (bool, error)
}

func WaitForPodConditition

func WaitForPodConditition(namespace string, selector metav1.ListOptions, isOk func(corev1.PodStatus) (bool, error)) ConditionWaiter[*k8s.Clientset]

func WaitForService

func WaitForService(namespace, name string) ConditionWaiter[*k8s.Clientset]

type PodObserver

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

PodObserver continuously attempts to resolve a single pod that match the specified set of labels. If the resolved pod is terminated, a new one is picked.

func NewPodObserver

func NewPodObserver(ctx context.Context, client *k8s.Clientset, namespace string, labels map[string]string) *PodObserver

func (*PodObserver) Resolve

func (p *PodObserver) Resolve(ctx context.Context) (v1.Pod, error)

func (*PodObserver) Watch

func (p *PodObserver) Watch(f func(*v1.Pod, int64, error)) func()

type WaitOnGenerationCondition

type WaitOnGenerationCondition struct {
	RestConfig         *rest.Config
	Name, Namespace    string
	ExpectedGeneration int64
	ConditionType      string
	Resource           schema.GroupVersionResource
}

func (WaitOnGenerationCondition) WaitUntilReady

func (w WaitOnGenerationCondition) WaitUntilReady(ctx context.Context, ch chan *orchestration.Event) error

type WaitOnResource

type WaitOnResource struct {
	RestConfig *rest.Config

	Name, Namespace  string
	Description      string
	GroupVersionKind kubeschema.GroupVersionKind
	Scope            schema.PackageName

	PreviousGen, ExpectedGen int64
}

func (WaitOnResource) WaitUntilReady

func (w WaitOnResource) WaitUntilReady(ctx context.Context, ch chan *orchestration.Event) error