Karma::Commands::Directive

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)

new(*, __pull_for_json_serializable pull : JSON::PullParser)

absolute_drift=(absolute_drift : Int64 | Nil)

after_lsn=(after_lsn : UInt64 | Nil)

before_unix=(before_unix : Int64 | Nil)

checked_points=(checked_points : Int64 | Nil)

chunk_seq=(chunk_seq : UInt64 | Nil)

command=(command : String)

cursor=(cursor : UInt64 | Nil)

date=(date : UInt64 | Nil)

event_id=(event_id : String | Nil)

fingerprint=(fingerprint : String | Nil)

granularity=(granularity : String | Nil)

idempotency_created_at_unix=(idempotency_created_at_unix : Int64 | Nil)

idempotency_key=(idempotency_key : String | Nil)

items=(items : Array(Array(UInt64)) | Nil)

key=(key : UInt64 | Nil)

keys=(keys : Array(UInt64) | Nil)

limit=(limit : Int32 | Nil)

max_abs_delta=(max_abs_delta : Int64 | Nil)

mismatch_count=(mismatch_count : Int64 | Nil)

mode=(mode : String | Nil)

multi_sum_items=(multi_sum_items : Array(MultiSumItem) | Nil)

protocol_version=(protocol_version : UInt32)

source=(source : String | Nil)

source_offset=(source_offset : String | Nil)

stream_id=(stream_id : String | Nil)

time_from=(time_from : UInt64 | Nil)

time_to=(time_to : UInt64 | Nil)

token=(token : String | Nil)

tree_name=(tree_name : String | Nil)

value=(value : UInt64 | Nil)