Struct flv_client::ScClient

pub struct ScClient<A>(_);

Methods

impl<A> ScClient<A>

pub fn inner(&self) -> &Client<A>

impl<A> ScClient<A> where
    A: ToSocketAddrs + Display, 

pub async fn get_topic_composition<'_, '_>(
    &'_ mut self,
    topic: &'_ str
) -> Result<FlvTopicCompositionResponse, KfSocketError>

Connect to server, get version, and for topic composition: Replicas and SPUs

pub async fn connect(config: ClientConfig<A>) -> Result<Self, ClientError>

pub async fn create_custom_spu<'_>(
    &'_ mut self,
    id: i32,
    name: String,
    public_server: ServerAddress,
    private_server: ServerAddress,
    rack: Option<String>
) -> Result<(), ClientError>

pub async fn delete_custom_spu<'_>(
    &'_ mut self,
    spu: FlvCustomSpu
) -> Result<(), ClientError>

pub async fn list_spu<'_>(
    &'_ mut self,
    only_custom_spu: bool
) -> Result<Vec<FlvFetchSpuResponse>, ClientError>

pub async fn create_group<'_>(
    &'_ mut self,
    group: FlvCreateSpuGroupRequest
) -> Result<(), ClientError>

pub async fn delete_group<'_, '_>(
    &'_ mut self,
    group: &'_ str
) -> Result<(), ClientError>

pub async fn list_group<'_>(
    &'_ mut self
) -> Result<FlvFetchSpuGroupsResponse, ClientError>

Trait Implementations

impl<A> SpuController for ScClient<A> where
    A: ToSocketAddrs + Display + Send + Sync, 

type Leader = SpuLeader

type TopicMetadata = FlvFetchTopicResponse

fn find_leader_for_topic_partition<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    topic: &'life1 str,
    partition: i32
) -> Pin<Box<dyn Future<Output = Result<Self::Leader, ClientError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Find address of the SPU leader for a topic/partition

fn delete_topic<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    topic: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<String, ClientError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn create_topic<'life0, 'async_trait>(
    &'life0 mut self,
    topic: String,
    replica: ReplicaConfig,
    validate_only: bool
) -> Pin<Box<dyn Future<Output = Result<String, ClientError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

create topic, for now we return string in order simply interface. Otherwise, we have to add associate type

fn topic_metadata<'life0, 'async_trait>(
    &'life0 mut self,
    topics: Option<Vec<String>>
) -> Pin<Box<dyn Future<Output = Result<Vec<Self::TopicMetadata>, ClientError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait,