generic

Dec 19, 2023

Changes in this version

+ var ResourceStatusJSONPathConditions []*ResourceStatusJSONPathCondition

+ type ContribResourceStatusRules struct

+ Rules []struct{ ... }

+ type ResourceStatusJSONPathCondition struct

+ CurrentValue string

+ FailedValues []string

+ GroupKind *schema.GroupKind

+ HumanPath string

+ JSONPath string

+ PendingValues []string

+ ReadyValues []string

Jul 26, 2022

Changes in this version

+ func SetWatchErrorHandler(cancelFn context.CancelFunc, resName string, ...) error

type ResourceStatus

+ func NewSucceededResourceStatus() *ResourceStatus

+ type SetWatchErrorHandlerOptions struct

+ FatalWatchErr *UnrecoverableWatchError

+ type UnrecoverableWatchError struct

+ Err error

+ ResName string

+ func (e UnrecoverableWatchError) Error() string

+ func (e UnrecoverableWatchError) Unwrap() error

Jul 5, 2022

Changes in this version

+ const ResourceStatusStabilizingDuration

+ var ResourceStatusJSONPathsByPriority []ResourceStatusJSONPath

+ func NewResourceStatusIndicator(object *unstructured.Unstructured) (indicator *indicators.StringEqualConditionIndicator, humanJSONPath string, ...)

+ type EventStatus struct

+ func NewEventStatus(event *corev1.Event) *EventStatus

+ func (s *EventStatus) FailureReason() string

+ func (s *EventStatus) IsFailure() bool

+ type Feed struct

+ func NewFeed(tracker *Tracker) *Feed

+ func (f *Feed) OnAdded(function func(status *ResourceStatus) error)

+ func (f *Feed) OnEventMsg(function func(event *corev1.Event) error)

+ func (f *Feed) OnFailed(function func(status *ResourceStatus) error)

+ func (f *Feed) OnReady(function func(status *ResourceStatus) error)

+ func (f *Feed) OnStatus(function func(status *ResourceStatus) error)

+ func (f *Feed) Track(ctx context.Context, timeout, noActivityTimeout time.Duration) error

+ type ResourceEventsWatcher struct

+ ResourceID *resid.ResourceID

+ func NewResourceEventsWatcher(object *unstructured.Unstructured, resID *resid.ResourceID, ...) *ResourceEventsWatcher

+ func (i *ResourceEventsWatcher) Run(ctx context.Context, eventsCh chan<- *corev1.Event) error

+ type ResourceStateWatcher struct

+ ResourceID *resid.ResourceID

+ func NewResourceStateWatcher(resID *resid.ResourceID, dynClient dynamic.Interface, mapper meta.RESTMapper) *ResourceStateWatcher

+ func (w *ResourceStateWatcher) Run(ctx context.Context, ...) error

+ type ResourceStatus struct

+ Indicator *indicators.StringEqualConditionIndicator

+ func NewDeletedResourceStatus() *ResourceStatus

+ func NewFailedResourceStatus(failureReason string) *ResourceStatus

+ func NewResourceStatus(object *unstructured.Unstructured) (*ResourceStatus, error)

+ func (s *ResourceStatus) DiffersFrom(newStatus *ResourceStatus) bool

+ func (s *ResourceStatus) FailureReason() string

+ func (s *ResourceStatus) HumanConditionPath() string

+ func (s *ResourceStatus) IsDeleted() bool

+ func (s *ResourceStatus) IsFailed() bool

+ func (s *ResourceStatus) IsReady() bool

+ type ResourceStatusJSONPath struct

+ CurrentValue string

+ FailedValue string

+ HumanPath string

+ JSONPath string

+ PendingValues []string

+ ReadyValue string

+ type Tracker struct

+ ResourceID *resid.ResourceID

+ func NewTracker(resID *resid.ResourceID, client kubernetes.Interface, ...) *Tracker

+ func (t *Tracker) Track(ctx context.Context, noActivityTimeout time.Duration, ...) error

+ type TrackerState string

+ const TrackerStateInitial

+ const TrackerStateResourceAdded

+ const TrackerStateResourceDeleted

+ const TrackerStateResourceFailed

+ const TrackerStateResourceSucceeded

+ const TrackerStateStarted

+ const TrackerStateStatusStabilizing