pub struct ManifestOutput { /* private fields */ }
Expand description
Describes a single output file from a containerized extractor. This is written by the container in manifest.yaml.
Implementations§
Source§impl ManifestOutput
impl ManifestOutput
Sourcepub fn builder() -> Builder<IngestTypeStage>
pub fn builder() -> Builder<IngestTypeStage>
Returns a new builder.
Source§impl ManifestOutput
impl ManifestOutput
Sourcepub fn new(
ingest_type: ManifestIngestType,
relative_path: impl Into<String>,
) -> Self
pub fn new( ingest_type: ManifestIngestType, relative_path: impl Into<String>, ) -> Self
Constructs a new instance of the type.
Sourcepub fn ingest_type(&self) -> &ManifestIngestType
pub fn ingest_type(&self) -> &ManifestIngestType
The type of ingestion for this output file
Sourcepub fn relative_path(&self) -> &str
pub fn relative_path(&self) -> &str
Relative path to the output file within OUTPUT_DIR. Example: “telemetry.csv” or “data/sensor_readings.parquet”
Sourcepub fn tag_columns(&self) -> &BTreeMap<String, String>
pub fn tag_columns(&self) -> &BTreeMap<String, String>
Optional mapping of tag names to column names for CSV/Parquet ingestion. Example: {“vehicle_id”: “veh_id”, “mission_id”: “msn_id”}
Sourcepub fn channel_prefix(&self) -> Option<&str>
pub fn channel_prefix(&self) -> Option<&str>
Optional prefix to prepend to channel names during ingestion. Example: “telemetry/” would create channels like “telemetry/speed”, “telemetry/altitude”
Trait Implementations§
Source§impl Clone for ManifestOutput
impl Clone for ManifestOutput
Source§fn clone(&self) -> ManifestOutput
fn clone(&self) -> ManifestOutput
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for ManifestOutput
impl Debug for ManifestOutput
Source§impl<'de> Deserialize<'de> for ManifestOutput
impl<'de> Deserialize<'de> for ManifestOutput
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl From<ManifestOutput> for Builder<Complete>
impl From<ManifestOutput> for Builder<Complete>
Source§fn from(v: ManifestOutput) -> Self
fn from(v: ManifestOutput) -> Self
Converts to this type from the input type.
Source§impl Hash for ManifestOutput
impl Hash for ManifestOutput
Source§impl Ord for ManifestOutput
impl Ord for ManifestOutput
Source§fn cmp(&self, other: &ManifestOutput) -> Ordering
fn cmp(&self, other: &ManifestOutput) -> Ordering
1.21.0 · Source§fn max(self, other: Self) -> Selfwhere
Self: Sized,
fn max(self, other: Self) -> Selfwhere
Self: Sized,
Compares and returns the maximum of two values. Read more
Source§impl PartialEq for ManifestOutput
impl PartialEq for ManifestOutput
Source§impl PartialOrd for ManifestOutput
impl PartialOrd for ManifestOutput
Source§impl Serialize for ManifestOutput
impl Serialize for ManifestOutput
impl Eq for ManifestOutput
impl StructuralPartialEq for ManifestOutput
Auto Trait Implementations§
impl Freeze for ManifestOutput
impl RefUnwindSafe for ManifestOutput
impl Send for ManifestOutput
impl Sync for ManifestOutput
impl Unpin for ManifestOutput
impl UnwindSafe for ManifestOutput
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Comparable<K> for Q
impl<Q, K> Comparable<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request