Sign in

Repository Index

47,133 repositories indexed

Tag: Data pipelines and messaging
Tag
Filters

Filters

Clear all filters

1–24 of 27 · Most stars

Apache Airflow - A platform to programmatically author, schedule, and monitor workflows

Apache Beam is a unified programming model for Batch and Streaming data processing.

Compositional, streaming I/O library for Scala

  • scala
  • stream
  • streaming-computation
  • fp

Probabilistic data structures for processing continuous, unbounded streams.

  • bloom-filter
  • go
  • stable-bloom-filters
  • cuckoo-filter

🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications

An implementation of Actor, Publish-Subscribe, and CSP models in one rather small C++ framework. With performance, quality, and stability proved by years in the production.

  • cpp
  • cplusplus
  • cplusplus-17
  • actor-model

A state-of-the-art distributed system using Reactive DDD as uncertainty modeling, Event Storming as subdomain decomposition, Event Sourcing as an eventual persistence mechanism, CQRS, Async Projections, Microservices for individual deployable units, Event-driven Architecture for efficient integration, and Clean Architecture as domain-centric design

[Go]Distributed Actor/Grain framework for Golang with goodies

  • actor-model
  • actors
  • actorsystem
  • golang

Monad, Functional Programming features for Golang

  • golang
  • functional-programming
  • functional-reactive-programming
  • reactive

A Simplest in-memory and Distributed Storage-Agnostic Message Queue for Your Concurrent Go Program

A refined core library for D programming language. The module has concurrency / collections / event / io / logging / text / serialization and more.

Scramjet Platform is a distributed runtime supervisor that can run data processing programs called Sequences and manage local resources on any Linux server, Docker on small edge servers, and even large-scale Kubernetes clusters in the cloud or datacenters without exposing network ports to the public internet.

A simple embeddable scripting language which supports concurrent event processing.