Struct pikmin::downloader::bitmex::MexDownloader

pub struct MexDownloader { /* fields omitted */ }

A pre-built downloader for BitMEX.

Methods

impl MexDownloader

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 MexDownloader

type IDT = Pagination<DateTime<Utc>, DateTimeID>

A type of element which ID is made up of.

type ID = PaginatedID<DateTime<Utc>, DateTimeID>

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

type RAW = MexGetExecution

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<MexGetExecution>>

Fetches trade data from somewhere (typically API).

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

Possibly some trades will be cut from the response if we just increment the starting timestamp since the API will return just requested number fo trades for single request. In order to avoid this, the last trades in terms of the traded timestamp should be ignored at the first time, and request again from the timestamp.

Mex API allows to send an offset parameter, so this will never get into an infinite loop.

fn sleep_millis(&self) -> u64

if we login, the API limit becomes 300/5min if not, it's 150/5min

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 MexDownloader

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

Formats the value using the given formatter.