Documentation
¶
Index ¶
- func CheckIfPipelineWontPause(ctx context.Context, pipeline *unstructured.Unstructured, ...) bool
- func CheckPipelinePhase(ctx context.Context, pipeline *unstructured.Unstructured, ...) bool
- func GetISBServiceChildResourceHealth(conditions []metav1.Condition) (metav1.ConditionStatus, string)
- func GetISBSvcStatefulSetFromK8s(ctx context.Context, c client.Client, isbsvc *unstructured.Unstructured) (*appsv1.StatefulSet, error)
- func IsPipelinePausedOrWontPause(ctx context.Context, pipeline *unstructured.Unstructured, ...) bool
- func WithDesiredPhase(pipeline *unstructured.Unstructured, phase string) error
- func WithoutDesiredPhase(obj *unstructured.Unstructured) (map[string]interface{}, error)
- type Lifecycle
- type MonoVertexStatus
- type PipelineSpec
- type PipelineStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckIfPipelineWontPause ¶
func CheckIfPipelineWontPause(ctx context.Context, pipeline *unstructured.Unstructured, pipelineRollout *apiv1.PipelineRollout) bool
func CheckPipelinePhase ¶
func CheckPipelinePhase(ctx context.Context, pipeline *unstructured.Unstructured, phase numaflowv1.PipelinePhase) bool
func GetISBServiceChildResourceHealth ¶
func GetISBServiceChildResourceHealth(conditions []metav1.Condition) (metav1.ConditionStatus, string)
func GetISBSvcStatefulSetFromK8s ¶
func GetISBSvcStatefulSetFromK8s(ctx context.Context, c client.Client, isbsvc *unstructured.Unstructured) (*appsv1.StatefulSet, error)
Each ISBService has one underlying StatefulSet
func IsPipelinePausedOrWontPause ¶
func IsPipelinePausedOrWontPause(ctx context.Context, pipeline *unstructured.Unstructured, pipelineRollout *apiv1.PipelineRollout) bool
either pipeline must be:
- Paused
- Failed (contract with Numaflow is that unpausible Pipelines are "Failed" pipelines)
- PipelineRollout parent Annotated to allow data loss
func WithDesiredPhase ¶
func WithDesiredPhase(pipeline *unstructured.Unstructured, phase string) error
func WithoutDesiredPhase ¶
func WithoutDesiredPhase(obj *unstructured.Unstructured) (map[string]interface{}, error)
TODO: make this and the WithDesiredPhase() signature from above similar to each other (this may naturally happen after refactoring) remove 'lifecycle.desiredPhase' key/value pair from spec also remove 'lifecycle' if it's an empty map
Types ¶
type Lifecycle ¶
type Lifecycle struct {
// DesiredPhase used to bring the pipeline from current phase to desired phase
// +kubebuilder:default=Running
// +optional
DesiredPhase string `json:"desiredPhase,omitempty"`
}
type MonoVertexStatus ¶
type MonoVertexStatus = kubernetes.GenericStatus
func ParseMonoVertexStatus ¶
func ParseMonoVertexStatus(obj *unstructured.Unstructured) (MonoVertexStatus, error)
type PipelineSpec ¶
type PipelineSpec struct {
InterStepBufferServiceName string `json:"interStepBufferServiceName"`
Lifecycle Lifecycle `json:"lifecycle,omitempty"`
}
PipelineSpec keeps track of minimum number of fields we need to know about
func (PipelineSpec) GetISBSvcName ¶
func (pipeline PipelineSpec) GetISBSvcName() string
type PipelineStatus ¶
type PipelineStatus struct {
Phase numaflowv1.PipelinePhase `json:"phase,omitempty"`
Conditions []metav1.Condition `json:"conditions,omitempty"`
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
DrainedOnPause bool `json:"drainedOnPause,omitempty" protobuf:"bytes,12,opt,name=drainedOnPause"`
}
func ParsePipelineStatus ¶
func ParsePipelineStatus(obj *unstructured.Unstructured) (PipelineStatus, error)
Source Files
Click to show internal directories.
Click to hide internal directories.