View Source MyClient (Klife v0.5.0)

Example test client

Summary

Returns a specification to start this module under a supervisor.

Callback implementation for Klife.Client.produce/2.

Callback implementation for Klife.Client.transaction/2.

Returns a specification to start this module under a supervisor.

@spec produce(Klife.Record.t(), opts :: list() | nil) ::
  {:ok, Klife.Record.t()} | {:error, Klife.Record.t()}

Callback implementation for Klife.Client.produce/2.

@spec produce_async(Klife.Record.t(), opts :: list() | nil) :: :ok

@spec produce_batch([Klife.Record.t()], opts :: list() | nil) :: [
  ok: Klife.Record.t(),
  error: Klife.Record.t()
]

@spec produce_batch_async(Klife.Record.t(), opts :: list() | nil) :: :ok

@spec produce_batch_txn([Klife.Record.t()], opts :: list() | nil) ::
  [{:ok, [Klife.Record.t()]}] | [{:error, [Klife.Record.t()]}]

@spec transaction(function(), opts :: list() | nil) :: any()

Callback implementation for Klife.Client.transaction/2.