94 Resources
Golang streaming Libraries
Using Golang to complete ChatGPT streaming, making it easier to join your own project
chatGPT_streaming go语言使用openai的ChatGPT接口实践，使用流式传输，类似ChatGPT网页效果，并且可以让ChatGPT的服务单独部署（单独部署到非大中华区的服务器），并用grpc streaming 做中间层，保证不受墙的影响。使用websocket最终通信，后端考
A lightweight event collection system.
Honeypot A self-contained, multi-protocol streaming event collection system with ambitions to be as boring as benthos. Honeypot is primarily built for
Miller is like awk, sed, cut, join, and sort for name-indexed data such as CSV, TSV, and tabular JSON
What is Miller? Miller is like awk, sed, cut, join, and sort for data formats such as CSV, TSV, JSON, JSON Lines, and positionally-indexed. What can M
Powerful Blockchain streaming data engine, based on StreamingFast Firehose technology.
Substreams - A streaming data engine for The Graph - by StreamingFast DEVELOPER PREVIEW OF SUBSTREAMS Think Fluvio for deterministic blockchain data.
Basic Event Streaming - Fundamentals of Kafka Studies (BESt-FunKS)
Apache Kafka My study repo for Apache Kafka. Based on this tutorial. Contents Overview Key Terms Event Topic Producer Consumer Partition Getting Start
Nba-simulation - Golang will be simulating nba match and streaming it real time
NBA Simulation golang in-memory To build and run go build ./nbaSimulation To ru
A live streaming tool more suitable for non-graphical servers
KPlayer KPlayer可以帮助你快速的在服务器上进行视频资源的循环直播推流。
Service that wrap up different movies-related APIs like IMDB and match it to streaming services
Service that wrap up different movies-related APIs like IMDB and match it to streaming services. That way you can check in which platforms you can find your favorite movies.
Prototype to show how to transform an existing (SOAP) API into a modern streaming API
vSphere Event Streaming Prototype to show how to transform an existing (SOAP) API into a modern HTTP/REST streaming API. Details The vSphere Event Str
Gosaxml is a streaming XML decoder and encoder, similar in interface to the encoding/xml
gosaxml is a streaming XML decoder and encoder, similar in interface to the encoding/xml, but with a focus on performance, low memory footprint and on
StreamWall - WIP demo application which streams music in exchange for streaming sats
Stream Wall Music examples borrowed from https://ableandthewolf.com/ check them
Streamhub: a toolkit crafted for streaming-powered applications written in Go
✉️ Streamhub Streamhub is a toolkit crafted for streaming-powered applications w
Scan for viruses by shelling out to clamav (streaming via stdin)
clamscan This is currently just an example program, but will eventually be a small library. ClamAV has functionality for performing a streaming scan o
Videos2gether-server - Server for the Realtime video streaming app Videos2Gether
Videos Together server Server source code for the https://videos2gether.com Arch
A YANG-centric Go toolkit - Go/Protobuf Code Generation; Validation; Marshaling/Unmarshaling
Introduction ygot (YANG Go Tools) is a collection of Go utilities that can be used to: Generate a set of Go structures and enumerated values for a set
Examples for building microservices with Go kit (gokit.io)
The updated source code is moved into the repository go-distsys gokit-examples Examples for building microservices with Go Kit (gokit.io) Articles Go
Go Nats Streaming gRPC PostgerSQL emails microservice
Golang NATS gRPC Postgresql email microservice example 👋 Jaeger UI: http://localhost:16686 Prometheus UI: http://localhost:9090 Grafana UI: http://lo
An application that uses gRPC Client Streaming framework to computes average.
compute-average An API that uses Client Streaming gRPC framework to capture all integer numbers on Requests that the client sent and returns just the
This is a single-instance streaming server with chat.
Table of Contents AlbertoBroadcast stream server Build requirements Older Go Versions Compile and install Docker build Building the Container Running
ZipFly: a golang HTTP server that streams a ZIP file from a list of URLs extracted from a JSON manifest
ZipFly, streaming files as a ZIP like a 🚀 ZipFly is a golang HTTP server that s
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Project Flogo is an Open Source ecosystem for event-driven apps Ecosystem | Core | Flows | Streams | Flogo Rules | Go Developers | When to use Flogo |
Parse and generate m3u8 playlists for Apple HTTP Live Streaming (HLS) in Ruby.
m3u8 m3u8 provides easy generation and parsing of m3u8 playlists defined in the HTTP Live Streaming (HLS) Internet Draft published by Apple. The libra
MQTT Datasource for Grafana allows streaming data from any MQTT broker running either locally or remotely.
MQTT data source for Grafana The MQTT data source plugin allows you to visualize streaming MQTT data from within Grafana. This datasource is under act
Golang tool to configure the Barco CX-20 station in one click. T
Golang tool to configure the Barco CX-20 station in one click. The CX-20 connect wireless to existing huddle room camera, speakerphones and audio peripherals, saving time and maximizing efficiency.
paymentstream / streaming payments is a module built using Cosmos SDK, Tendermint and Starport, to stream payments from on address to the other, using delayed and continuous payments types inspired by Vesting module from Cosmos SDK.
paymentstream / Streaming Payments paymentstream is a module built using Cosmos SDK, Tendermint and Starport to stream payments from on address to the
Functional Programming support for golang.(Streaming API)
Funtional Api for Golang Functional Programming support for golang.(Streaming API) The package can only be used with go 1.18. Do not try in lower vers
Tarserv serves streaming tar files from filesystem snapshots.
tarserv A collection of tools that allow serving large datasets from local filesystem snapshots. It is meant for serving big amounts of data to shell
Мост между NATS streaming и MQ Series
Мост между NATS streaming и MQ Series Оригинальный репозиторий https://github.com/nats-io/nats-mq NATS-MQ Bridge This project implements a simple, but
Server and client implementation of the grpc go libraries to perform unary, client streaming, server streaming and full duplex RPCs from gRPC go introduction
Description This is an implementation of a gRPC client and server that provides route guidance from gRPC Basics: Go tutorial. It demonstrates how to u
json encoding and decoding
jx Package jx implements encoding and decoding of json [RFC 7159]. Lightweight fork of jsoniter. go get github.com/go-faster/jx Usage and examples Roa
Client streaming grpc with golang
grpc client streaming grpc client sends a stream of messages to the server instead of a single message. server streaming grpc server returns a stream
MatrixOne is a planet scale, cloud-edge native big data engine crafted for heterogeneous workloads.
What is MatrixOne? MatrixOne is a planet scale, cloud-edge native big data engine crafted for heterogeneous workloads. It provides an end-to-end data
Schema-free, document-oriented streaming database that optimized for monitoring network traffic in real-time
Basenine Schema-free, document-oriented streaming database that optimized for monitoring network traffic in real-time. Featured Aspects Has the fastes
go-linereader: A small library for streaming lines from an io.Reader.
go-linereader: A small library for streaming lines from an io.Reader.
HTTP server receives events and publishes them to STAN
Publishes events to Nats Streaming(STAN) synchornously and asynchronously. Cache events's publish-state using Redis and Store events using MongoDB.
Self-hosted music streaming server 🎶 with RESTful API and Web interface
Self-hosted music streaming server 🎶 with RESTful API and Web interface. Think of it as your very own Spotify!
Service responsible for streaming Kafka messages.
kafka-stream 🧙🏼♂️ Service responsible for streaming Kafka messages. What it does? This service reads all messages from the input topic and sends th
replicate messages from streaming channel to jetstream
NATS Streaming/Jetstream Replicator [SJR] Introduction This project replicates messages from streaming channels to jetstream. but why? At Snapp when w
Walrus 🕑 Real-time event streaming platform built on top of gRPC streams
Walrus 🕑 Real-time event streaming platform built on top of gRPC streams Table of Contents About the project Built With How it works Getting Started
pubsub controller using kafka and base on sarama. Easy controll flow for actions streamming, event driven.
Psub helper for create system using kafka to streaming and events driven base. Install go get github.com/teng231/psub have 3 env variables for config
Machine is a library for creating data workflows.
Machine is a library for creating data workflows. These workflows can be either very concise or quite complex, even allowing for cycles for flows that need retry or self healing mechanisms.
This project is designed to be an open source implementation for streaming desktop games using WebRTC
The aim of this project is develop a WebRTC screenshare designed for streaming video games and accepting remote inputs. There will be ansible instruct
The OCI Service Operator for Kubernetes (OSOK) makes it easy to connect and manage OCI services from a cloud native application running in a Kubernetes environment.
OCI Service Operator for Kubernetes Introduction The OCI Service Operator for Kubernetes (OSOK) makes it easy to create, manage, and connect to Oracle
Streaming replication for SQLite.
Litestream Litestream is a standalone streaming replication tool for SQLite. It runs as a background process and safely replicates changes incremental
A crunchyroll api integration in go with included cli
crunchyroll-go A Go library & cli for the undocumented crunchyroll api. You surely need a crunchyroll premium account to get full (api) access. CLI 🖥
live streaming server in golang
中文 Simple and efficient live broadcast server: Very simple to install and use; Pure Golang, high performance, and cross-platform; Supports commonly us
Live streaming from your terminal
TStream - Streaming from terminal 🙋♂️ Come stream at tstream.club How to start streaming Please refer to this link Upcoming features One command to
Kafka implemented in Golang with built-in coordination (No ZK dep, single binary install, Cloud Native)
Jocko Kafka/distributed commit log service in Go. Goals of this project: Implement Kafka in Go Protocol compatible with Kafka so Kafka clients and ser
This application demonstrates how to launch high-performance "serverless" functions from the YoMo framework to process streaming data. The functions are embedded in a WebAssembly VM, WasmEdge, for safety, security, portability, and manageability.
Streaming Image Recognition by WebAssembly This project demonstrates how to process a video stream in real-time using WebAssembly and apply a pre-trai
This package helps establish a websocket connection to the bilibili streaming server.
biliStreamClient This package helps establish a websocket connection to the bilibili streaming server. bilibili直播弹幕的WebSocket协议分析请参考：https://blog.csdn
live video streaming server in golang
中文 Simple and efficient live broadcast server: Very simple to install and use; Pure Golang, high performance, and cross-platform; Supports commonly us
Take control over your live stream video by running it yourself. Streaming + chat out of the box.
Take control over your content and stream it yourself. Explore the docs » View Demo · Use Our Server for Testing · FAQ · Report Bug Table of Contents
Graphik is a Backend as a Service implemented as an identity-aware document & graph database with support for gRPC and graphQL
Graphik is a Backend as a Service implemented as an identity-aware, permissioned, persistant document/graph database & pubsub server written in Go.
Ciak is a lightweight media server written in go
Ciak allows you to show and stream your personal media tv series, movies, etc with a simple and clean web ui. The server also provide on the fly video encoding in order to stream non standard formats such as avi, mkv...
Async peer communication protocol & library
Gotalk exists to make it easy for programs to talk with one another over the internet, like a web app coordinating with a web server, or a bunch of programs dividing work amongst each other.
Apache Pulsar Go Client Library
Apache Pulsar Go Client Library A Go client library for the Apache Pulsar project. Goal This projects is developing a pure-Go client library for Pulsa
Reactive Extensions for the Go language.
RxGo Reactive Extensions for the Go Language ReactiveX ReactiveX, or Rx for short, is an API for programming with Observable streams. This is the offi
ready-to-use RTSP / RTMP server and proxy that allows to read, publish and proxy video and audio streams
rtsp-simple-server is a simple, ready-to-use and zero-dependency RTSP / RTMP server and proxy, a software that allows users to publish, read and proxy live video and audio streams. RTSP is a specification that describes how to perform these operations with the help of a server, that is contacted by both publishers and readers and relays the publisher's streams to the readers.
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
Overview Gazette makes it easy to build platforms that flexibly mix SQL, batch, and millisecond-latency streaming processing paradigms. It enables tea
Simple, high-performance event streaming broker
Styx Styx is a simple and high-performance event streaming broker. It aims to provide teams of all sizes with a simple to operate, disk-persisted publ
Pure Go implementation of the WebRTC API
Pion WebRTC A pure Go implementation of the WebRTC API New Release Pion WebRTC v3.0.0 has been released! See the release notes to learn about new feat
🦖 Streaming-Serverless Framework for Low-latency Edge Computing applications, running atop QUIC protocol, engaging 5G technology.
YoMo YoMo is an open-source Streaming Serverless Framework for building Low-latency Edge Computing applications. Built atop QUIC Transport Protocol an
Full-featured BitTorrent client package and utilities
torrent This repository implements BitTorrent-related packages and command-line utilities in Go. The emphasis is on use as a library from other projec
⚡High Performance DICOM Medical Image Parser in Go.
dicom High Performance Golang DICOM Medical Image Parser 👀 v1.0 just released! This is a library and command-line tool to read, write, and generally
Self hosted live chat server written in Go
goch is a self-hosted live-chat server written in Go. It allows you to run a live-chat software on your own infrastructure. You can create multip
Personal video streaming server.
tube This is a Golang project to build a self hosted "tube"-style video player for watching your own video collection over HTTP or hosting your own ch
A lightweight stream processing library for Go
go-streams A lightweight stream processing library for Go. go-streams provides a simple and concise DSL to build data pipelines. Wiki In computing, a
A pluggable backend API that enforces the Event Sourcing Pattern for persisting & broadcasting application state changes
A pluggable "Application State Gateway" that enforces the Event Sourcing Pattern for securely persisting & broadcasting application state changes
Machine is a zero dependency library for highly concurrent Go applications.
Machine is a zero dependency library for highly concurrent Go applications. It is inspired by errgroup.Group with extra bells & whistles
Declarative streaming ETL for mundane tasks, written in Go
Benthos is a high performance and resilient stream processor, able to connect various sources and sinks in a range of brokering patterns and perform hydration, enrichments, transformations and filters on payloads.
nanoQ — high-performance brokerless Pub/Sub for streaming real-time data
nanoQ — high-performance brokerless Pub/Sub for streaming real-time data nanoQ is a very minimalistic (opinionated/limited) Pub/Sub transport library.
Live on-demand transcoding in go using ffmpeg. Also with NVIDIA GPU hardware acceleration.
Go live HTTP on-demand transcoding Transcoding is expensive and resource consuming operation on CPU and GPU. For big companies with thousands of custo
Fast, concurrent, streaming access to Amazon S3, including gof3r, a CLI. http://godoc.org/github.com/rlmcpherson/s3gof3r
s3gof3r s3gof3r provides fast, parallelized, pipelined streaming access to Amazon S3. It includes a command-line interface: gof3r. It is optimized for
Parser and generator of M3U8-playlists for Apple HLS. Library for Go language. :cinema:
M3U8 This is the most complete opensource library for parsing and generating of M3U8 playlists used in HTTP Live Streaming (Apple HLS) for internet vi
Parse and generate m3u8 playlists for Apple HTTP Live Streaming (HLS) in Golang (ported from gem https://github.com/sethdeckard/m3u8)
go-m3u8 Golang package for m3u8 (ported m3u8 gem https://github.com/sethdeckard/m3u8) go-m3u8 provides easy generation and parsing of m3u8 playlists d
Go Twitter REST and Streaming API v1.1
go-twitter go-twitter is a Go client library for the Twitter API. Check the usage section or try the examples to see how to access the Twitter API. Fe
omniparser: a native Golang ETL streaming parser and transform library for CSV, JSON, XML, EDI, text, etc.
omniparser Omniparser is a native Golang ETL parser that ingests input data of various formats (CSV, txt, fixed length/width, XML, EDI/X12/EDIFACT, JS
csvutil provides fast and idiomatic mapping between CSV and Go (golang) values.
csvutil Package csvutil provides fast and idiomatic mapping between CSV and Go (golang) values. This package does not provide a CSV parser itself, it
Streaming approximate histograms in Go
gohistogram - Histograms in Go This package provides Streaming Approximate Histograms for efficient quantile approximations. The histograms in this pa
Server-sent live updates: protocol and reference implementation
Protocol and Reference Implementation Mercure is a protocol allowing to push data updates to web browsers and other HTTP clients in a convenient, fast
A library for scheduling when to dispatch a message to a channel
gosd go-schedulable-dispatcher (gosd), is a library for scheduling when to dispatch a message to a channel. Implementation The implementation provides
Build event-driven and event streaming applications with ease
Commander 🚀 Commander is Go library for writing event-driven applications. Enabling event sourcing, RPC over messages, SAGA's, bidirectional streamin
Declarative streaming ETL for mundane tasks, written in Go
Benthos is a high performance and resilient stream processor, able to connect various sources and sinks in a range of brokering patterns and perform h
httpstream provides HTTP handlers for simultaneous streaming uploads and downloads of objects, as well as persistence and a standalone server.
httpfstream httpfstream provides HTTP handlers for simultaneous streaming uploads and downloads of files, as well as persistence and a standalone serv
Go library for writing standalone Map/Reduce jobs or for use with Hadoop's streaming protocol
dmrgo is a Go library for writing map/reduce jobs. It can be used with Hadoop's streaming protocol, but also includes a standalone map/reduce impleme
Pure Go implementation of the WebRTC API
Pion WebRTC A pure Go implementation of the WebRTC API New Release Pion WebRTC v3.0.0 has been released! See the release notes to learn about new feat
A cloud native distributed streaming network telemetry.
Panoptes Streaming Panoptes Streaming is a cloud native distributed streaming network telemetry. It can be installed as a single binary or clustered n
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Project Flogo is an Open Source ecosystem for event-driven apps Ecosystem | Core | Flows | Streams | Flogo Rules | Go Developers | When to use Flogo |
A stream processing API for Go (alpha)
A data stream processing API for Go (alpha) Automi is an API for processing streams of data using idiomatic Go. Using Automi, programs can process str
:envelope: A streaming Go library for the Internet Message Format and mail messages
go-message A Go library for the Internet Message Format. It implements: RFC 5322: Internet Message Format RFC 2045, RFC 2046 and RFC 2047: Multipurpos
Full-featured BitTorrent client package and utilities
torrent This repository implements BitTorrent-related packages and command-line utilities in Go. The emphasis is on use as a library from other projec
Lightweight, fault-tolerant message streams.
Liftbridge provides lightweight, fault-tolerant message streams by implementing a durable stream augmentation for the NATS messaging system. It extend