Struct pikmin::downloader::liquid::LiquidDownloader

pub struct LiquidDownloader { /* fields omitted */ }

A pre-built downloader for Liquid.

Methods

impl LiquidDownloader

pub fn new(start: DateTime<Utc>, end: DateTime<Utc>) -> Self

Creates a new downloader with a specific range. The input source is fixed.

Trait Implementations

impl Downloader for LiquidDownloader

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 = LiquidGetExecution

A type of downloaded trade data.

fn start_id(&self) -> DateTime<Utc>

Returns beginning ID for a downloading process.

fn end_id(&self) -> DateTime<Utc>

Returns ending ID for a downloading process.

fn continue_condition(
    &self,
    current: &DateTime<Utc>,
    end: &DateTime<Utc>
) -> bool

Judges whether to continue downloading or not.

fn fetch(&self, c: &Self::IDT) -> Result<Vec<LiquidGetExecution>>

Fetches trade data from somewhere (typically API).

fn convert(&self, v: &LiquidGetExecution) -> Result<Trade>

Converts a raw trade datum into a standard trade struct.

fn output(&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

Returns milli seconds to sleep between fetching processes.

fn init_id(
    &self,
    default: Self::IDT,
    recorder: &mut impl ProgressRecorder
) -> Result<Self::ID>

Returns initial ID from a progress file. If reading is failed, use a given default value.

fn run(
    &self,
    writer: &mut impl Writer,
    recorder: &mut impl ProgressRecorder
) -> Result<()>

Executes downloading.

impl Debug for LiquidDownloader

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.