message-passing | Topic | Ecosyste.ms: Repos

Topic: "message-passing"

php-enqueue/enqueue-dev

Message Queue, Job Queue, Broadcasting, WebSockets packages for PHP, Symfony, Laravel, Magento. DEVELOPMENT REPOSITORY - provided by Forma-Pro

Language: PHP - Size: 19.3 MB - Last synced at: 19 days ago - Pushed at: 29 days ago - Stars: 2,189 - Forks: 442

discord/manifold

Fast batch message passing between nodes for Erlang/Elixir.

Language: Elixir - Size: 85 KB - Last synced at: 7 days ago - Pushed at: about 2 years ago - Stars: 1,800 - Forks: 72

andywer/pg-listen

📡 PostgreSQL LISTEN & NOTIFY for node.js that finally works.

Language: TypeScript - Size: 413 KB - Last synced at: 10 days ago - Pushed at: 12 months ago - Stars: 619 - Forks: 32

Pyrlang/Pyrlang

Erlang node implemented in Python 3.5+ (Asyncio-based)

Language: Python - Size: 1020 KB - Last synced at: 16 days ago - Pushed at: 2 months ago - Stars: 617 - Forks: 61

mratsim/weave

A state-of-the-art multithreading runtime: message-passing based, fast, scalable, ultra-low overhead

Language: Nim - Size: 8.58 MB - Last synced at: 1 day ago - Pushed at: 11 months ago - Stars: 558 - Forks: 22

breandan/kotlingrad

🧩 Shape-Safe Symbolic Differentiation with Algebraic Data Types

Language: Kotlin - Size: 288 MB - Last synced at: 17 days ago - Pushed at: 6 months ago - Stars: 537 - Forks: 22

Stiffstream/sobjectizer

An implementation of Actor, Publish-Subscribe, and CSP models in one rather small C++ framework. With performance, quality, and stability proved by years in the production.

Language: C++ - Size: 14.4 MB - Last synced at: 8 days ago - Pushed at: 11 days ago - Stars: 533 - Forks: 50

yarpc/yarpc-go

A message passing platform for Go

Language: Go - Size: 14.4 MB - Last synced at: 6 days ago - Pushed at: 10 days ago - Stars: 420 - Forks: 110

FutureSDR/FutureSDR

An Async SDR Runtime for Heterogeneous Architectures

Language: Rust - Size: 26.8 MB - Last synced at: 16 days ago - Pushed at: about 1 month ago - Stars: 370 - Forks: 62

ReactiveBayes/RxInfer.jl

Julia package for automated Bayesian inference on a factor graph with reactive message passing

Language: Jupyter Notebook - Size: 437 MB - Last synced at: 4 days ago - Pushed at: 7 days ago - Stars: 338 - Forks: 29

kyzhouhzau/NLPGNN

1. Use BERT, ALBERT and GPT2 as tensorflow2.0's layer. 2. Implement GCN, GAN, GIN and GraphSAGE based on message passing.

Language: Python - Size: 205 KB - Last synced at: 14 days ago - Pushed at: 10 months ago - Stars: 334 - Forks: 66

vijaydwivedi75/gnn-lspe

Source code for GNN-LSPE (Graph Neural Networks with Learnable Structural and Positional Representations), ICLR 2022

Language: Python - Size: 267 KB - Last synced at: 2 months ago - Pushed at: over 3 years ago - Stars: 253 - Forks: 36

huangwl18/modular-rl

[ICML 2020] PyTorch Code for "One Policy to Control Them All: Shared Modular Policies for Agent-Agnostic Control"

Language: Jupyter Notebook - Size: 4.26 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 230 - Forks: 35

Mostafa-Samir/klyng

A message-passing distributed computing framework for node.js

Language: JavaScript - Size: 166 KB - Last synced at: 20 days ago - Pushed at: about 8 years ago - Stars: 167 - Forks: 10

Elepover/pmcenter

A Telegram bot helping you process private messages.

Language: C# - Size: 8.51 MB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 152 - Forks: 37

ALANVF/star

An experimental programming language that's made to be powerful, productive, and predictable

Language: Haxe - Size: 2.24 MB - Last synced at: 3 days ago - Pushed at: 3 months ago - Stars: 136 - Forks: 2

ReactiveBayes/ReactiveMP.jl

High-performance reactive message-passing based Bayesian inference engine

Language: Julia - Size: 107 MB - Last synced at: 17 days ago - Pushed at: 17 days ago - Stars: 112 - Forks: 14

