Packages

fluvio

0.1.0
0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.0

Elixir client for Fluvio streaming platform

HexDocs

Current section

Files

Jump to
Readme
7 Versions
1 Dependency
Dependants
Files
Activity
fluvio lib fluvio native.ex
Raw

lib/fluvio/native.ex 

defmodule Fluvio.Native do

  use Rustler, otp_app: :fluvio, crate: "fluvio_ex"



  def connect(), do: :erlang.nif_error(:nif_not_loaded)

  def new_consumer(_fluvio_ref, _topic, _partition, _offset_from, _offset_value),

    do: :erlang.nif_error(:nif_not_loaded)



  def new_producer(_fluvio_ref, _topic), do: :erlang.nif_error(:nif_not_loaded)

  def send(_producer_ref, _key, _value), do: :erlang.nif_error(:nif_not_loaded)

  def flush(_producer_ref), do: :erlang.nif_error(:nif_not_loaded)

  def next(_consumer_ref, _secs_timeout), do: :erlang.nif_error(:nif_not_loaded)

end