jito_geyser

Documentation

Index

• type Client
  • func New(ctx context.Context, grpcDialURL string, md metadata.MD) (*Client, error)
  • func (c *Client) AddStreamClient(ctx context.Context, streamName string, opts ...grpc.CallOption) error
  • func (c *Client) Close() error
  • func (c *Client) GetFilters() []string
  • func (c *Client) GetStreamClient(streamName string) *StreamClient
• type StreamClient
  • func (s *StreamClient) GetHeartbeatInterval(opts ...grpc.CallOption) (*jito_geyser_pb.GetHeartbeatIntervalResponse, error)
  • func (s *StreamClient) SubscribeAccounts(filterName string, accounts ...string) error
  • func (s *StreamClient) SubscribeBlocks(filterName string) error
  • func (s *StreamClient) SubscribePartialAccount(filterName string, skipVoteAccounts bool) error
  • func (s *StreamClient) SubscribePrograms(filterName string, programs ...string) error
  • func (s *StreamClient) SubscribeSlots(filterName string) error
  • func (s *StreamClient) SubscribeSlotsEntry(filterName string) error
  • func (s *StreamClient) SubscribeTransaction(filterName string) error
  • func (s *StreamClient) UnsubscribeAccounts(filterName string)
  • func (s *StreamClient) UnsubscribeBlocks(filterName string)
  • func (s *StreamClient) UnsubscribePartialAccount(filterName string)
  • func (s *StreamClient) UnsubscribePrograms(filterName string)
  • func (s *StreamClient) UnsubscribeSlots(filterName string)
  • func (s *StreamClient) UnsubscribeTransaction(filterName string)

Types

type Client

type Client struct {
	GrpcConn *grpc.ClientConn
	Ctx      context.Context
	Geyser   jito_geyser_pb.GeyserClient
	ErrCh    chan error

	Stream *StreamClient
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, grpcDialURL string, md metadata.MD) (*Client, error)

New creates a new Client instance.

func (*Client) AddStreamClient

func (c *Client) AddStreamClient(ctx context.Context, streamName string, opts ...grpc.CallOption) error

AddStreamClient creates a new Geyser subscribe stream client. You can retrieve it with GetStreamClient.

func (*Client) Close

func (c *Client) Close() error

func (*Client) GetFilters

func (c *Client) GetFilters() []string

func (*Client) GetStreamClient

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

GetStreamClient returns a StreamClient for the given streamName from the client's map.

type StreamClient

type StreamClient struct {
	Ctx context.Context

	Accounts        map[string]grpc.ServerStreamingClient[jito_geyser_pb.TimestampedAccountUpdate]
	PartialAccounts map[string]grpc.ServerStreamingClient[jito_geyser_pb.MaybePartialAccountUpdate]
	Slots           map[string]grpc.ServerStreamingClient[jito_geyser_pb.TimestampedSlotUpdate]
	SlotsEntry      map[string]grpc.ServerStreamingClient[jito_geyser_pb.TimestampedSlotEntryUpdate]
	Programs        map[string]grpc.ServerStreamingClient[jito_geyser_pb.TimestampedAccountUpdate]
	Blocks          map[string]grpc.ServerStreamingClient[jito_geyser_pb.TimestampedBlockUpdate]
	Transactions    map[string]grpc.ServerStreamingClient[jito_geyser_pb.TimestampedTransactionUpdate]

	ErrCh chan error
	// contains filtered or unexported fields
}

func (*StreamClient) GetHeartbeatInterval

func (s *StreamClient) GetHeartbeatInterval(opts ...grpc.CallOption) (*jito_geyser_pb.GetHeartbeatIntervalResponse, error)

GetHeartbeatInterval returns

func (*StreamClient) SubscribeAccounts

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

SubscribeAccounts subscribes to account updates.

func (*StreamClient) SubscribeBlocks

func (s *StreamClient) SubscribeBlocks(filterName string) error

SubscribeBlocks subscribes to block updates.

func (*StreamClient) SubscribePartialAccount

func (s *StreamClient) SubscribePartialAccount(filterName string, skipVoteAccounts bool) error

SubscribePartialAccount subscribes .

func (*StreamClient) SubscribePrograms

func (s *StreamClient) SubscribePrograms(filterName string, programs ...string) error

SubscribePrograms subscribes to program updates.

func (*StreamClient) SubscribeSlots

func (s *StreamClient) SubscribeSlots(filterName string) error

SubscribeSlots subscribes to slot updates.

func (*StreamClient) SubscribeSlotsEntry

func (s *StreamClient) SubscribeSlotsEntry(filterName string) error

func (*StreamClient) SubscribeTransaction

func (s *StreamClient) SubscribeTransaction(filterName string) error

SubscribeTransaction subscribes to transaction updates.

func (*StreamClient) UnsubscribeAccounts

func (s *StreamClient) UnsubscribeAccounts(filterName string)

UnsubscribeAccounts unsubscribes all accounts.

func (*StreamClient) UnsubscribeBlocks

func (s *StreamClient) UnsubscribeBlocks(filterName string)

func (*StreamClient) UnsubscribePartialAccount

func (s *StreamClient) UnsubscribePartialAccount(filterName string)

func (*StreamClient) UnsubscribePrograms

func (s *StreamClient) UnsubscribePrograms(filterName string)

func (*StreamClient) UnsubscribeSlots

func (s *StreamClient) UnsubscribeSlots(filterName string)

UnsubscribeSlots unsubscribes from slot updates.

func (*StreamClient) UnsubscribeTransaction

func (s *StreamClient) UnsubscribeTransaction(filterName string)

UnsubscribeTransaction unsubscribes from transaction updates.