Struct flv_client::KfClient

pub struct KfClient<A>(_);

Methods

impl<A> KfClient<A>

pub fn mut_client(&mut self) -> &mut Client<A>

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

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

pub async fn query_metadata<'_>(
    &'_ mut self,
    topics: Option<Vec<String>>
) -> Result<KfMetadataResponse, KfSocketError>

pub async fn list_offsets<'_, '_, '_>(
    &'_ mut self,
    topic_name: &'_ str,
    leader: &'_ LeaderParam
) -> Result<KfListOffsetResponse, KfSocketError>

pub async fn offsets_fetch<'_, '_, '_, '_>(
    &'_ mut self,
    group_id: &'_ str,
    topic_name: &'_ str,
    tp_param: &'_ TopicPartitionParam
) -> Result<KfOffsetFetchResponse, KfSocketError>

pub async fn group_coordinator<'_, '_>(
    &'_ mut self,
    group_id: &'_ str
) -> Result<KfFindCoordinatorResponse, KfSocketError>

pub async fn send_heartbeat<'_, '_, '_>(
    &'_ mut self,
    group_id: &'_ str,
    member_id: &'_ str,
    generation_id: i32
) -> Result<KfHeartbeatResponse, KfSocketError>

pub async fn join_group<'_, '_, '_, '_>(
    &'_ mut self,
    topic_name: &'_ str,
    group_id: &'_ str,
    member_id: &'_ str
) -> Result<KfJoinGroupResponse, KfSocketError>

pub async fn leave_group<'_, '_, '_>(
    &'_ mut self,
    group_id: &'_ str,
    member_id: &'_ str
) -> Result<KfLeaveGroupResponse, KfSocketError>

pub async fn kf_fetch_logs<'_, '_>(
    &'_ mut self,
    fetch_log_param: &'_ FetchLogsParam
) -> Result<DefaultKfFetchResponse, KfSocketError>

Fetch log records from a target server

pub async fn sync_group<'_, '_, '_, '_>(
    &'_ mut self,
    topic_name: &'_ str,
    group_id: &'_ str,
    member_id: &'_ str,
    generation_id: i32
) -> Result<KfSyncGroupResponse, KfSocketError>

Trait Implementations

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

type Leader = KfLeader

type TopicMetadata = MetadataResponseTopic

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 Broker 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,