Search Results for "pubsub"
Sort By:
Showing 29 open source projects for "pubsub"
View related business solutions-
Go from Code to Production URL in SecondsSkip the Kubernetes configs. Cloud Run handles HTTPS, scaling, and infrastructure automatically. Two million requests free per month.
-
Train ML Models With SQL You Already KnowBuild and deploy ML models using familiar SQL. Automate data prep with built-in Gemini. Query 1 TB and store 10 GB free monthly.
-
1
graphql-subscriptions
A small module that implements GraphQL subscriptions for Node.js
GraphQL subscriptions is a simple npm package that lets you wire up GraphQL with a pubsub system (like Redis) to implement subscriptions in GraphQL. You can use it with any GraphQL client and server (not only Apollo). To begin with GraphQL subscriptions, start by defining a GraphQL Subscription type in your schema. Next, add the Subscription type to your schema definition. Now, let's create a simple PubSub instance - it is a simple pubsub implementation, based on EventEmitter. ... -
2
TwitchIO
An Async Bot/API wrapper for Twitch made in Python
...TwitchIO covers almost all of the new Twitch API and features support for commands, PubSub, Webhooks, and EventSub. -
3
Phoenix Framework
Peace of mind from prototype to production
...It runs on the Erlang VM (BEAM). It is designed to support both traditional request/response web applications. It also supports real-time, soft-real-time applications via WebSockets, channels, PubSub, and presence features. Phoenix emphasizes fault tolerance, scalability, and developer productivity. It provides tools like code generators, LiveView integration, templating, routing, and a flexible plug pipeline. Phoenix runs on the Erlang VM with the ability to handle millions of WebSocket connections alongside Elixir's tooling for building robust systems. ... -
4
Argo Events
Event-driven Automation Framework for Kubernetes
...It allows you to trigger 10 different actions (such as the creation of Kubernetes objects, invoking workflows or serverless workloads) on over 20 different events (such as webhook, S3 drop, cron schedule, messaging queues - e.g. Kafka, GCP PubSub, SNS, SQS). -
Gemini 3 and 200+ AI Models on One PlatformBuild, govern, and optimize agents and models with Gemini Enterprise Agent Platform.
-
5
KubeAI
Private Open AI on Kubernetes
Get inferencing running on Kubernetes: LLMs, Embeddings, Speech-to-Text. KubeAI serves an OpenAI compatible HTTP API. Admins can configure ML models by using the Model Kubernetes Custom Resources. KubeAI can be thought of as a Model Operator (See Operator Pattern) that manages vLLM and Ollama servers. -
6
live_beats is an example Phoenix LiveView application developed by Fly.io to demonstrate real-time features and deployment workflows in modern Elixir web applications. It showcases how developers can build interactive, stateful web experiences without relying heavily on client-side JavaScript frameworks. The project streams live audio updates and visual feedback directly through WebSocket connections managed by LiveView, highlighting the power of Elixir’s concurrent architecture. In addition...
-
7
Broadway
Concurrent and multi-stage data ingestion and data processing
Broadway is a data processing library for Elixir designed to handle high-throughput, concurrent workloads with ease. It provides an abstraction for defining pipelines that consume data from sources like RabbitMQ, Kafka, Amazon SQS, or custom producers. Each pipeline is fault-tolerant and backpressure-aware, ensuring stable throughput even under load. The library integrates seamlessly with GenStage and OTP supervision trees, making it highly resilient in production. Developers can enrich... -
8
Horde
Horde is a distributed Supervisor and Registry
...Because everything runs under OTP supervision, failures are isolated and recoveries are automatic, even during network partitions or rolling deploys. It integrates naturally with common clustering tools and plays well with PubSub, job systems, and presence tracking. The result is predictable, configuration-driven distribution that removes a lot of custom glue typically needed for multi-node Elixir systems. -
9
Micro Cloud
A distributed OS built for the Cloud
Micro addresses the key requirements for building services in the cloud. It leverages the microservices architecture pattern and provides a set of services which act as the building blocks of a platform. Micro deals with the complexity of distributed systems and provides simpler programmable abstractions to build on. Micro is the all encompassing end to end platform experience from source to running and beyond built with a developer first focus. Micro’s goal is to abstract away the... -
Build Securely on Azure with Proven FrameworksMoving to the cloud brings new challenges. How can you manage a larger attack surface while ensuring great network performance? Turn to Fortinet’s Tested Reference Architectures, blueprints for designing and securing cloud environments built by cybersecurity experts. Learn more and explore use cases in this white paper.
-
10
The Go Cloud Development Kit
Library and tools for open cloud development in Go
The Go Cloud Development Kit (Go CDK) allows Go application developers to seamlessly deploy cloud applications on any combination of cloud providers. It does this by providing stable, idiomatic interfaces for common uses like storage and databases. Think database/sql for cloud products. The project works well with a code generator called Wire. It creates human-readable code that only imports the cloud SDKs for services you use. This allows the Go CDK to grow to support any number of cloud... -
11
Spring Data Redis
Provides support to increase developer productivity in Java
...Exception translation to Spring’s portable Data Access exception hierarchy for Redis driver exceptions. RedisTemplate that provides a high level abstraction for performing various Redis operations, exception translation and serialization support. Pubsub support (such as a MessageListenerContainer for message-driven POJOs). Redis Sentinel and Redis Cluster support. Reactive API using the Lettuce driver. JDK, String, JSON and Spring Object/X. -
12
S2OPC - Safe & Secure OPC UA
An Open Source Safe & Secure OPC UA stack
Open-source Safe and Secure OPC UA Toolkit designed with embedded devices in mind (see https://www.s2opc.com). Its demo server is certified by the OPC Foundation and CSPN(-BSZ). -
13
Mitt
Tiny 200 byte functional event emitter / pubsub
Mitt was made for the browser, but works in any JavaScript runtime. It has no dependencies and supports IE9+. This project uses node and npm. Go check them out if you don't have them locally installed. Then with a module bundler like rollup or webpack, use as you would anything else. The UMD build is also available on unpkg. Set "strict": true in your tsconfig.json to get improved type inference for mitt instance methods. Alternatively, you can use the provided Emitter type. Remove an event... -
14
ipfs-pubsub-room
IPFS Pubsub room
Creates a room based on a LibP2P pub-sub channel. Emits membership events, listens for messages, broadcasts and direct messages to peers. -
15
galacteek
Multi-platform browser for the distributed web
galacteek is a multi-platform Qt5-based browser and semantic agent for the distributed web. Be sure to install all the gstreamer packages on your system to be able to use the mediaplayer. After opening/mounting the DMG image, hold Control and click on the galacteek icon, and select Open and accept. You probably need to allow the system to install applications from anywhere in the security settings. Docker images are available. They run the full GUI inside a virtual Xorg server (using Xvfb).... -
16
peerchat
A terminal-based P2P chat application using libp2p and Golang
A terminal-based P2P chat application using libp2p and Golang that uses a Kademlia DHT and the IPFS network for peer discovery and routing. The application was inspired by chat examples found on libp2p's pubsub library, but is more evolved and fully featured version of it. It uses a Kademlia DHT from libp2p for peer discovery and routing and supports a more fully featured host. The other components of the libp2p such as TLS encryption, peer active discovery, YAMUX stream multiplexing are integrated as well. The application also allows users to jump between different chat rooms without having to restart the application and they can also change their usernames at any point. ... -
17
Kubeless
Kubernetes Native Serverless Framework
...We then run an in-cluster controller that watches these custom resources and launches runtimes on-demand. The controller dynamically injects the functions code into the runtimes and makes them available over HTTP or via a PubSub mechanism. Kubeless is purely open-source and non-affiliated to any commercial organization. Chime in at any time, we would love the help and feedback. -
18
Rust IPFS
The InterPlanetary File System (IPFS), implemented in Rust
This repository contains the crates for the IPFS core implementation which includes a blockstore, a libp2p integration which includes DHT content discovery and pubsub support, and HTTP API bindings. Our goal is to leverage both the unique properties of Rust to create powerful, performant software that works even in resource-constrained environments, while also maximizing interoperability with the other "flavors" of IPFS, namely JavaScript and Go. -
19
qD Messages
Lightning fast peer-to-peer cross-platform messenger
...Alias and profile pictures are linked from qD Social. Peers can nickname participants and override the information that references other peers' social profiles. The messenger uses the second layer Quest Network PubSub protocol and if you are using qOS in your application you can use the channels as well. -
20
go-libp2p-pubsub-grpc
libp2p pubsub with controls exposed via a gRPC API
pubsubgrpc provides a LibP2P PubSub framework that can be used as a stand-alone gRPC pubsub server and API, or as a module/component of existing gRPC servers to provide LibP2P PubSub functionality. It uses proto3 and borrows some ideas from libp2p/go-libp2p-daemon and libp2p/go-libp2p-pubsub. -
21
net-ipfs-engine
IPFS Core API implementation in .Net
An embedded IPFS engine implemented in C#. It implements the IPFS Core API which makes it possible to create a decentralised and distributed application without relying on an "IPFS daemon". Basically, your application becomes an IPFS node. -
22
Ardb
A redis protocol compatible nosql, it support multiple storage engines
...Arab instance work as master of Redis 2.6/2.8+ instance. Ardb instance work as slave of Ardb instance. Auto failover support by redis-sentinel. Lua Scripting support. Pub/Sub. All redis pubsub commands are supported. Transactions. All redis transaction commands are supported. Backup data online. Use 'save/bgsave' to backup data. -
23
Kue
Kue is a priority job queue backed by redis, built for node.js
Kue is a feature rich priority job queue for node.js backed by redis. A key feature of Kue is its clean user-interface for viewing and managing queued, active, failed, and completed jobs. At any point in the job's life-time you can view verbose details, including the job's arbitrary data, creation, update, failure, and completion times. Jobs may incrementally update their progress, providing vital feedback for long-running tasks. Job-specific logging allows you to see how your job's are... -
24
Karellen Gevent Websocket Library
Karellen Gevent Websocket Library
This is a Karellen fork of gevent-websocket. The goal of this fork is to maintain the project to support Python 3.3, 3.4 and 3.5+ as well as latest WS standards errata. -
25
AWS IoT Arduino Yún SDK
SDK for connecting to AWS IoT from an Arduino Yún
...The AWS-IoT-Arduino-Yún-SDK provides APIs to let users publish messages to AWS IoT and subscribe to MQTT topics to receive messages transmitted by other devices or coming from the broker. This allows to interact with the standard MQTT PubSub functionality of AWS IoT.