bknyaz/sgg

Train Scene Graph Generation for Visual Genome and GQA in PyTorch >= 1.2 with improved zero and few-shot generalization.

Language: Jupyter Notebook - Size: 21.8 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 99 - Forks: 20

eao197/so-5-5

SObjectizer: it's all about in-process message dispatching!

Language: C++ - Size: 4.78 MB - Last synced at: about 2 months ago - Pushed at: almost 5 years ago - Stars: 88 - Forks: 6

VIS4ROB-lab/hyperion

Symbolic Continuous-Time Gaussian Belief Propagation Framework with Ceres Interoperability

Language: C++ - Size: 7.39 MB - Last synced at: 6 months ago - Pushed at: 7 months ago - Stars: 83 - Forks: 10

relvaner/actor4j-core

Actor4j is a multi-runtime actor-oriented Java framework.

Language: Java - Size: 8.67 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 72 - Forks: 14

eugeneia/erlangen

Distributed, asychronous message passing system for Clozure Common Lisp

Language: Common Lisp - Size: 189 KB - Last synced at: 2 months ago - Pushed at: over 7 years ago - Stars: 66 - Forks: 9

faasm/faabric

Messaging and state layer for distributed serverless applications

Language: C++ - Size: 2.35 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 65 - Forks: 14

duckstax/actor-zeta

Library that provides an actor style message-passing programming model (in C++).

Language: C++ - Size: 2.1 MB - Last synced at: about 2 months ago - Pushed at: 2 months ago - Stars: 65 - Forks: 9

danbar/fglib

factor graph library

Language: Python - Size: 108 KB - Last synced at: 11 months ago - Pushed at: over 6 years ago - Stars: 64 - Forks: 17

benedekrozemberczki/PDN

