Struct BackproofStrategy

pub struct BackproofStrategy { /* private fields */ }

Represents the strategy that you can run.

Implementations

impl BackproofStrategy

pub fn builder() -> BackProofStrategyBuilder

Get a builder to configure the strategy.

Examples found in repository

examples/client.rs (line 16)

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 register(&mut self) -> Result<Session, BackproofSdkError>

register the strategy and setup the backend.

Examples found in repository

examples/client.rs (line 32)

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 run( self, _opts: Options, session: Session, ) -> Result<Sender<()>, BackproofSdkError>

Starts the strategy with given options.

Examples found in repository

examples/client.rs (line 37)

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");
}