immudb_elixir v0.2.0

Immudb.Stream (immudb_elixir v0.2.0)

Link to this section Summary

Functions

stream_exec_all(channel, params)
stream_get(arg1, arg2)
stream_history(arg1, key, arg3)
stream_scan(arg1, arg2)
stream_set(channel, params)
stream_verifiable_get(arg1, arg2)
stream_verifiable_set(channel, params)
stream_z_scan(channel, params)

Link to this section Functions

Link to this function

stream_exec_all(channel, params)

Link to this function

stream_get(arg1, arg2)

@spec stream_get(Immudb.Socket.t(),
  key: String.t(),
  at_tx: integer(),
  since_tx: integer()
) ::
  {:error, String.t() | atom()} | {:ok, nil}
Link to this function

stream_history(arg1, key, arg3)

@spec stream_history(Immudb.Socket.t(), binary(),
  offset: integer(),
  limit: integer(),
  desc: boolean(),
  since_tx: integer()
) :: {:error, String.t() | atom()} | {:ok, Immudb.Schemas.Entries.t()}
Link to this function

stream_scan(arg1, arg2)

@spec stream_scan(Immudb.Socket.t(),
  seek_key: binary(),
  prefix: binary(),
  desc: binary(),
  limit: integer(),
  since_tx: binary(),
  no_wait: boolean()
) :: {:error, String.t() | atom()} | {:ok, Entries.t()}
Link to this function

stream_set(channel, params)

Link to this function

stream_verifiable_get(arg1, arg2)

@spec stream_verifiable_get(Immudb.Socket.t(),
  key: String.t(),
  at_tx: integer(),
  since_tx: integer(),
  prove_since_tx: integer()
) :: {:error, String.t() | atom()} | {:ok, nil}
Link to this function

stream_verifiable_set(channel, params)

Link to this function

stream_z_scan(channel, params)