Karma::Ingest

SUPPORTED_MODES = ["add", "set", "replace_series"] of ::String

abort(stream_id : String)

begin_stream(stream_id : String, mode : String, granularity : String | Nil, begin_fingerprint : String)

bind_series!(stream : Stream, series_name : String) : Stream

chunk_status(stream_id : String, chunk_seq : UInt64, fingerprint : String | Nil = nil, series_name : String | Nil = nil)

commit(stream_id : String, cluster)

mark_chunk(stream_id : String, chunk_seq : UInt64, fingerprint : String)

record_chunk(applied : Bool, skipped : Bool, item_count : Int32, latency_ms : Float64) : Nil

validate_chunk!(stream_id : String, chunk_seq : UInt64) : Stream

validate_stream_exists!(stream_id : String) : Stream