module Karma::Commands

Defined in:

command.cr
commands/counter/batch_add.cr
commands/counter/batch_delete_range.cr
commands/counter/batch_reset.cr
commands/counter/batch_set.cr
commands/counter/batch_sum.cr
commands/counter/decrement.cr
commands/counter/delete.cr
commands/counter/find.cr
commands/counter/increment.cr
commands/counter/multi_sum.cr
commands/counter/reset.cr
commands/counter/sum.cr
commands/directive.cr
commands/idempotency/prune.cr
commands/idempotency/snapshot_fetch_chunk.cr
commands/ingest/ingest_abort.cr
commands/ingest/ingest_begin.cr
commands/ingest/ingest_chunk.cr
commands/ingest/ingest_commit.cr
commands/parser.cr
commands/registry.cr
commands/request_fields.cr
commands/snapshot/dump.cr
commands/snapshot/dump_all.cr
commands/snapshot/dumps.cr
commands/snapshot/load.cr
commands/snapshot/snapshot_fetch.cr
commands/snapshot/snapshot_fetch_chunk.cr
commands/snapshot/snapshot_info.cr
commands/system/health.cr
commands/system/metrics.cr
commands/system/ping.cr
commands/system/reconciliation_report.cr
commands/system/recovery_checkpoint.cr
commands/system/recovery_status.cr
commands/system/replication_entries.cr
commands/system/replication_status.cr
commands/system/stats.cr
commands/system/verify.cr
commands/tree/compact.cr
commands/tree/create.cr
commands/tree/delete_before.cr
commands/tree/drop.cr
commands/tree/tree_info.cr
commands/tree/tree_keys.cr
commands/tree/tree_summary.cr
commands/tree/tree_top.cr
commands/tree/trees.cr
commands/v2_parser.cr
commands/validation_rules.cr
commands/validator.cr

Constant Summary

COMMANDS = {"trees" => Commands::Trees, "create" => Commands::Create, "drop" => Commands::Drop, "dump" => Commands::Dump, "dump_all" => Commands::DumpAll, "dumps" => Commands::Dumps, "load" => Commands::Load, "increment" => Commands::Increment, "decrement" => Commands::Decrement, "sum" => Commands::Sum, "batch_sum" => Commands::BatchSum, "multi_sum" => Commands::MultiSum, "batch_add" => Commands::BatchAdd, "batch_set" => Commands::BatchSet, "batch_reset" => Commands::BatchReset, "batch_delete_range" => Commands::BatchDeleteRange, "delete_before" => Commands::DeleteBefore, "compact" => Commands::Compact, "find" => Commands::Find, "reset" => Commands::Reset, "delete" => Commands::Delete, "health" => Commands::Health, "stats" => Commands::Stats, "metrics" => Commands::Metrics, "verify" => Commands::Verify, "reconciliation_report" => Commands::ReconciliationReport, "recovery_checkpoint" => Commands::RecoveryCheckpoint, "recovery_status" => Commands::RecoveryStatus, "replication_status" => Commands::ReplicationStatus, "replication_entries" => Commands::ReplicationEntries, "idempotency_prune" => Commands::IdempotencyPrune, "idempotency_snapshot_fetch_chunk" => Commands::IdempotencySnapshotFetchChunk, "ping" => Commands::Ping, "tree_info" => Commands::TreeInfo, "tree_keys" => Commands::TreeKeys, "tree_summary" => Commands::TreeSummary, "tree_top" => Commands::TreeTop, "snapshot_info" => Commands::SnapshotInfo, "snapshot_fetch" => Commands::SnapshotFetch, "snapshot_fetch_chunk" => Commands::SnapshotFetchChunk, "ingest_begin" => Commands::IngestBegin, "ingest_chunk" => Commands::IngestChunk, "ingest_commit" => Commands::IngestCommit, "ingest_abort" => Commands::IngestAbort}

MUTATING_COMMANDS = ["create", "drop", "increment", "decrement", "delete", "reset", "batch_reset", "batch_set", "batch_delete_range", "batch_add", "delete_before", "compact", "ingest_begin", "ingest_chunk", "ingest_commit", "ingest_abort", "recovery_checkpoint", "idempotency_prune"] of ::String

READ_ONLY_COMMANDS = ["ping", "trees", "dumps", "health", "stats", "metrics", "verify", "sum", "batch_sum", "multi_sum", "find", "tree_info", "tree_keys", "tree_summary", "tree_top", "snapshot_info", "snapshot_fetch", "snapshot_fetch_chunk", "recovery_status", "replication_status", "replication_entries", "idempotency_snapshot_fetch_chunk"] of ::String

Class Method Summary

• .call(message, cluster, persist = true, authorize = true, synchronize = true, enforce_request_size = true, enforce_role = true)
• .known?(directive : Directive) : Bool
• .mutating?(directive : Directive) : Bool
• .parse(message : String) : Directive
• .read_only?(directive : Directive) : Bool

Class Method Detail