fluvio v0.2.4

View Source Fluvio.Admin (fluvio v0.2.4)

Fluvio Admin cluster functionalities. This module is backed by a GenServer.

Link to this section Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

create_topic(pid, name, options \\ %{partitions: 1, replication: 1, ignore_rack: false})

Creates a topic.

delete_topic(pid, name)

Deletes a topic.

start_link(gen_opts \\ [], native_mod \\ Fluvio.Native)

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

Link to this section Functions

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

create_topic(pid, name, options \\ %{partitions: 1, replication: 1, ignore_rack: false})

View Source 
@spec create_topic(pid(), bitstring(), map()) :: {atom(), any()}

Creates a topic.

Link to this function

delete_topic(pid, name)

View Source 
@spec delete_topic(pid(), bitstring()) :: {atom(), any()}

Deletes a topic.

Link to this function

start_link(gen_opts \\ [], native_mod \\ Fluvio.Native)

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

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