The official PyTorch implementation of "Pathfinder Discovery Networks for Neural Message Passing" (WebConf '21)

Language: Python - Size: 4.8 MB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 58 - Forks: 11

p-ranav/iris

Lightweight Component Model and Messaging Framework based on ØMQ

Language: C++ - Size: 21.3 MB - Last synced at: about 1 month ago - Pushed at: about 5 years ago - Stars: 53 - Forks: 3

php-enqueue/rdkafka

[READ-ONLY] The Kafka Enqueue transport.

Language: PHP - Size: 146 KB - Last synced at: 14 days ago - Pushed at: 29 days ago - Stars: 51 - Forks: 40

pgiri/pycos

Concurrent, Asynchronous, Distributed, Communicating Tasks with Python

Language: Python - Size: 1.6 MB - Last synced at: 5 days ago - Pushed at: 12 months ago - Stars: 48 - Forks: 9

Zubax/ramen

Real-time Actor-based Message Exchange Network 🍜

Language: C++ - Size: 164 KB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 46 - Forks: 3

gr-eventstream is a set of GNU Radio blocks for creating precisely timed events and either inserting them into, or extracting them from normal data-streams precisely. It allows for the definition of high speed time-synchronous c++ burst event handlers, as well as bridging to standard GNU Radio Async PDU messages with precise timing easily.

Language: C++ - Size: 842 KB - Last synced at: about 2 months ago - Pushed at: over 7 years ago - Stars: 44 - Forks: 28

CarsonScott/Knowledge-Discovery-Agents

A Goal-Oriented Approach to Knowledge Discovery in Multi-Agent Systems

Size: 250 KB - Last synced at: over 2 years ago - Pushed at: about 8 years ago - Stars: 38 - Forks: 3

ostwalprasad/LGNpy

Linear Gaussian Bayesian Networks - Inference, Parameter Learning and Representation. 🖧

Language: Python - Size: 702 KB - Last synced at: 12 days ago - Pushed at: almost 3 years ago - Stars: 36 - Forks: 8

tk-rusch/gradientgating

Gradient gating (ICLR 2023)

Language: Python - Size: 241 KB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 33 - Forks: 2

ecrl/graphchem

Graph-based machine learning for chemical property prediction

Language: Python - Size: 2.7 MB - Last synced at: 26 days ago - Pushed at: 4 months ago - Stars: 32 - Forks: 7

SirWaithaka/simple-wallet

This is a simple wallet REST api that is capable of acount deposits and withdrawals, checking for account balance and providing a ministatement. It follows domain driven design practices. The project uses the DDD architecture approach.

Language: Go - Size: 146 KB - Last synced at: almost 2 years ago - Pushed at: over 4 years ago - Stars: 32 - Forks: 12

bmoren/p5.localmessage

p5.localmessage provides an interface to send messages locally from one sketch to another with a service worker for multi-window sketching!

Language: JavaScript - Size: 535 KB - Last synced at: 2 months ago - Pushed at: about 6 years ago - Stars: 32 - Forks: 4

kcenon/messaging_system

Asynchronous TCP communication system in order to support micro-service architecture.

Language: C++ - Size: 1.14 MB - Last synced at: 7 days ago - Pushed at: 8 days ago - Stars: 31 - Forks: 1

mark-i-m/os2

x86_64 OS kernel with completely async userspace and single address space [WIP; but basic kernel functionality implemented]

Language: Rust - Size: 201 KB - Last synced at: about 2 months ago - Pushed at: about 5 years ago - Stars: 31 - Forks: 4

jwu4sml/Graph-Embedding-Techniques

It provides some typical graph embedding techniques based on task-free or task-specific intuitions.

Size: 104 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 31 - Forks: 11

dtqec/aether

Distributed system emulation in Common Lisp

Language: Common Lisp - Size: 73.2 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 29 - Forks: 1

mcosovic/FactorGraph.jl

The FactorGraph package provides the set of different functions to perform inference over the factor graph with continuous or discrete random variables using the belief propagation algorithm.

Language: Julia - Size: 8.63 MB - Last synced at: about 1 month ago - Pushed at: almost 3 years ago - Stars: 29 - Forks: 4

njmarko/machine-learning-with-graphs

My solutions for Stanford University course CS224W: Machine Learning with Graphs Fall 2021 colabs (GNN, GAT, GraphSAGE, GCN)

Language: Jupyter Notebook - Size: 1.25 MB - Last synced at: 2 months ago - Pushed at: about 3 years ago - Stars: 29 - Forks: 3

sargun/wat

How fast are computers?

Language: C - Size: 29.3 KB - Last synced at: about 2 years ago - Pushed at: about 8 years ago - Stars: 26 - Forks: 7

LouisCharlesC/mess

A compile-time header-only C++17 library for dataflow programing.

Language: C++ - Size: 374 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 24 - Forks: 2

thadikari/ldpc_decoders

Belief propagation with sparse matrices (scipy.sparse) in Python for LDPC codes. Includes NumPy implementation of message passing (min-sum and sum-product) and a few other decoders.

Language: Python - Size: 3.27 MB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 23 - Forks: 7

ngoctrng/golang-outbox-example

Example outbox pattern implement in Golang

Language: Go - Size: 95.7 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 22 - Forks: 0

TurtleKitty/Vaquero

A scripting language for cowboy coders

Language: Scheme - Size: 353 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 22 - Forks: 2

hurlybird/Duck

Duck-Typed Programming in C

Language: C - Size: 1.84 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 18 - Forks: 0

samuelsonric/AlgebraicInference.jl

Bayesian inference on wiring diagrams.

Language: Julia - Size: 1.77 MB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 18 - Forks: 1

asimen1/ext-messenger

📫 Extension message passing made easy

Language: JavaScript - Size: 88.9 KB - Last synced at: 7 days ago - Pushed at: 9 months ago - Stars: 17 - Forks: 0

extremecodetv/message-passing

Пример реализации посылки сообщений

Language: JavaScript - Size: 3.91 KB - Last synced at: 2 months ago - Pushed at: about 3 years ago - Stars: 16 - Forks: 4

simplygreatwork/godsend

A simple and eloquent workflow for streaming messages to micro-services.

Language: JavaScript - Size: 634 KB - Last synced at: 9 days ago - Pushed at: about 8 years ago - Stars: 16 - Forks: 1

yihong-chen/ReFactorGNN

Implementation for ReFactor GNNs

Language: Python - Size: 7.81 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 15 - Forks: 0

shawnh2/GNN-CCA

DGL implementation of GNN-CCA: Graph Neural Networks for Cross-Camera Data Association [arXiv:2201.06311]

Language: Python - Size: 290 KB - Last synced at: about 13 hours ago - Pushed at: over 2 years ago - Stars: 15 - Forks: 2

eerimoq/messi

⚽ Reliable message passing in distributed systems.

Language: C - Size: 470 KB - Last synced at: 22 days ago - Pushed at: about 2 years ago - Stars: 14 - Forks: 1

leostera/react-useMailbox

:mailbox: A small React hook to turn your components into "Actors".

Language: JavaScript - Size: 207 KB - Last synced at: 2 months ago - Pushed at: about 6 years ago - Stars: 13 - Forks: 0

asimen1/chrome-ext-messenger

DEPRECATED (use ext-messenger now): Chrome extension message passing made easy

Language: JavaScript - Size: 53.7 KB - Last synced at: 12 days ago - Pushed at: over 6 years ago - Stars: 13 - Forks: 3

gamblevore/PicoMsg

Miniature Message Passing IPC System (Single Header C++ File)

Language: C++ - Size: 136 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 12 - Forks: 1

ryansmccoy/zmq-high-speed-subs

Example of High-Speed Subscriber Patterns in ZeroMQ

Language: Python - Size: 538 KB - Last synced at: about 23 hours ago - Pushed at: over 2 years ago - Stars: 11 - Forks: 2

zduny/mezzenger

Message passing infrastructure for Rust.

Language: Rust - Size: 187 KB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 0

arangesh/TrackMPNN

Language: Python - Size: 1.95 MB - Last synced at: 3 months ago - Pushed at: about 3 years ago - Stars: 10 - Forks: 1

sunsided/Graph 📦

.NET pipeline/dataflow data processing framework written in C#

Language: C# - Size: 140 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 9 - Forks: 1

msgflo/msgflo-nodejs

Node.js participant support for MsgFlo

Language: CoffeeScript - Size: 405 KB - Last synced at: 2 months ago - Pushed at: about 5 years ago - Stars: 9 - Forks: 2

ilpropheta/calico

Camera Lite Composer, or just the project behind my blog series "SObjectizer Tales"

Language: C++ - Size: 367 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 8 - Forks: 1

mikyll/GoSnek

Go CLI implementation of Snake 🐍 game, using channels

Language: Go - Size: 1.5 MB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 8 - Forks: 0

lthibault/turbine

High-performance alternative to channels with pipelining

Language: Go - Size: 12.7 KB - Last synced at: about 2 months ago - Pushed at: about 6 years ago - Stars: 8 - Forks: 0

anqur/libscoa

Erlang-like lightweight C++ actor framework

Language: C++ - Size: 1.15 MB - Last synced at: about 2 months ago - Pushed at: about 7 years ago - Stars: 8 - Forks: 0

romanf-dev/magnesium

Hardware-assisted asynchronous micro-RTOS

Language: C - Size: 582 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 7 - Forks: 1

bayrameda/MrAP

NODE ATTRIBUTE COMPLETION IN KNOWLEDGE GRAPHS WITH MULTI-RELATIONAL PROPAGATION

Language: Jupyter Notebook - Size: 87.9 KB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 7 - Forks: 2

jishnub/MPIMapReduce.jl

An MPI-based distributed map-reduce function for Julia

Language: Julia - Size: 126 KB - Last synced at: 2 months ago - Pushed at: almost 4 years ago - Stars: 7 - Forks: 0

awncorp/zing

Actor-Model Toolkit and Multi-Process Management System

Language: Perl - Size: 389 KB - Last synced at: 2 months ago - Pushed at: over 4 years ago - Stars: 7 - Forks: 0

junipertcy/sbm-bp

Community detection engine for the degree-corrected Stochastic Block Model, using the Belief Propagation algorithm.

Language: C++ - Size: 87.9 KB - Last synced at: 2 days ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 0

FirstHandScientist/amp

Advanced Message Passing

Language: Python - Size: 1.64 MB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 1

FeiGSSS/NEDMP

Official PyTorch implementation of Neural Enhanced Dynamic Message Passing in AISTATS 2022

Language: Jupyter Notebook - Size: 44.9 MB - Last synced at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 6 - Forks: 2

unevens/lockfree-async

A simple C++17 header-only template library for lock-free inter-thread communication.

Language: C++ - Size: 316 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 6 - Forks: 0

iamjatinchauhan/OS-Programs

OS-Programs related to System Call, Process Creation, Threading, Synchronization, Race condition, Semaphores, Inter-Process-Communication, Pipes, Shared memory, message passing & further more.

Size: 715 KB - Last synced at: over 1 year ago - Pushed at: about 5 years ago - Stars: 6 - Forks: 11

kaymanb/todc

A collection of Rust crates for distributed computing.

Language: Rust - Size: 640 KB - Last synced at: 5 days ago - Pushed at: 8 months ago - Stars: 5 - Forks: 0

systems-group/anysystem

A framework for deterministic simulation and testing of distributed systems

Language: Rust - Size: 315 KB - Last synced at: 8 days ago - Pushed at: 8 months ago - Stars: 5 - Forks: 0

PhilippMDoerner/ThreadButler

Use threads as if they were servers/microservices to enable multi-threading with a simple mental model.

Language: Nim - Size: 581 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 5 - Forks: 0

lmiconsulting/cosasi

COntagion Simulation And Source Identification: a Python package for graph diffusion source inference

Language: Python - Size: 2.68 MB - Last synced at: 4 days ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 4

biaslab/RxAgent-Zoo

Archive of active inference agents based on reactive message passing.

Language: Jupyter Notebook - Size: 1 MB - Last synced at: 27 days ago - Pushed at: about 2 years ago - Stars: 5 - Forks: 0

zarexalvindaria/udaconnect

Refactored the Udaconnect app (from monolithic to microservices) and implemented Kafka, gRPC, and RESTful API to allow message passing between the microservices. I also created OpenAPI documentation for the API endpoints and provided a Postman library for the endpoints created.

Language: Python - Size: 946 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 1

mrusamamuzaffar/static_chat_screen

This is demo chat screen. You can add message to the sender side by simply pressing the send button and to add message to the receiver side, you have to long press the same send button.

Language: Dart - Size: 62.5 KB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 1

jcoo092/CML_benchmarks

The code and other assorted files pertaining to my attempts to benchmark parallel Concurrent ML processing in a handful of languages

Language: Racket - Size: 355 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 5 - Forks: 2

bezzad/TinyMediator

A light weight copy of MediatR for Mediator Pattern in .NetStandard

Language: C# - Size: 35.2 KB - Last synced at: about 2 months ago - Pushed at: over 5 years ago - Stars: 5 - Forks: 0

pawelswoboda/LP_MP-QAP

Dual decomposition solvers for the quadratic assignment problem (QAP), also called graph matching in computer vision based on the LP_MP library.

Language: C++ - Size: 65.4 KB - Last synced at: about 1 year ago - Pushed at: almost 7 years ago - Stars: 5 - Forks: 2

XerProjects/Xer.Delegator

A lightweight and easy-to-use delegate-based message routing library

Language: C# - Size: 115 KB - Last synced at: about 1 year ago - Pushed at: about 7 years ago - Stars: 5 - Forks: 1

osklunds/Distributed-SWMR-register

Emulation of an atomic single-writer multi-reader register in message passing systems, using the ABD algorithm.

Language: Rust - Size: 450 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 4 - Forks: 0

mauris/react-lh

📣 React Loud Hailer: message passing and state management for React

Language: JavaScript - Size: 169 KB - Last synced at: 7 days ago - Pushed at: almost 5 years ago - Stars: 4 - Forks: 0

JuliaRobotics/DrakeLCMTypes.jl

LCM type definitions for compatibility with RobotLocomotion/Drake in Julia

Language: Julia - Size: 20.5 KB - Last synced at: 2 months ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 1

20ft/messidge

An authenticated/secured message passing broker and clients

Language: Python - Size: 122 KB - Last synced at: 7 months ago - Pushed at: almost 7 years ago - Stars: 4 - Forks: 0

kevinchesser/Programming-erlang-2nd-edition-exercises

Exercises that go along with the book Programming Erlang Software for a Concurrent World - Second Edition

Language: Erlang - Size: 59.6 KB - Last synced at: 5 months ago - Pushed at: over 8 years ago - Stars: 4 - Forks: 1

Govcraft/acton-reactive

The Acton Reactive Application Framework provides an efficient way to build fast, reactive Rust applications. Designed around an actor-based model, it simplifies concurrency and allows developers to focus on writing scalable, maintainable code. Acton gets its name from the fact that it "acts on" messages you define.

Language: Rust - Size: 2.32 MB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 3 - Forks: 0

polluxio/pollux-payload

Pollux payload core files and examples

Language: C++ - Size: 19.1 MB - Last synced at: 27 days ago - Pushed at: 28 days ago - Stars: 3 - Forks: 0

git-afsantos/hpl-specs

High-Level Property Specification Language

Language: Python - Size: 250 KB - Last synced at: 7 days ago - Pushed at: 4 months ago - Stars: 3 - Forks: 0

relvaner/nodes4j-core 📦

Framework for parallel processing based on Actor4j. Useful for data analysis.

Language: Java - Size: 279 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 3