[][src]Struct rettle::pot::Pot

pub struct Pot { /* fields omitted */ }

Data Structure that holds the recipe to brew tea (ETL data).

Methods

impl Pot[src]

pub fn new() -> Pot[src]

Initializes Pot with an empty recipe and empty sources.

pub fn add_ingredient(&self, ingredient: Box<dyn Ingredient + Send + Sync>)[src]

Adds Ingredient to recipe held by the Pot.

Arguments

  • ingredient - the ingredient to add to the recipe

pub fn add_source(&mut self, source: Box<dyn Source>)[src]

Adds Source to sources held by the Pot.

Arguments

  • source - the source to add to the sources Array

pub fn get_sources(&self) -> &Vec<Box<dyn Source>>[src]

Returns the sources held by the Pot.

pub fn get_recipe(&self) -> Arc<RwLock<Vec<Box<dyn Ingredient + Send + Sync>>>>[src]

Returns the recipe held by the Pot.

pub fn brew(&self, brewery: &Brewery)[src]

Iterates over sources to pull in data and send jobs to the Brewery for processing.

Arguments

  • brewery - Brewery struct holding the receiver and Brewer Array to process Tea

Auto Trait Implementations

impl !Sync for Pot

impl !Send for Pot

impl Unpin for Pot

impl !RefUnwindSafe for Pot

impl !UnwindSafe for Pot

Blanket Implementations

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]