Documentation ¶
Index ¶
- func AreReplicasReady(replicas, ready, updated int32) bool
- func CheckContainerFailed(pod corev1.Pod) error
- func MatchPodCondition(ps corev1.PodStatus, typ corev1.PodConditionType) (corev1.PodCondition, bool)
- func NewPodCondititionWaiter(namespace string, selector metav1.ListOptions, ...) *podWaiter
- func PickPod(name string) metav1.ListOptions
- func PodStatusToWaitStatus(ns, name string, ps v1.PodStatus) *orchestration.Event_WaitStatus
- 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 WatchPods[V any](ctx context.Context, cli *k8s.Clientset, namespace string, ...) (V, error)
- type ConditionWaiter
- type PodObserver
- type WaitOnGenerationCondition
- type WaitOnResource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AreReplicasReady ¶ added in v0.0.75
func CheckContainerFailed ¶ added in v0.0.121
func MatchPodCondition ¶
func MatchPodCondition(ps corev1.PodStatus, typ corev1.PodConditionType) (corev1.PodCondition, bool)
func NewPodCondititionWaiter ¶
func PickPod ¶
func PickPod(name string) metav1.ListOptions
func PodStatusToWaitStatus ¶ added in v0.0.81
func PodStatusToWaitStatus(ns, name string, ps v1.PodStatus) *orchestration.Event_WaitStatus
func PrepareEvent ¶
func PrepareEvent(gvk kubeschema.GroupVersionKind, namespace, name, desc string, deployable *runtime.Deployable) *orchestration.Event
func ResolvePod ¶
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
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]
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 ¶
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
Click to show internal directories.
Click to hide internal directories.