class Karma::Ingest::Stream

• Karma::Ingest::Stream
• Reference
• Object

Defined in:

ingest/stream.cr

Constructors

• .new(stream_id : String, mode : String, granularity : String | Nil, begin_fingerprint : String)

Instance Method Summary

• #begin_fingerprint : String
• #begin_fingerprint=(begin_fingerprint : String)
• #chunk_fingerprints : Hash(UInt64, String)
• #granularity : String | Nil
• #last_chunk_seq : UInt64
• #last_chunk_seq=(last_chunk_seq : UInt64)
• #mode : String
• #series_name : String | Nil
• #series_name=(series_name : String | Nil)
• #staged_tree : CounterTree::Tree | Nil
• #staged_tree=(staged_tree : CounterTree::Tree | Nil)
• #stream_id : String

Constructor Detail

Instance Method Detail