blockworks-foundation
/
geyser-grpc-connector
mirror of https://github.com/blockworks-foundation/geyser-grpc-connector.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
212 Commits 27 Branches 26 Tags 2.4 MiB
Rust 92.3%
Shell 7.7%
Go to file
GroovieGermanikus 89f27a3404
comment on yellowstone version 		2024-12-09 12:06:26 +01:00
.github/workflows
…
ci fix rust+deps version 2024-12-09 11:55:02 +01:00
examples Makes clippy happy 2024-11-26 11:24:51 +08:00
src comment on loop break 2024-12-09 12:06:04 +01:00
.gitignore gitignore 2023-12-15 10:28:49 +01:00
Cargo.lock Applies PR feedback and some clippy fixes 2024-11-26 11:07:08 +08:00
Cargo.toml comment on yellowstone version 2024-12-09 12:06:26 +01:00
LICENSE add license file 2023-12-20 09:45:34 +01:00
README.md Update to 2.0.16 2024-11-20 13:35:37 +08:00
accounts-testnet.csv args 2024-05-07 10:54:06 +02:00
rust-toolchain.toml Applies PR feedback and some clippy fixes 2024-11-26 11:07:08 +08:00

README.md

Solana Geyser gRPC Multiplexing and Reconnect

This project provides multiplexing of multiple Yellowstone gRPC subscriptions based on Fastest Wins Strategy.

  • Multiple Futures get merged where the first next block that arrives will be emitted.
  • No guarantees are made about if the messages are continuous or not.
  • Reconnects are handled transparently inside the Futures.

Disclaimer: The library is designed with the needs of LiteRPC in mind yet might be useful for other projects as well.

The implementation is based on Rust Futures.

Please open an issue if you have any questions or suggestions -> New Issue.

Versions

These are the currently maintained versions of the library: see Wiki

Installation and Usage

cargo add geyser-grpc-connector

An example how to use the library is provided in stream_blocks_mainnet_stream.rs.

Known issues

  • Library does not support other data than Blocks/Slots very well.
  • Should not be used with commitment level PROCESSED because slot numbers are not monotoic.
  • Library needs messages to be in order and provide slot information to work properly.