Compare commits
8 Commits
89915bf249
...
34dc341059
Author | SHA1 | Date |
---|---|---|
Lou-Kamades | 34dc341059 | |
Riordan Panayides | cbb89a3219 | |
Riordan Panayides | 252cccf74e | |
dboures | c7c760ae72 | |
dboures | 8b3e4b95a7 | |
dboures | d4afc71c04 | |
dboures | c7ee74b872 | |
dboures | 4ba8fd5ec5 |
20
markets.json
20
markets.json
|
@ -34,5 +34,25 @@
|
||||||
{
|
{
|
||||||
"name": "RAY/USDC",
|
"name": "RAY/USDC",
|
||||||
"address": "DZjbn4XC8qoHKikZqzmhemykVzmossoayV9ffbsUqxVj"
|
"address": "DZjbn4XC8qoHKikZqzmhemykVzmossoayV9ffbsUqxVj"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "mSOL/SOL",
|
||||||
|
"address": "AYhLYoDr6QCtVb5n1M5hsWLG74oB8VEz378brxGTnjjn"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "stSOL/USDC",
|
||||||
|
"address": "JCKa72xFYGWBEVJZ7AKZ2ofugWPBfrrouQviaGaohi3R"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "LDO/USDC",
|
||||||
|
"address": "BqApFW7DwXThCDZAbK13nbHksEsv6YJMCdj58sJmRLdy"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "stSOL/SOL",
|
||||||
|
"address": "GoXhYTpRF4vs4gx48S7XhbaukVbJXVycXimhGfzWNGLF"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "JitoSOL/USDC",
|
||||||
|
"address": "DkbVbMhFxswS32xnn1K2UY4aoBugXooBTxdzkWWDWRkH"
|
||||||
}
|
}
|
||||||
]
|
]
|
|
@ -55,7 +55,7 @@ async fn main() -> std::io::Result<()> {
|
||||||
.unwrap();
|
.unwrap();
|
||||||
// For collecting metrics on the public api, excluding 404s
|
// For collecting metrics on the public api, excluding 404s
|
||||||
let public_metrics = PrometheusMetricsBuilder::new("openbook_candles_server")
|
let public_metrics = PrometheusMetricsBuilder::new("openbook_candles_server")
|
||||||
.registry(registry.clone())
|
.registry(registry)
|
||||||
.exclude_status(StatusCode::NOT_FOUND)
|
.exclude_status(StatusCode::NOT_FOUND)
|
||||||
.build()
|
.build()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
|
@ -22,7 +22,7 @@ pub async fn batch_for_market(pool: &Pool, market: &MarketInfo) -> anyhow::Resul
|
||||||
loop {
|
loop {
|
||||||
let market_clone = market.clone();
|
let market_clone = market.clone();
|
||||||
loop {
|
loop {
|
||||||
sleep(Duration::milliseconds(2000).to_std()?).await;
|
sleep(Duration::milliseconds(5000).to_std()?).await;
|
||||||
match batch_inner(pool, &market_clone).await {
|
match batch_inner(pool, &market_clone).await {
|
||||||
Ok(_) => {}
|
Ok(_) => {}
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
|
@ -63,7 +63,7 @@ async fn batch_inner(pool: &Pool, market: &MarketInfo) -> anyhow::Result<()> {
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn save_candles(pool: &Pool, candles: Vec<Candle>) -> anyhow::Result<()> {
|
async fn save_candles(pool: &Pool, candles: Vec<Candle>) -> anyhow::Result<()> {
|
||||||
if candles.len() == 0 {
|
if candles.is_empty() {
|
||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
let upsert_statement = build_candles_upsert_statement(&candles);
|
let upsert_statement = build_candles_upsert_statement(&candles);
|
||||||
|
|
Loading…
Reference in New Issue