Karma
- Backup
  - SnapshotMetadata
- Cli
- ClientSession
- Cluster
  - ClusterType
- Commands
  - BatchAdd
  - BatchDeleteRange
  - BatchReset
  - BatchSet
  - BatchSum
  - Compact
  - Create
  - Decrement
  - Delete
  - DeleteBefore
  - Directive
  - Drop
  - Dump
  - DumpAll
  - Dumps
  - FastIncrementJob
  - Find
  - Health
  - IdempotencyPrune
  - IdempotencySnapshotFetchChunk
  - Increment
  - IngestAbort
  - IngestBegin
  - IngestChunk
  - IngestCommit
  - Load
  - Metrics
  - MultiSum
  - MultiSumItem
  - Ping
  - ReconciliationReport
  - RecoveryCheckpoint
  - RecoveryStatus
  - ReplicationEntries
  - ReplicationStatus
  - Reset
  - SnapshotFetch
  - SnapshotFetchChunk
  - SnapshotInfo
  - Stats
  - Sum
  - TreeInfo
  - TreeKeys
  - Trees
  - TreeSummary
  - TreeTop
  - Verify
- Config
- Error
- Idempotency
  - CommittedStream
  - Record
  - Result
  - SnapshotMetadata
  - SnapshotPayload
- Ingest
  - Stream
- Launcher
- Log
- Operations
- Protocol
- QueryDeadline
- Recovery
  - Checkpoint
  - Document
- Replication
  - Poller
    - Response
  - SnapshotClient
- Runtime
- Server
- Signals
- State
- TimeSeries
  - Bucket
  - BucketRange
  - Key
  - Series
- Wal
  - AppendJob
  - EntriesPage
  - Entry

Generated using Crystal 1.16.3
2026-06-14 03:12:46 UTC

module Karma::Commands::IngestBegin

Defined in:

commands/ingest/ingest_begin.cr

Class Method Summary

.call(directive, cluster)

Class Method Detail

def self.call(directive, cluster) #

[View source]