calvinlfer/etl-workflow

Stars
2
Language
Scala
Created over 6 years ago
Updated about 6 years ago

calvinlfer/etl-workflow

calvinlfer

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

An opinionated way to structure ETL pipelines with a heavy focus on reusability and testing

akka-http-streaming-response-examples

A list of examples that involve streaming with Akka Streams and used together with Akka HTTP

Akka-HTTP-Akka-Streams-Akka-Actors-Integration

Streaming Chuck Norris jokes in JSON as Server Sent Events using Akka Steams, Akka HTTP and Akka Actors

Akka-Persistence-example-with-Protocol-Buffers-serialization

A simple example that demonstrates the usage of Akka Persistence along with Protocol Buffers as the serialization mechanism

akka-streams-interleaving

Akka Streams example of how to interleave Sources with priorities

tagless-final-example

An example of how to create services using tagless final

es-cqrs-shopping-cart

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)

websockets-pubsub-akka

WebSockets and Publish-Subscribe with Akka

compose-cassandra-cluster

A Docker Compose blueprint describing the creation of a 3 node cluster

free-monads-functional-web-apps

Delving into Free Monads and using them to write pure functional web applications

Akka-Persistence-Schema-Evolution-Example

This example is intended to demonstrate how to perform Schema Evolution without using an encoding mechanism that supports schema evolution (e.g. Protocol Buffers, Avro and Thrift).

Kafka-Akka-HTTP-and-Akka-Streams-integration

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.

Akka-Streams-custom-stream-processing-examples

Demos of how to do custom stream processing using the Akka Streams GraphStages API

akka-cluster-sample

A sample Akka Cluster application that uses ZooKeeper for service discovery

skull-island

A tool for 'diffable' Kong API Gateway configuration

akka-cluster-docker-swarm

Deploying a multi-node Akka Cluster to a Docker Swarm

Play-Framework-Cassandra-Example

An example that shows how you can integrate Cassandra with Play Framework

Play-Framework-DynamoDB-example

A simplistic Play Framework application providing a REST API for the persons. It makes use of Google Guice injection along with DynamoDB through the use of Scanamo.

akka-http-streaming-client-and-server

Examples showing how to perform streaming requests and responses using Akka HTTP along with some bonuses

tyrian-chartjs-interop-example

This is an example of how to use Chart.JS and integrate it with Tyrian

docker-nexus3-oss

A Sonatype Nexus3 OSS image which makes it easy to do volume mounting

Akka-persistence-example-with-custom-serializer

streaming-analytics

A streaming data pipeline to perform basic analytics with scalability in mind

free-monad-coproduct-example

Free Monad composition using Monad Coproducts from FreeK

cassandra-ebs-cloudformation

A CloudFormation blueprint to materialize a 3 node Cassandra cluster backed by EBS

alpakka-cassandra-sink-usage

A demonstration of how to use the Alpakka Cassandra Sink to push case classes through to a Cassandra Table

wallet-api

An implementation of an API for wallet built using Akka (HTTP, Cluster Sharding, Event Sourcing) and ZIO

rate-limiting-and-gating-akka

An example (from Reactive Design Patterns) that shows how to do rate-limiting and gating on a per-client basis using Akka

node-aws-examples

Node.JS Examples using the AWS SDK to perform management/other tasks

twitter-streams-example

Playing around with the Play Framework, Iteratees and Akka Streams

actors-and-streams

Yet another example showing how to use `Sink.actorRef` but with the added twist of using timers

reactive-s3-sqs-extended-library

The S3 SQS extended library built on Alpakka with configurable delivery semantics

Weather-Manager

A simple Weather Manager application using Akka HTTP and DynamoDB that interacts with OpenWeather

ecs-cluster-akka

An AWS CloudFormation template to launch an autoscaling ECS Cluster with an ALB to run Akka apps

scala3-runthrough

account-experiment

restify-dynamodb-example

play-framework-validation-example

A minimal example showing how to serialize JSON => Scala and vice versa with additional field validation and tests

shapeless-guide-runthrough

sample-node-docker

A sample application showing how to dockerize a Node.JS web application

fill-in-the-blanks

A very simple command line tool that takes opinionated template files and data and generates an output file

kafka-zio-integration-leak-reproducer

A repository that contains small applications that integrate with FS2 Kafka and ZIO Kafka to determine if there are memory leaks