[−][src]Struct pikmin::downloader::bitmex::MexDownloader
A pre-built downloader for BitMEX.
Methods
impl MexDownloader
[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 MexDownloader
[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 = MexGetExecution
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<MexGetExecution>>
[src]
fn convert(&self, v: &MexGetExecution) -> 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>
Possibly some trades will be cut from the response if we just increment the starting timestamp since the API will return just 1,000 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.
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]
if we login, the API limit becomes 300/5min if not, it's 150/5min
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 MexDownloader
[src]
Auto Trait Implementations
impl Send for MexDownloader
impl Sync for MexDownloader
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