[−][src]Struct pikmin::downloader::liquid::LiquidDownloader
A pre-built downloader for Liquid.
Methods
impl LiquidDownloader
[src]
pub fn new(start: DateTime<Utc>, end: DateTime<Utc>) -> Self
[src]
Creates a new downloader with a specific range. The input source is fixed.
Trait Implementations
impl Downloader for LiquidDownloader
[src]
type IDT = DateTime<Utc>
A type of element which ID is made up of.
type ID = DateTimeID
A type of ID for specifying the downloading point in an API client.
type RAW = QnGetExecution
A type of downloaded trade data.
fn start_id(&self) -> DateTime<Utc>
[src]
fn end_id(&self) -> DateTime<Utc>
[src]
fn continue_condition(
&self,
current: &DateTime<Utc>,
end: &DateTime<Utc>
) -> bool
[src]
&self,
current: &DateTime<Utc>,
end: &DateTime<Utc>
) -> bool
fn fetch(&self, c: &Self::IDT) -> Result<Vec<QnGetExecution>>
[src]
fn convert(&self, v: &QnGetExecution) -> Result<Trade>
[src]
fn output(
&self,
u: Vec<Trade>,
writer: &mut impl Writer
) -> Result<Self::IDT>
[src]
&self,
u: Vec<Trade>,
writer: &mut impl Writer
) -> Result<Self::IDT>
Liquid (by Quoine) API has inconsistent statements in the document (https://developers.quoine.com/#get-executions-by-timestamp).
As Get Executions by Timestamp
won't return the complete executions at the same timestamp,
this function has to re-request the executions for the timestamp so as to obtain all of them.
Errors
In order to avoid an infinite loop, this function will return an error when there are more than 1,000 executions at the same timestamp.
fn sleep_millis(&self) -> u64
[src]
fn init_id(
&self,
default: Self::IDT,
process_log_path: &Path
) -> Result<Self::IDT>
[src]
&self,
default: Self::IDT,
process_log_path: &Path
) -> Result<Self::IDT>
Returns initial ID from a progress file. If reading is failed, use a given default
value.
fn record_progress(&self, path: &Path, id: &str) -> Result<()>
[src]
Records progress on somewhere (typically a file).
fn run(
&self,
writer: &mut impl Writer,
process_log_path: &Path
) -> Result<()>
[src]
&self,
writer: &mut impl Writer,
process_log_path: &Path
) -> Result<()>
Executes downloading.
impl Debug for LiquidDownloader
[src]
Auto Trait Implementations
impl Send for LiquidDownloader
impl Sync for LiquidDownloader
Blanket Implementations
impl<T> From for T
[src]
impl<T, U> Into for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = !
try_from
)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> Borrow for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
try_from
)The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Erased for T
impl<T> Same for T
type Output = T
Should always be Self