fluvio._fluvio_python

class Fluvio:
def connect():
def connect_with_config(config):
def consumer_with_config(self, /, config):
def partition_consumer(self, /, topic, partition):
def multi_partition_consumer(self, /, strategy):
def topic_producer(self, /, topic):
class FluvioConfig:
def load():

Load config file from default config dir

def new(addr):

Create without tls

def set_endpoint(self, /, endpoint):
def set_use_spu_local_address(self, /, val):
def disable_tls(self, /):
def set_anonymous_tls(self, /):
def set_inline_tls(self, /, domain, key, cert, ca_cert):
def set_tls_file_paths(self, /, domain, key_path, cert_path, ca_cert_path):
def set_client_id(self, /, id):
def unset_client_id(self, /):
class ConsumerConfig:
def max_bytes(self, /, max_bytes):
def disable_continuous(self, /, setting):
def smartmodule( self, /, name, path, kind, param_keys, param_values, aggregate_accumulator, context=None, join_param=None, join_topic=None, join_derived_stream=None):
def build(self, /):
class ConsumerConfigExt:
class ConsumerConfigExtBuilder:
def disable_continuous(self, /, val=True):

the fluvio client should disconnect after fetching the specified records

def max_bytes(self, /, max_bytes):
def offset_start(self, /, offset):
def offset_consumer(self, /, id):
def offset_strategy(self, /, strategy=Ellipsis):
def partition(self, /, partition):
def topic(self, /, topic):
def build(self, /):
class OffsetManagementStrategy:
NONE = <builtins.OffsetManagementStrategy object>
MANUAL = <builtins.OffsetManagementStrategy object>
AUTO = <builtins.OffsetManagementStrategy object>
class PartitionConsumer:
def stream(self, /, offset):
def async_stream(self, /, offset):
def stream_with_config(self, /, offset, config):
def async_stream_with_config(self, /, offset, config):
class PartitionConsumerStream:
def next(self, /):
class AsyncPartitionConsumerStream:
def async_next(self, /):
class TopicProducer:
def send(self, /, key, value):
def async_send(self, /, key, value):
def send_all(self, /, records):
def async_send_all(self, /, records):
def flush(self, /):
def async_flush(self, /):
class ProduceOutput:
def wait(self, /):
def async_wait(self, /):
class RecordMetadata:
def offset(self, /):
def partition_id(self, /):
class ProducerBatchRecord:
class SmartModuleKind:
class Record:
def value_string(self, /):
def key_string(self, /):
def offset(self, /):
def value(self, /):
def key(self, /):
def timestamp(self, /):
class Offset:

Describes the location of a record stored in a Fluvio partition.

def absolute(index):

Specifies an absolute offset with the given index

def beginning():

Specifies an offset starting at the beginning of the saved log

def from_beginning(offset):

Specifies an offset relative to the beginning of the saved log

def end():

Specifies an offset relative to the beginning of the saved log

def from_end(offset):
class Cloud:
def login_with_username(remote, profile=None, email=None, password=None):
class MultiplePartitionConsumer:
def stream(self, /, offset):
def async_stream(self, /, offset):
def stream_with_config(self, /, offset, config):
def async_stream_with_config(self, /, offset, config):
class PartitionSelectionStrategy:
def with_all(topic):
def with_multiple(selections):
class FluvioAdmin:
def connect():
def connect_with_config(config):
def create_topic(self, /, name, dry_run, spec):
def create_topic_with_config(self, /, rq, spec):
def delete_topic(self, /, name):
def all_topics(self, /):
def list_topics(self, /, filters):
def list_topics_with_params(self, /, filters, summary):
def watch_topic(self, /):
def create_smart_module(self, /, name, dry_run, spec):
def delete_smart_module(self, /, name):
def list_smart_modules(self, /, filters):
def watch_smart_module(self, /):
def list_partitions(self, /, filters):
class TopicSpec:
def new_assigned(maps):
def new_computed(partitions, replications, ignore=None):
class PartitionMap:
def new(partition, replicas):
class CommonCreateRequest:
def new(name, dry_run, timeout=None):
class MetadataTopicSpec:
def name(self, /):
class WatchTopicStream:
def next(self, /):
class MetaUpdateTopicSpec:
def epoch(self, /):
def changes(self, /):
def all(self, /):
class MessageMetadataTopicSpec:
def is_update(self, /):
def is_delete(self, /):
def metadata_topic_spec(self, /):
class SmartModuleSpec:
def with_binary(bytes):
class MetadataSmartModuleSpec:
def name(self, /):
class WatchSmartModuleStream:
def next(self, /):
class MessageMetadataSmartModuleSpec:
def is_update(self, /):
def is_delete(self, /):
def metadata_smart_module_spec(self, /):
class MetaUpdateSmartModuleSpec:
def epoch(self, /):
def changes(self, /):
def all(self, /):
class MetadataPartitionSpec:
def name(self, /):
Error = <class 'mymodule.PyFluvioError'>
def fluvio_consumer_with_config(fluvio, config):