examples/

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

Links

Open Source Insights

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
mongo-cdc-orderstats Package orderstats defines a Murmur pipeline that aggregates per-customer order totals from a Mongo collection (Bootstrap mode) and a Kafka CDC stream (Live mode).	Package orderstats defines a Murmur pipeline that aggregates per-customer order totals from a Mongo collection (Bootstrap mode) and a Kafka CDC stream (Live mode).
cmd/bootstrap command Bootstrap binary for the mongo-cdc-orderstats example.	Bootstrap binary for the mongo-cdc-orderstats example.
cmd/worker command Live streaming worker for the mongo-cdc-orderstats example.	Live streaming worker for the mongo-cdc-orderstats example.
page-view-counters Package pageviews defines the page-view-counters Murmur pipeline.	Package pageviews defines the page-view-counters Murmur pipeline.
cmd/query command Connect-RPC query server for the page-view-counters example.	Connect-RPC query server for the page-view-counters example.
cmd/worker command Streaming worker for the page-view-counters example.	Streaming worker for the page-view-counters example.
recently-interacted-topk Package recentlyinteracted defines a TopK "recently interacted" pipeline fed by TWO sources at once: a Segment-style Kinesis stream (consumed via an AWS Lambda trigger) and an internal Kafka topic (consumed by a long-lived ECS streaming worker).	Package recentlyinteracted defines a TopK "recently interacted" pipeline fed by TWO sources at once: a Segment-style Kinesis stream (consumed via an AWS Lambda trigger) and an internal Kafka topic (consumed by a long-lived ECS streaming worker).
cmd/lambda command Lambda binary for the recently-interacted-topk example.	Lambda binary for the recently-interacted-topk example.
cmd/query command Connect-RPC query server for the recently-interacted-topk example.	Connect-RPC query server for the recently-interacted-topk example.
cmd/worker command Streaming worker binary for the recently-interacted-topk example.	Streaming worker binary for the recently-interacted-topk example.
search-projector Package projector is the runnable Pattern B reference implementation from doc/search-integration.md.	Package projector is the runnable Pattern B reference implementation from doc/search-integration.md.
cmd/projector command Lambda binary for the search-projector example.	Lambda binary for the search-projector example.
search-rerank Package rerank is the runnable Pattern A reference implementation from doc/search-integration.md.	Package rerank is the runnable Pattern A reference implementation from doc/search-integration.md.
cmd/server command HTTP server fronting the rerank service.	HTTP server fronting the rerank service.
typed-rpc-codegen
bot-interactions/_expected
typed-wrapper Package wrapper is a count-core-shaped example showing how to expose Murmur counter pipelines through your application's OWN typed Connect-RPC service rather than the generic Value{bytes} shape.	Package wrapper is a count-core-shaped example showing how to expose Murmur counter pipelines through your application's OWN typed Connect-RPC service rather than the generic Value{bytes} shape.