flv-client 0.1.0

Fluvio rust client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29


use async_trait::async_trait;


use crate::ClientError;
use crate::ReplicaLeader;
use crate::query_params::ReplicaConfig;

#[async_trait]
pub trait SpuController
{
    type Leader: ReplicaLeader;
    type TopicMetadata;

    async fn find_leader_for_topic_partition(
        &mut self,
        topic: &str,
        partition: i32,
    ) -> Result<Self::Leader, ClientError>;


    async fn delete_topic(&mut self, topic: &str) -> Result<String,ClientError>;

    /// create topic, for now we return string in order simply interface.  Otherwise, we have to add associate type
    async fn create_topic(&mut self,topic: String, replica: ReplicaConfig,validate_only: bool) -> Result<String,ClientError>;

    async fn topic_metadata(&mut self,topics: Option<Vec<String>>) -> Result<Vec<Self::TopicMetadata>,ClientError>;
}