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>;
    topicProducerWithConfig(topic: string, config: TopicProducerConfig): Promise<TopicProducer>;
}

Implemented by

default

Index

Methods

admin connect partitionConsumer topicProducer topicProducerWithConfig

Methods

admin

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

connect

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

partitionConsumer

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

topicProducer

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

topicProducerWithConfig

topicProducerWithConfig(topic, config): Promise<TopicProducer>
Parameters
- topic: string
- config: TopicProducerConfig
Returns Promise<TopicProducer>
- Defined in index.ts:560