struct Karma::Commands::Directive

• Karma::Commands::Directive
• Struct
• Value
• Object

Included Modules

• JSON::Serializable

Defined in:

Constructors

• .new(pull : JSON::PullParser)
• .new(command : String, tree_name : String | Nil = nil, key : UInt64 | Nil = nil, keys : Array(UInt64) | Nil = nil, items : Array(Array(UInt64)) | Nil = nil, multi_sum_items : Array(MultiSumItem) | Nil = nil, time_from : UInt64 | Nil = nil, time_to : UInt64 | Nil = nil, date : UInt64 | Nil = nil, value : UInt64 | Nil = nil, token : String | Nil = nil, stream_id : String | Nil = nil, mode : String | Nil = nil, chunk_seq : UInt64 | Nil = nil, granularity : String | Nil = nil, limit : Int32 | Nil = nil, cursor : UInt64 | Nil = nil, after_lsn : UInt64 | Nil = nil, checked_points : Int64 | Nil = nil, mismatch_count : Int64 | Nil = nil, absolute_drift : Int64 | Nil = nil, max_abs_delta : Int64 | Nil = nil, source : String | Nil = nil, source_offset : String | Nil = nil, event_id : String | Nil = nil, idempotency_key : String | Nil = nil, fingerprint : String | Nil = nil, idempotency_created_at_unix : Int64 | Nil = nil, before_unix : Int64 | Nil = nil, protocol_version : UInt32 = Karma::Protocol::VERSION)

Instance Method Summary

• #absolute_drift : Int64 | Nil
• #absolute_drift=(absolute_drift : Int64 | Nil)
• #after_lsn : UInt64 | Nil
• #after_lsn=(after_lsn : UInt64 | Nil)
• #before_unix : Int64 | Nil
• #before_unix=(before_unix : Int64 | Nil)
• #bucket_from : Karma::TimeSeries::Bucket
• #bucket_range : Karma::TimeSeries::BucketRange
• #bucket_range? : Karma::TimeSeries::BucketRange | Nil
• #bucket_to : Karma::TimeSeries::Bucket
• #checked_points : Int64 | Nil
• #checked_points=(checked_points : Int64 | Nil)
• #chunk_seq : UInt64 | Nil
• #chunk_seq=(chunk_seq : UInt64 | Nil)
• #command : String
• #command=(command : String)
• #cursor : UInt64 | Nil
• #cursor=(cursor : UInt64 | Nil)
• #date : UInt64 | Nil
• #date=(date : UInt64 | Nil)
• #event_id : String | Nil
• #event_id=(event_id : String | Nil)
• #fingerprint : String | Nil
• #fingerprint=(fingerprint : String | Nil)
• #granularity : String | Nil
• #granularity=(granularity : String | Nil)
• #idempotency_created_at_unix : Int64 | Nil
• #idempotency_created_at_unix=(idempotency_created_at_unix : Int64 | Nil)
• #idempotency_key : String | Nil
• #idempotency_key=(idempotency_key : String | Nil)
• #items : Array(Array(UInt64)) | Nil
• #items=(items : Array(Array(UInt64)) | Nil)
• #key : UInt64 | Nil
• #key=(key : UInt64 | Nil)
• #key_value : UInt64
• #keyed? : Bool
• #keys : Array(UInt64) | Nil
• #keys=(keys : Array(UInt64) | Nil)
• #limit : Int32 | Nil
• #limit=(limit : Int32 | Nil)
• #max_abs_delta : Int64 | Nil
• #max_abs_delta=(max_abs_delta : Int64 | Nil)
• #mismatch_count : Int64 | Nil
• #mismatch_count=(mismatch_count : Int64 | Nil)
• #mode : String | Nil
• #mode=(mode : String | Nil)
• #multi_sum_items : Array(MultiSumItem) | Nil
• #multi_sum_items=(multi_sum_items : Array(MultiSumItem) | Nil)
• #protocol_version : UInt32
• #protocol_version=(protocol_version : UInt32)
• #series : Karma::TimeSeries::Series
• #series_key : Karma::TimeSeries::Key
• #series_name : String
• #source : String | Nil
• #source=(source : String | Nil)
• #source_offset : String | Nil
• #source_offset=(source_offset : String | Nil)
• #stream_id : String | Nil
• #stream_id=(stream_id : String | Nil)
• #time_from : UInt64 | Nil
• #time_from=(time_from : UInt64 | Nil)
• #time_to : UInt64 | Nil
• #time_to=(time_to : UInt64 | Nil)
• #token : String | Nil
• #token=(token : String | Nil)
• #tree_name : String | Nil
• #tree_name=(tree_name : String | Nil)
• #value : UInt64 | Nil
• #value=(value : UInt64 | Nil)
• #write_bucket : Karma::TimeSeries::Bucket
• #write_value : UInt64

Constructor Detail

Instance Method Detail