Search Results for "publish subscribe"
Sort By:
Showing 96 open source projects for "publish subscribe"
View related business solutions-
Full-stack observability with actually useful AI | Grafana CloudBuilt on open standards like Prometheus and OpenTelemetry, Grafana Cloud includes Kubernetes Monitoring, Application Observability, Incident Response, plus the AI-powered Grafana Assistant. Get started with our generous free tier today.
-
Try Google Cloud Risk-Free With $300 in CreditUse your credit across every product. Compute, storage, AI, analytics. When it runs out, 20+ products stay free. You only pay when you choose to.
-
1
Redigo
Go client for Redis
Redigo is a Go client for the Redis database. A Print-like API with support for all Redis commands. Pipelining, including pipelined transactions. Publish/Subscribe. Connection pooling. Script helper type with optimistic use of EVALSHA. Helper functions for working with command replies. The Conn interface is the primary interface for working with Redis. Applications create connections by calling the Dial, DialWithTimeout or NewConn functions. In the future, functions will be added for creating sharded and other types of connections. ... -
2
MQTT X
Powerful cross-platform MQTT 5.0 desktop, CLI, and WebSocket client
...It’s easy and quick to create multiple, simultaneous online MQTT client connections, and can test the connection, publishing, and subscription functions of MQTT/TCP, MQTT/TLS, MQTT/WebSocket as well as other MQTT protocol features. MQTT stands for MQ Telemetry Transport. It is a publish/subscribe, extremely simple and lightweight messaging protocol, designed for constrained devices and low-bandwidth, high-latency or unreliable networks. To run MQTT Broker locally, EMQX is recommended: An Open-Source, Cloud-Native, Distributed MQTT Broker for IoT. After the MQTT is connected successfully, you can perform MQTT publish and subscription tests. -
3
Apache RocketMQ
Distributed messaging and streaming platform with low latency
Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability. Messaging patterns including publish/subscribe, request/reply and streaming. Financial grade transactional message. Built-in fault tolerance and high availability configuration options base on DLedger. A variety of cross language clients, such as Java, C/C++, Python, Go. Pluggable transport protocols, such as TCP, SSL, AIO. Built-in message tracing capability, also support opentracing. ... -
4
Artifact Hub
Find, install and publish Kubernetes packages
Artifact Hub is a web-based application that enables finding, installing, and publishing packages and configurations for CNCF projects. Discovering artifacts to use with CNCF projects can be difficult. If every CNCF project that needs to share artifacts creates its own Hub this creates a fair amount of repeat work for each project and a fractured experience for those trying to find the artifacts to consume. The Artifact Hub attempts to solve that by providing a single experience for... -
MongoDB Atlas runs apps anywhereMongoDB Atlas gives you the freedom to build and run modern applications anywhere—across AWS, Azure, and Google Cloud. With global availability in over 115 regions, Atlas lets you deploy close to your users, meet compliance needs, and scale with confidence across any geography.
-
5
Datasette
An open source multi-tool for exploring and publishing data
...Try a demo and explore 33,000 power plants around the world, then take a look at some other examples of Datasette in action. Then read how to get started with Datasette, subscribe to the monthly-ish newsletter and consider signing up for office hours for an in-person conversation about the project. -
6
Spring Integration
Provides an extension of the Spring programming model
Extends the Spring programming model to support the well-known Enterprise Integration Patterns. Spring Integration enables lightweight messaging within Spring-based applications and supports integration with external systems via declarative adapters. Those adapters provide a higher-level of abstraction over Spring’s support for remoting, messaging, and scheduling. Spring Integration’s primary goal is to provide a simple model for building enterprise integration solutions while maintaining... -
7
Mercure
Server-sent live updates, protocol and reference implementation
Mercure is an open protocol for real-time communications designed to be fast, reliable and battery-efficient. It is a modern and convenient replacement for both the WebSocket API and the higher-level libraries and services relying on it. Mercure is especially useful to add streaming and asynchronous capabilities to REST and GraphQL APIs. Because it is a thin layer on top of HTTP and SSE, Mercure is natively supported by modern web browsers, mobile applications, and IoT devices. A free (as in... -
8
Yazi
Blazing fast terminal file manager written in Rust, based on async I/O
...Also integrated with Überzug++, covering almost all terminals. Built on a client-server architecture (no additional server process required), integrated with a Lua-based publish-subscribe model, achieving cross-instance communication and state persistence. Install plugins and themes with one command, keeping them always up to date. -
9
Sensu Go
Simple. Scalable. Multi-cloud monitoring
...The shift from static to dynamic infrastructure requires a change in approach to monitoring, from host-based to functional role-based. Connectivity moves from remote polling to publish-subscribe, the control plane moves from point-and-click interfaces to infrastructure as code workflows and self-service developer APIs. -
AI-powered service management for IT and enterprise teamsGive your IT, operations, and business teams the ability to deliver exceptional services—without the complexity. Maximize operational efficiency with refreshingly simple, AI-powered Freshservice.
-
10
Jedis
A small redis java client
...The features supported are sorting, connection handling, commands operating on any kind of values, commands operating on string values, commands operating on hashes, commands operating on lists, commands operating on sets, commands operating on sorted sets, commands operating on streams, transactions, pipelining, publish/subscribe, persistence control commands, remote server control commands, connection pooling, sharding (MD5, MurmurHash), key-tags for sharding, sharding with pipelining, scripting with pipelining, and Redis Cluster. Redis is primarily built for master/slave distribution. This means that write requests have to be explicitly addressed to the master (a redis server), which replicates changes to slaves (which are also redis servers). -
11
eBus
Publish/Subscribe, Request/Reply Messaging API for Java.
A Java middleware API supporting broker-less, type+topic-based publish/subscribe and request/reply messaging for both intra- and inter-application, object-level communication. Broker-less: messages are transmitted directly between eBus applications. There is no message broker (i.e. server) in between. Type+topic addressing: eBus clients subscribe to a message class (type) and message topic, providing stronger typing than just topic-based subscriptions. ... -
12
graphql-redis-subscriptions
A graphql subscriptions implementation using redis
...As the graphql-subscriptions package is declared as a peer dependency, you might receive a warning about an unmet peer dependency if it's not installed already by one of your other packages. Calling the method asyncIterator of the RedisPubSub instance will send redis a SUBSCRIBE message to the topic provided and will return an AsyncIterator binded to the RedisPubSub instance and listens to any event published on that topic. Now, the GraphQL engine knows that somethingChanged is a subscription, and every time we will use pubsub.publish over this topic, the RedisPubSub will PUBLISH the event over redis to all other subscribed instances and those in their turn will emit the event to GraphQL using the next callback. -
13
nanomsg
nanomsg library
The nanomsg library is a simple high-performance implementation of several "scalability protocols". These scalability protocols are lightweight messaging protocols that can be used to solve a number of very common messaging patterns, such as request/reply, publish/subscribe, surveyor/respondent, and so forth. These protocols can run over a variety of transports such as TCP, UNIX sockets, and even WebSocket. This pattern is useful for solving producer/consumer problems, including load-balancing. Messages flow from the push side to the pull side. If multiple peers are connected, the pattern attempts to distribute fairly. nanomsg is a socket library that provides several common communication patterns. ... -
14
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... -
15
Zotonic
The Erlang Web Framework & CMS
...It brings structure to your documents and makes semantic data manageable for normal humans. Real-time connectivity is deeply integrated using the Internet of Things publish/subscribe protocol MQTT. You can rapidly develop CMS-based sites on top of Zotonic. If you need more flexibility, you can customize all aspects of Zotonic. The included web server means can start working with Zotonic right away, without the need for installing Apache or Nginx separately. Zotonic is structured into modules. Each module offers a specific piece of functionality; the CMS is itself a module. ... -
16
Emitter
High performance, distributed, low latency publish-subscribe platform
Emitter is a real-time communication service for connecting online devices. The Publish-Subscribe messaging API is built for speed and security. The simple and efficient messaging platform for all of your gaming, IoT and web apps. Emitter can be used for online gaming and mobile apps by satisfying the requirements for low latency, binary messaging, and high throughput. It can also be used for real-time web applications such as dashboards or visual analytics or chat systems. ... -
17
AWS IoT Jobs library
Client library for using AWS IoT Jobs service on embedded devices
...A Job can be used to manage your fleet of devices, update firmware and security certificates on your devices, or perform administrative tasks such as restarting devices and performing diagnostics. It interacts with the AWS IoT Jobs service using MQTT, a lightweight publish-subscribe protocol. This library provides a convenience API to compose and recognize the MQTT topic strings used by the Jobs service. The library is written in C compliant with ISO C90 and MISRA C:2012, and is distributed under the MIT Open Source License. This library has gone through code quality checks including verification that no function has a GNU Complexity score over 8, and checks against deviations from mandatory rules in the MISRA coding standard. ... -
18
SObjectizer
It's all about in-process message dispatching!
...Since Aug 2019 the development of SObjectizer and so5extra is moved to GitHub: https://github.com/Stiffstream/sobjectizer https://github.com/Stiffstream/so5extra SObjectizer is an in-process message dispatching framework with implementation of Actor Model, Publish-Subscribe Model and CSP-like channels. SObjectizer allows the creation of a concurrent app as a set of agent-objects which interact with each other through asynchronous messages. It handles message dispatching and provides a working context for message processing. And allows to tune those things by supplying various ready-to-use dispatchers. -
19
QP Real-Time Event Frameworks & Tools
Real-Time Event Frameworks based on active objects & state machines
QP real-time event frameworks (RTEFs) provide lightweight, modern, event-driven architecture based on asynchronous Active Objects (Actors) and Hierarchical State Machines. The matching QM model-based design tool and other host-based tools complement the QP frameworks by supporting graphical modeling, code generation, software tracing, and unit testing for event-driven embedded software. Visit https://www.state-machine.com for more information. The QP RTEFs can run on bare-metal... -
20
Brill Software
A faster way to develop React Web Applications
The Brill Framework allows React web applications to be built quickly using a "Low Code" approach. A Content Management System (CMS) supports editing of pages containing React components. The React components communicate with each other and the Server using a middleware that's based on WebSockets. With a "No Code" solution, there's always something you require that's not support. You spend ages bending the product to your requirements or pay the supplier to provide the components... -
21
OpenDDS
OpenDDS is open source publish/subscribe middleware
OpenDDS is an open source implementation of the Object Management Group (OMG) Data Distribution Service (DDS), providing a publish/subscribe middleware solution for real-time distributed systems. OpenDDS includes development and run-time tools. Full product information, source code, documentation, build instructions, and license information are available from http://www.opendds.org. Commercial consulting, support, and training for OpenDDS are available. -
22
M3O
Next generation cloud
M3O is a next generation cloud plaform. Explore, discover and consume public APIs as simpler programmable building blocks. One platform, one account, one framework. Discover, explore and consume public APIs all in one place. Manage your API usage with one account and one token. Learn, develop and integrate using one set of docs and libraries. Predictable pricing with no hidden costs. It’s free to start and everything is priced per request. So far there are over 50+ APIs. Geocode an address... -
23
libcluster
Automatic cluster formation/healing for Elixir applications
libcluster provides automatic cluster formation and node discovery for Erlang/Elixir applications, removing the manual steps typically required to connect distributed nodes. It ships with multiple pluggable strategies—such as DNS polling, Kubernetes integration, EC2 metadata/tag discovery, UDP gossip, and EPMD helpers—so you can adapt clustering to your runtime environment. The library supervises a topology process that continually discovers peers and joins or prunes nodes as they become... -
24
Godis
A Golang implemented Redis Server and Cluster
Godis is a golang implementation of Redis Server, which intents to provide an example of writing a high concurrent middleware using golang. MULTI Commands Transaction is Atomic and Isolated. If any errors are encountered during execution, godis will rollback the executed commands. Server-side Cluster which is transparent to client. You can connect to any node in the cluster to access all data in the cluster. MSET, MSETNX, DEL, Rename, RenameNX command is supported and atomically executed in... -
25
QP/C++ Real-Time Embedded Framework
Mirror of the QP/C++ real-time embedded framewrok GitHub repo
QP/C++ real-time embedded framework/RTOS for embedded systems based on active objects (actors) and hierarchical state machines.
