Struct PipelineExecutionData 

pub struct PipelineExecutionData {
    pub body: PipelineData,
    pub exit: Vec<Option<(Arc<Mutex<ExitStatusFuture>>, Span)>>,
}

A wrapper to PipelineData which can also track exit status.

We use exit status tracking to implement the pipefail feature.

Fields

body: PipelineData

exit: Vec<Option<(Arc<Mutex<ExitStatusFuture>>, Span)>>

Implementations

impl PipelineExecutionData

pub fn empty() -> Self

Methods from Deref<Target = PipelineData>

pub fn metadata(&self) -> Option<PipelineMetadata>

pub fn is_nothing(&self) -> bool

pub fn span(&self) -> Option<Span>

PipelineData doesn’t always have a Span, but we can try!

pub fn get_type(&self) -> Type

Get a type that is representative of the PipelineData.

The type returned here makes no effort to collect a stream, so it may be a different type than would be returned by Value::get_type() on the result of .into_value().

Specifically, a ListStream results in list<any> rather than the fully complete list type (which would require knowing the contents), and a ByteStream with unknown type results in any rather than string or binary.

pub fn is_subtype_of(&self, other: &Type) -> bool

Determine if the PipelineData is a subtype of other.

This check makes no effort to collect a stream, so it may be a different result than would be returned by calling Value::is_subtype_of() on the result of .into_value().

A ListStream acts the same as an empty list type: it is a subtype of any list or table type. After converting to a value, it may become a more specific type. For example, a ListStream is a subtype of list<int> and list<string>. If calling .into_value() results in a list<int>, then the value would not be a subtype of list<string>, in contrast to the original ListStream.

A ByteStream is a subtype of string if it is coercible into a string. Likewise, a ByteStream is a subtype of binary if it is coercible into a binary value.

pub fn clone_exit_status_future(&self) -> Option<Arc<Mutex<ExitStatusFuture>>>

Trait Implementations

impl Deref for PipelineExecutionData

type Target = PipelineData

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl From<PipelineData> for PipelineExecutionData

fn from(value: PipelineData) -> Self

Converts to this type from the input type.