| 81 | #[cfg(feature = "real-time")] |
| 82 | impl<S: Scope<Timestamp = Duration>> Sourceable<S> for Source { |
| 83 | fn source( |
| 84 | &self, |
| 85 | scope: &mut S, |
| 86 | context: SourcingContext<S::Timestamp>, |
| 87 | ) -> Vec<( |
| 88 | Aid, |
| 89 | AttributeConfig, |
| 90 | Stream<S, ((Value, Value), Duration, isize)>, |
| 91 | )> { |
| 92 | match *self { |
| 93 | Source::TimelyLogging(ref source) => source.source(scope, context), |
| 94 | Source::DifferentialLogging(ref source) => source.source(scope, context), |
| 95 | // Source::DeclarativeLogging(ref source) => source.source(scope, context), |
| 96 | #[cfg(feature = "csv-source")] |
| 97 | Source::CsvFile(ref source) => source.source(scope, context), |
| 98 | _ => unimplemented!(), |
| 99 | } |
| 100 | } |
| 101 | } |
| 102 | |
| 103 | #[cfg(not(feature = "real-time"))] |