Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

geyser_grpc

package

Go to main page

Versions in this module

v0

v0.0.5

Jan 24, 2025

v0.0.4

Dec 3, 2024

Changes in this version

type Client

+ func (c *Client) AddStreamClientWithoutSubscribe(ctx context.Context, streamName string, ...) error

v0.0.3

Nov 29, 2024

v0.0.2

Nov 29, 2024

Changes in this version

+ type Client struct

+ Ctx context.Context

+ ErrCh chan error

+ Geyser geyser_pb.GeyserClient

+ func (c *Client) AddStreamClient(ctx context.Context, streamName string, ...) error

+ func (c *Client) Close() error

+ func (c *Client) GetStreamClient(streamName string) *StreamClient

+ func (c *Client) Ping(count int32) (*geyser_pb.PongResponse, error)

+ type StreamClient struct

+ Ctx context.Context

+ ErrCh chan error

+ UpdateCh chan *geyser_pb.SubscribeUpdate

+ func (s *StreamClient) AppendAccounts(filterName string, accounts ...string) error

+ func (s *StreamClient) GetAccounts(filterName string) []string

+ func (s *StreamClient) NewRequest() *geyser_pb.SubscribeRequest

+ func (s *StreamClient) SendCustomRequest(request *geyser_pb.SubscribeRequest) error

+ func (s *StreamClient) SetCommitmentLevel(commitmentLevel *geyser_pb.CommitmentLevel)

+ func (s *StreamClient) SetRequest(req *geyser_pb.SubscribeRequest)

+ func (s *StreamClient) Stop()

+ func (s *StreamClient) SubscribeAccountDataSlice(req []*geyser_pb.SubscribeRequestAccountsDataSlice) error

+ func (s *StreamClient) SubscribeAccounts(filterName string, req *geyser_pb.SubscribeRequestFilterAccounts) error

+ func (s *StreamClient) SubscribeBlocks(filterName string, req *geyser_pb.SubscribeRequestFilterBlocks) error

+ func (s *StreamClient) SubscribeBlocksMeta(filterName string, req *geyser_pb.SubscribeRequestFilterBlocksMeta) error

+ func (s *StreamClient) SubscribeEntry(filterName string, req *geyser_pb.SubscribeRequestFilterEntry) error

+ func (s *StreamClient) SubscribeSlots(filterName string, req *geyser_pb.SubscribeRequestFilterSlots) error

+ func (s *StreamClient) SubscribeTransaction(filterName string, req *geyser_pb.SubscribeRequestFilterTransactions) error

+ func (s *StreamClient) SubscribeTransactionStatus(filterName string, req *geyser_pb.SubscribeRequestFilterTransactions) error

+ func (s *StreamClient) UnsubscribeAccountDataSlice() error

+ func (s *StreamClient) UnsubscribeAccounts(filterName string, accounts ...string) error

+ func (s *StreamClient) UnsubscribeAllAccounts(filterName string) error

+ func (s *StreamClient) UnsubscribeBlocks(filterName string) error

+ func (s *StreamClient) UnsubscribeBlocksMeta(filterName string) error

+ func (s *StreamClient) UnsubscribeEntry(filterName string) error

+ func (s *StreamClient) UnsubscribeSlots(filterName string) error

+ func (s *StreamClient) UnsubscribeTransaction(filterName string) error

+ func (s *StreamClient) UnsubscribeTransactionStatus(filterName string) error

+ type StreamManager struct

v0.0.1

Nov 26, 2024

Changes in this version

+ func BatchConvertBlockHash(geyserBlocks ...*geyser_pb.SubscribeUpdateBlock) []*rpc.GetBlockResult

+ func BatchConvertTransaction(geyserTxns ...*geyser_pb.SubscribeUpdateTransaction) []*rpc.GetTransactionResult

+ func ConvertBlockHash(geyserBlock *geyser_pb.SubscribeUpdateBlock) *rpc.GetBlockResult

+ func ConvertTransaction(geyserTx *geyser_pb.SubscribeUpdateTransaction) (*rpc.GetTransactionResult, error)

+ func New(ctx context.Context, grpcDialURL string, useGzipCompression bool, ...) (*client, error)