worker-service 0.2.0

Worker Service - A worker administration microservice that interoperates with the worker-matcher crate
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

//! Event consumer implementation

use super::{EventConsumer, WorkerEvent};
use crate::Result;

pub struct FluvioConsumer {
    // Fluvio consumer will be initialized here
}

impl EventConsumer for FluvioConsumer {
    fn subscribe(&mut self) -> Result<()> {
        // TODO: Implement Fluvio subscription
        todo!("Implement Fluvio subscription")
    }

    fn next_event(&mut self) -> Result<Option<WorkerEvent>> {
        // TODO: Implement event consumption
        todo!("Implement event consumption")
    }
}