orign 0.2.3

A globally distributed container orchestrator
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::sync::Arc;
use crate::db::DbPool;
use redis::Client as RedisClient;
use rdkafka::producer::FutureProducer;
use rdkafka::admin::AdminClient;
use rdkafka::client::DefaultClientContext;

#[derive(Clone)]
pub enum MessageQueue {
    Kafka {
        producer: Arc<FutureProducer>,
        admin: Arc<AdminClient<DefaultClientContext>>,
    },
    Redis {
        client: Arc<RedisClient>,
    },
}

#[derive(Clone)]
pub struct AppState {
    pub db_pool: DbPool,
    pub message_queue: MessageQueue,
}