AnyMindGroup/zio-pubsub

Google Cloud Pub/Sub client for ZIO and ZIO Streams

Language: Scala - Size: 1.67 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 2 - Forks: 2

laserdisc-io/tamer

Standalone alternatives to Kafka Connect Connectors

Language: Scala - Size: 1.65 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 45 - Forks: 15

kaizen-solutions/virgil

A purely functional Cassandra client built on top of the Datastax Java Driver supporting a variety of effect systems like ZIO & Cats-Effect supporting both Scala 2 & 3

Language: Scala - Size: 971 KB - Last synced at: 7 days ago - Pushed at: 17 days ago - Stars: 40 - Forks: 8

ollls/zio-quartz-h2

ZIO2 native, asynchronous Java NIO based implementation of http/2 packet streaming server with TLS encryption implemented as scala ZIO2 effect. Direct native translation of ZIO ZStream chunks into http2 packets (inbound and outbound).

Language: Scala - Size: 7.98 MB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 8 - Forks: 0

SneaksAndData/arcane-stream-parquet

Parquet stream for Arcane Streaming Service

Language: Scala - Size: 66.4 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 0 - Forks: 0

grouzen/zio-apache-parquet

Scala ZIO-powered Apache Parquet library

Language: Scala - Size: 435 KB - Last synced at: 9 days ago - Pushed at: about 1 month ago - Stars: 26 - Forks: 4

SneaksAndData/arcane-stream-microsoft-synapse-link

Microsoft Synapse Link stream for Arcane Streaming Service

Language: Python - Size: 578 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 1

zio/zio-ftp

A simple, idiomatic (S)FTP client for ZIO

Language: Scala - Size: 1.63 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 28 - Forks: 13

grouzen/zio-apache-arrow

Scala ZIO-powered Apache Arrow library

Language: Scala - Size: 496 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 21 - Forks: 1

fancellu/zio-restful-webservice

ZIO 2.0 Restful webservice example using zio, zio-http, zio-json, quill, H2, twirl, zio-streams, zio-cache, zio-logging, zio-actors, zio-spark, openai, DallE

Language: Scala - Size: 79.1 KB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 59 - Forks: 6

mvillafuertem/scala

🤓 Examples Advanced 🧐 Projects Akka 🚀 ZIO ⚡️ Algorithms 😼 Cats

Language: Scala - Size: 32.9 MB - Last synced at: 5 months ago - Pushed at: 12 months ago - Stars: 9 - Forks: 2

makiftutuncu/tweet-tracker

An application for streaming tweets containing a search term on Twitter in real time for a predefined duration or number of tweets

Language: Scala - Size: 33.2 KB - Last synced at: 5 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0

mbannour/zio-mongoDB

ZIO wrapper for MongoDB Reactive Streams Java Driver and MongoDb scala Driver

Language: Scala - Size: 116 KB - Last synced at: 5 months ago - Pushed at: 10 months ago - Stars: 7 - Forks: 3

otobrglez/dojodis

High-performance Redis server implemented in Scala with ZIO.

Language: Scala - Size: 41 KB - Last synced at: 5 months ago - Pushed at: almost 3 years ago - Stars: 25 - Forks: 2

ernestochero/sensor_statistics_challenge

code challenge

Language: Scala - Size: 215 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

jczuchnowski/zio-pulsar

Apache Pulsar client for Scala with ZIO and ZIO Streams integration.

Language: Scala - Size: 179 KB - Last synced at: 4 months ago - Pushed at: about 1 year ago - Stars: 23 - Forks: 5

epifab/cql4s

Cassandra typesafe DSL for pure functional Scala supporting cats effect, fs2, ZIO

Language: Scala - Size: 183 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 7 - Forks: 0

mvillafuertem/scalcite

Scalcite is a library to query 💬 and update ✏️ JSON data 📄

Language: Scala - Size: 1.46 MB - Last synced at: 5 months ago - Pushed at: about 1 year ago - Stars: 10 - Forks: 3

googley42/zio-dynamodb-example

An example of ZIO integration with AWS java SDK. Shows ZIO Streaming of a paged query.

Language: Scala - Size: 33.2 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 1

kensuio-oss/redis-streams-zio

An example application leveraging zio-streams and Redisson library to consume and produce events to Redis streams.

Language: Scala - Size: 140 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 23 - Forks: 3

oleg-korolenko/basket-score-streaming

Score events streaming pipeline

Language: Scala - Size: 35.2 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 1 - Forks: 0

kaizen-solutions/circe-zio-streams

ZIO Streams integration for streaming json parsing via Circe + Jawn

Language: Scala - Size: 11.7 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

45375dfhg/ZBroker-CoAP

Language: Scala - Size: 669 KB - Last synced at: over 2 years ago - Pushed at: almost 5 years ago - Stars: 0 - Forks: 0

mtumilowicz/scala-zio2-zstream-workshop

Introduction to streaming using zio (ZStream).

Language: Scala - Size: 97.7 KB - Last synced at: 7 months ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0

mtumilowicz/scala-zio2-grpc-workshop

Introduction to proto-buffers and gRPC based on ZIO approach.

Language: Scala - Size: 131 KB - Last synced at: 7 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

pawelkaczor/telemetry-reports

Sample app combining zio-streams, akka-streams, zio-prelude (Associative, Identity type classes)

Language: Scala - Size: 54.7 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 1

otobrglez/frogger

frogger is high-performance transit lookup server written as part of transit-lang-cmp language comparison challenge.

Language: Scala - Size: 6.84 KB - Last synced at: 6 months ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

EtaCassiopeia/api-aggregation-service

Scala, ZIO, Http4s, Sttp

Language: Scala - Size: 298 KB - Last synced at: 5 months ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

EtaCassiopeia/tvi-charging-back-office

Scala, ZIO, Http4s

Language: Scala - Size: 37.1 KB - Last synced at: 5 months ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

gurghet/scala-vns

Variable Neighborhood Search library for scala

Language: Scala - Size: 1000 Bytes - Last synced at: 4 months ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0

DmytroOrlov/zio-streams-example

Language: Scala - Size: 1.95 KB - Last synced at: over 2 years ago - Pushed at: about 6 years ago - Stars: 2 - Forks: 0