struct
Karma::Idempotency::CommittedStream
- Karma::Idempotency::CommittedStream
- Struct
- Value
- Object
Included Modules
- JSON::Serializable
Defined in:
idempotency/committed_stream.crConstructors
- .new(stream_id : String, mode : String, granularity : String | Nil, series_name : String | Nil, last_chunk_seq : UInt64, begin_fingerprint : String, chunk_fingerprints : Hash(UInt64, String), committed_at_unix : Int64)
- .new(pull : JSON::PullParser)
Instance Method Summary
- #begin_fingerprint : String
- #chunk_fingerprints : Hash(UInt64, String)
- #committed_at_unix : Int64
- #compatible_begin?(mode : String, granularity : String | Nil) : Bool
- #compatible_chunk?(chunk_seq : UInt64, fingerprint : String, series_name : String) : Bool
- #granularity : String | Nil
- #last_chunk_seq : UInt64
- #mode : String
- #series_name : String | Nil
- #stream_id : String
- #to_status(status : String)
Constructor Detail
def self.new(stream_id : String, mode : String, granularity : String | Nil, series_name : String | Nil, last_chunk_seq : UInt64, begin_fingerprint : String, chunk_fingerprints : Hash(UInt64, String), committed_at_unix : Int64)
#
Instance Method Detail
def compatible_chunk?(chunk_seq : UInt64, fingerprint : String, series_name : String) : Bool
#