Struct BackProofStrategyBuilder

pub struct BackProofStrategyBuilder { /* private fields */ }

The strategy backproof strategy builder.

Implementations

impl BackProofStrategyBuilder

Lets you build your strategy step by step.

pub fn new() -> Self

pub fn api_key(self, api_key: String) -> Self

Examples found in repository

examples/client.rs (line 17)

async fn main() {
    tracing_subscriber::fmt::init();

    let address = std::env::args().nth(1).unwrap();

    let mut strategy = BackproofStrategy::builder()
        .api_key("A323FSDEO3123FSD".to_string())
        .api_strategy("flex".to_string(), |x: Candle| -> Order {
            println!("Strategy running with input {x:?}...");
            std::thread::sleep(Duration::from_secs(1));

            Order {
                symbol: "BTC".to_string(),
                quantity: "100".to_string(),
                side: 1,
            }
        })
        .build(address)
        .await
        .expect("strategy build failed");

    let session = strategy.register().await.expect("register");

    info!("Starting strategy");

    let closer = strategy
        .run(Options::default(), session)
        .await
        .expect("strategy run failed");

    std::thread::sleep(Duration::from_secs(5));
    info!("closing backend.");
    let _ = closer.send(()).expect("failed to close");
}

pub fn api_strategy( self, name: String, logic: impl Fn(Candle) -> Order + 'static + Send, ) -> Self

Examples found in repository

examples/client.rs (lines 18-27)

async fn main() {
    tracing_subscriber::fmt::init();

    let address = std::env::args().nth(1).unwrap();

    let mut strategy = BackproofStrategy::builder()
        .api_key("A323FSDEO3123FSD".to_string())
        .api_strategy("flex".to_string(), |x: Candle| -> Order {
            println!("Strategy running with input {x:?}...");
            std::thread::sleep(Duration::from_secs(1));

            Order {
                symbol: "BTC".to_string(),
                quantity: "100".to_string(),
                side: 1,
            }
        })
        .build(address)
        .await
        .expect("strategy build failed");

    let session = strategy.register().await.expect("register");

    info!("Starting strategy");

    let closer = strategy
        .run(Options::default(), session)
        .await
        .expect("strategy run failed");

    std::thread::sleep(Duration::from_secs(5));
    info!("closing backend.");
    let _ = closer.send(()).expect("failed to close");
}

pub async fn build<D>( self, endpoint: D, ) -> Result<BackproofStrategy, BackproofSdkError>

where D: TryInto<Endpoint> + Debug, D::Error: Into<StdError>,

Examples found in repository

examples/client.rs (line 28)

async fn main() {
    tracing_subscriber::fmt::init();

    let address = std::env::args().nth(1).unwrap();

    let mut strategy = BackproofStrategy::builder()
        .api_key("A323FSDEO3123FSD".to_string())
        .api_strategy("flex".to_string(), |x: Candle| -> Order {
            println!("Strategy running with input {x:?}...");
            std::thread::sleep(Duration::from_secs(1));

            Order {
                symbol: "BTC".to_string(),
                quantity: "100".to_string(),
                side: 1,
            }
        })
        .build(address)
        .await
        .expect("strategy build failed");

    let session = strategy.register().await.expect("register");

    info!("Starting strategy");

    let closer = strategy
        .run(Options::default(), session)
        .await
        .expect("strategy run failed");

    std::thread::sleep(Duration::from_secs(5));
    info!("closing backend.");
    let _ = closer.send(()).expect("failed to close");
}

Trait Implementations

impl Debug for BackProofStrategyBuilder

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

Formats the value using the given formatter.

impl Default for BackProofStrategyBuilder

fn default() -> BackProofStrategyBuilder

Returns the “default value” for a type.