Database.Franz.Writer

Writer interface

data WriterHandle (f :: Type -> Type)

Instances

NFData (WriterHandle f)

Defined in Database.Franz.Writer

Methods

rnf :: WriterHandle f -> ()

openWriter

Arguments

:: Foldable f

=> f String

index names: a fixed-length collection of the names of indices for this stream. Use Proxy if you don't want any indices. If you want only one type of index, use `Identity ""`.

-> FilePath

-> IO (WriterHandle f)

closeWriter :: WriterHandle f -> IO ()

Flush any pending data and close a WriterHandle.

withWriter :: Foldable f => f String -> FilePath -> (WriterHandle f -> IO a) -> IO a

write

Arguments

:: Foldable f

=> WriterHandle f

-> f Int64

index values

-> Builder

payload

-> IO Int

flush :: WriterHandle f -> IO ()

Flush the changes.

getLastSeqNo :: WriterHandle f -> IO Int

Get the sequential number of the last item item written.