GitPlanet

Cheap and reliable Node.js hosting starts at $3/month, and $1/month static HTML hosting

Created with love in Canada, visit hostnodejs.com today

Feel like to post an Ad? Learn Details
All Projects → msales → streams

msales / streams

Licence: MIT license
Simple Go stream processor

Programming Languages

go
31211 projects - #10 most used programming language

Labels

streamsgo-library

Projects that are alternatives of or similar to streams

go-streams
Stream Collections for Go. Inspired in Java 8 Streams and .NET Linq
Stars: ✭ 127 (+535%)
Mutual labels:  streams
swift-futures
Demand-driven asynchronous programming in Swift
Stars: ✭ 32 (+60%)
Mutual labels:  streams
penumbra
Encrypt/decrypt anything in the browser using streams on background threads.
Stars: ✭ 100 (+400%)
Mutual labels:  streams
kafka-shell
⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.
Stars: ✭ 107 (+435%)
Mutual labels:  streams
godsend
A simple and eloquent workflow for streaming messages to micro-services.
Stars: ✭ 15 (-25%)
Mutual labels:  streams
whatsup
Reactive framework, simple, fast, easy to use!
Stars: ✭ 115 (+475%)
Mutual labels:  streams
JavaCertification
This is a full resource guide for my attempt to get Java 11 Certified
Stars: ✭ 67 (+235%)
Mutual labels:  streams
movie-catalog
🎬 A movie catalog app for both Android & IOS ~ Flutter.io project in Dart | Dart, Bloc, Movies
Stars: ✭ 46 (+130%)
Mutual labels:  streams
wasm-streams
Bridging between web streams and Rust streams using WebAssembly
Stars: ✭ 61 (+205%)
Mutual labels:  streams
redis-microservices-demo
Microservice application with various Redis use-cases with RediSearch, RedisGraph and Streams. The data are synchronize between MySQL and Redis using Debezium as a CDC engine
Stars: ✭ 48 (+140%)
Mutual labels:  streams
random
Random data generator AKA faker
Stars: ✭ 14 (-30%)
Mutual labels:  go-library
level-ws
A basic writable stream for abstract-level databases.
Stars: ✭ 19 (-5%)
Mutual labels:  streams
stream-registry
Stream Discovery and Stream Orchestration
Stars: ✭ 105 (+425%)
Mutual labels:  streams
flowage
Easy transformations and filtering for NodeJS object streams.
Stars: ✭ 85 (+325%)
Mutual labels:  streams
go-httpheader
A Go library for encoding structs into Header fields.
Stars: ✭ 38 (+90%)
Mutual labels:  go-library
.
A simple streaming library
Stars: ✭ 99 (+395%)
Mutual labels:  streams
telegram
📚 Golang bindings for Telegram API
Stars: ✭ 15 (-25%)
Mutual labels:  go-library
goelftools
Library for parsing ELF files written in pure Go.
Stars: ✭ 26 (+30%)
Mutual labels:  go-library
IoTPy
Python for streams
Stars: ✭ 24 (+20%)
Mutual labels:  streams
urx
urx is a stream-based Reactive state management library
Stars: ✭ 18 (-10%)
Mutual labels:  streams
View All Similar Projects ➔

Streams

Go Report Card Test Coverage Status GoDoc GitHub release GitHub license

Streams is a light weight, simple stream processing library. While Kafka is the main use case for Streams, it is flexible enough to be used for any form of processing from any source.

Installation

You can install streams using go get

go get github.com/msales/streams

Concepts

Streams breaks processing into the following basic parts.

  • Message is a message in the system, consisting of a key, value and context.

  • Sources reads and handles position from a data source.

  • Processor processes the data, optionally passing it on or marking the sources position. A sink is just a processor the does not forward the data on.

  • Pipe gives processors an abstract view of the current state, allowing Messages to flow through the system.

Read more here:

https://medium.com/@rafamnich/getting-started-with-streams-v3-b9ab36fb9d54

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].