Struct pikmin::downloader::bf::BfDownloader

pub struct BfDownloader { /* fields omitted */ }

A pre-built downloader for bitFlyer.

Methods

impl BfDownloader

pub fn new(newer: u64, older: u64) -> Self

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

Trait Implementations

impl Downloader for BfDownloader

type IDT = u64

A type of element which ID is made up of.

type ID = OrdID<Self::IDT>

A type of ID for specifying the downloading point in an API client.

type RAW = BfGetExecution

A type of downloaded trade data.

fn start_id(&self) -> Self::IDT

Returns beginning ID for a downloading process.

fn end_id(&self) -> Self::IDT

Returns ending ID for a downloading process.

fn continue_condition(&self, current: &Self::IDT, end: &Self::IDT) -> bool

Judges whether to continue downloading or not.

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

Fetches trade data from somewhere (typically API).

fn convert(&self, v: &Self::RAW) -> 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>

Writes trade data to somewhere with a given writer. This must return an id for the next iteration, and this will be recorded on a progress file.

fn sleep_millis(&self) -> u64

Returns milli seconds to sleep between fetching processes.

fn init_id(
    &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<()>

Records progress on somewhere (typically a file).

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

Executes downloading.

impl Debug for BfDownloader

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

Formats the value using the given formatter.