Directories
¶
| Path | Synopsis |
|---|---|
|
Package bootstrap drives a Murmur pipeline in Bootstrap mode: it reads from a SnapshotSource (Mongo collection scan, DynamoDB ParallelScan, etc.), applies the pipeline's key/value extractors and monoid Combine, and writes to the primary state store — populating initial state when the live event stream lacks full history.
|
Package bootstrap drives a Murmur pipeline in Bootstrap mode: it reads from a SnapshotSource (Mongo collection scan, DynamoDB ParallelScan, etc.), applies the pipeline's key/value extractors and monoid Combine, and writes to the primary state store — populating initial state when the live event stream lacks full history. |
|
lambda
|
|
|
dynamodbstreams
Package dynamodbstreams hosts a Murmur pipeline behind an AWS Lambda DynamoDB Streams trigger.
|
Package dynamodbstreams hosts a Murmur pipeline behind an AWS Lambda DynamoDB Streams trigger. |
|
kinesis
Package kinesis hosts a Murmur pipeline behind an AWS Lambda Kinesis trigger.
|
Package kinesis hosts a Murmur pipeline behind an AWS Lambda Kinesis trigger. |
|
sqs
Package sqs hosts a Murmur pipeline behind an AWS Lambda SQS trigger.
|
Package sqs hosts a Murmur pipeline behind an AWS Lambda SQS trigger. |
|
Package processor is the shared per-record processing core that every Murmur runtime delegates to.
|
Package processor is the shared per-record processing core that every Murmur runtime delegates to. |
|
Package replay drives a Murmur pipeline in Replay mode: it consumes historical events from a replay.Driver (typically S3-archived Firehose/Kafka-Connect output, or a Kafka offset range under tiered storage) and applies the same monoid Combine the live runtime would.
|
Package replay drives a Murmur pipeline in Replay mode: it consumes historical events from a replay.Driver (typically S3-archived Firehose/Kafka-Connect output, or a Kafka offset range under tiered storage) and applies the same monoid Combine the live runtime would. |
|
Package streaming runs a Murmur Pipeline in Live mode: it reads records from the pipeline's Source, applies the user's key/value extractors and monoid Combine, writes to the primary state store (and optionally a cache), and Acks the source record.
|
Package streaming runs a Murmur Pipeline in Live mode: it reads records from the pipeline's Source, applies the user's key/value extractors and monoid Combine, writes to the primary state store (and optionally a cache), and Acks the source record. |
Click to show internal directories.
Click to hide internal directories.