[−][src]Struct yy_boss::PipelineManager
Implementations
impl PipelineManager
[src]
pub fn pipelines(&self) -> &BTreeMap<String, Pipeline>
[src]
Returns a map of all the pipelines currently known.
pub fn pipeline(&self, pipeline_name: impl Into<String>) -> Option<&Pipeline>
[src]
Returns a specific pipeline by name, if it exists.
pub fn pipeline_destinations(
&self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>
) -> Option<&PipelineDesinations>
[src]
&self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>
) -> Option<&PipelineDesinations>
Gets all of the destinations for a given source within a given pipeline, if both the pipeline and a source within that pipeline exist.
pub fn add_pipeline(
&mut self,
name: impl Into<String>
) -> Result<(), PipelineError>
[src]
&mut self,
name: impl Into<String>
) -> Result<(), PipelineError>
Creates a pipeline. If a pipeline of that name already exists, an error is returned.
pub fn add_source_to_pipeline(
&mut self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>
) -> Result<(), PipelineError>
[src]
&mut self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>
) -> Result<(), PipelineError>
Adds a source to a given pipeline.
If a pipeline doesn't exist, an error is returned.
pub fn add_destination_to_source<S: Into<String>>(
&mut self,
pipeline_name: S,
source_name: S,
destination_key: S,
destination_value: FilesystemPath
) -> Result<(), PipelineError>
[src]
&mut self,
pipeline_name: S,
source_name: S,
destination_key: S,
destination_value: FilesystemPath
) -> Result<(), PipelineError>
Adds a destination to a given source on a given pipeline.
If the pipeline doesn't exist or the source doesn't exist on the pipeline, an error is returned.
pub fn add_destination_to_source_rf<S: Into<String>>(
&mut self,
pipeline_name: S,
source_name: S,
destination_key: S,
destination_value: FilesystemPath
)
[src]
&mut self,
pipeline_name: S,
source_name: S,
destination_key: S,
destination_value: FilesystemPath
)
Adds a destination to a given source on a given pipeline.
If any elements do not exist, they will be created. If a destination exists on a source/pipeline which already exists, it will be replaced and lost.
pub fn remove_pipeline(
&mut self,
pipeline_name: impl Into<String>
) -> Result<(), PipelineError>
[src]
&mut self,
pipeline_name: impl Into<String>
) -> Result<(), PipelineError>
Removes a given pipeline from the manager. If any data is on the pipeline, it will be lost permanently!
If the pipeline does not exist, an error is returned.
pub fn remove_source_from_pipeline(
&mut self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>
) -> Result<(), PipelineError>
[src]
&mut self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>
) -> Result<(), PipelineError>
Removes a given source from a pipeline. If any destinations are in the source, it will be lost permanently!
If the pipeline does not exist, or if the source does not exist on the pipeline, an error is returned.
pub fn remove_destination_from_source(
&mut self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>,
destination_name: &str
) -> Result<(), PipelineError>
[src]
&mut self,
pipeline_name: impl Into<String>,
source_name: impl Into<String>,
destination_name: &str
) -> Result<(), PipelineError>
Removes a given destination from a source.
If the pipeline does not exist, or if the source does not exist on the pipeline, or if the destination does not exist on the source, an error is returned.
Trait Implementations
impl Clone for PipelineManager
[src]
fn clone(&self) -> PipelineManager
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for PipelineManager
[src]
impl Default for PipelineManager
[src]
fn default() -> PipelineManager
[src]
impl Eq for PipelineManager
[src]
impl PartialEq<PipelineManager> for PipelineManager
[src]
impl StructuralEq for PipelineManager
[src]
Auto Trait Implementations
impl RefUnwindSafe for PipelineManager
impl Send for PipelineManager
impl Sync for PipelineManager
impl Unpin for PipelineManager
impl UnwindSafe for PipelineManager
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> SetParameter for T
fn set<T>(&mut self, value: T) -> <T as Parameter<Self>>::Result where
T: Parameter<Self>,
T: Parameter<Self>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,