Interface FluvioClient

interface FluvioClient {
    admin(): Promise<FluvioAdmin>;
    connect(options?: Partial<Options>): Promise<FluvioClient>;
    partitionConsumer(topic: string, partition: number): Promise<PartitionConsumer>;
    topicProducer(topic: string): Promise<TopicProducer>;
}

Implemented by

default

Index

Methods

admin connect partitionConsumer topicProducer

Methods

admin

admin(): Promise<FluvioAdmin>
Returns Promise<FluvioAdmin>
- Defined in index.ts:532

connect

connect(options?): Promise<FluvioClient>
Parameters
- Optionaloptions: Partial<Options>
Returns Promise<FluvioClient>
- Defined in index.ts:525

partitionConsumer

partitionConsumer(topic, partition): Promise<PartitionConsumer>
Parameters
- topic: string
- partition: number
Returns Promise<PartitionConsumer>
- Defined in index.ts:528

topicProducer

topicProducer(topic): Promise<TopicProducer>
Parameters
- topic: string
Returns Promise<TopicProducer>
- Defined in index.ts:527