Kvasir.Storage behaviour (kvasir v0.0.15) View Source

Link to this section Summary

Link to this section Callbacks

Specs

child_spec(name :: atom(), opts :: Keyword.t()) :: false | map()
Link to this callback

contains?(name, arg2, arg3)

View Source

Specs

contains?(name :: atom(), Kvasir.topic(), Kvasir.Offset.t()) ::
  :maybe | true | false
Link to this callback

freeze(name, arg2, event)

View Source

Specs

freeze(name :: atom(), Kvasir.Topic.t(), event :: map()) ::
  :ok | {:error, atom()}

Specs

offsets(name :: atom(), Kvasir.topic()) ::
  {:ok, Kvasir.Offset.t()} | {:error, atom()}

Specs

stream(name :: atom(), Kvasir.topic()) :: {:ok, Stream.t()} | {:error, atom()}