Struct service::Kollector

pub struct Kollector {
    pub context: Context<InnerMessage>,
    pub max_depth: usize,
    pub pairs: Vec<String>,
    /* private fields */
}

The Kollector is the main the main service

Fields

context: Context<InnerMessage>

max_depth: usize

pairs: Vec<String>

Implementations

impl Kollector

pub fn new(pairs: &str, max_depth: usize) -> Self

Create a new Kollector service

Arguments

• pairs - comma separated list of crypto pairs
• max_depth - maximum depth of order book to stream

pub fn spawn_gateway(&mut self, gateway: Box<dyn Gateway>)

Spawn a gateway

This method add a new gateway to the gateway’s hashmap and start the websocket coroutine which connect to the exchange.

This method should be called before running the service.

pub fn spawn_grpc(&mut self)

Spawn the grpc server

This method should be called before running the service

pub fn spawn_http(&self)

Add web service

Add a web service for prometheus metrics and k8s liveness probe

pub fn handle_ctrlc(&self)

Add Ctrl-C handler

pub async fn run(&mut self)

Main coroutine

This coroutine runs the main part of the kollector service