module Karma::Ingest

Defined in:

ingest.cr
ingest/metrics.cr
ingest/registry.cr
ingest/stream.cr

Constant Summary

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

Class Method Summary

• .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)
• .metrics
• .record_chunk(applied : Bool, skipped : Bool, item_count : Int32, latency_ms : Float64) : Nil
• .record_rejected_chunk : Nil
• .reset! : Nil
• .validate_chunk!(stream_id : String, chunk_seq : UInt64) : Stream
• .validate_stream_exists!(stream_id : String) : Stream

Class Method Detail