View Source Fluvio (fluvio v0.2.4)

This module provides high-level Fluvio interface for cluster functionalities.

Link to this section Summary

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

Gets the platform version of the connected cluster.

Starts a GenServer process linked to the current process connected to Fluvio cluster.

Returns a specification to start this module under a supervisor.

@spec platform_version(pid()) :: {atom(), any()}

Gets the platform version of the connected cluster.

@spec start_link(list(), any()) :: GenServer.on_start()

Starts a GenServer process linked to the current process connected to Fluvio cluster.