Provides an interface for managing a Fluvio cluster
Check to ensure this.client has been set. This method is used internally to check the connection status of the client before calling a method using the internal client.
Optionally pass in connection host options (e.g. { host: '' }) uses the partial Options type; This does not override the default options, only replaces default options in this case;
Creates a new PartitionConsumer for the given topic and partition
Currently, consumers are scoped to both a specific Fluvio topic and to a particular partition within that topic. That means that if you have a topic with multiple partitions, then in order to receive all of the events in all of the partitions, you will need to create one consumer per partition.
topic string
partition id
Creates a new TopicProducer for the given topic name
Currently, producers are scoped to a specific Fluvio topic. That means when you send events via a producer, you must specify which partition each event should go to.
Name of the topic to create a producer for
Generated using TypeDoc
Fluvio TypeScript / NodeJS Client
Overview
The NodeJS client for communicating with Fluvio clusters.
Example Construction
Uses Node Native Modules
TypeScript wrapper around native fluvio core module written in Rust.
Core module is generated from node-bindgen. This TypeScript wrapper provides type definitions and generates the JavaScript client.