geyser_client

Documentation

Index

• type Client
  • func New(ctx context.Context, grpcDialURL string, tlsConfig *tls.Config, ...) (*Client, error)
  • func (c *Client) OnAccountUpdates(ctx context.Context, accounts []string, opts ...grpc.CallOption) (<-chan *proto.TimestampedAccountUpdate, <-chan error, error)
  • func (c *Client) OnBlockUpdates(ctx context.Context) (<-chan *proto.TimestampedBlockUpdate, <-chan error, error)
  • func (c *Client) OnPartialAccountUpdates(ctx context.Context) (<-chan *proto.PartialAccountUpdate, <-chan error, error)
  • func (c *Client) OnProgramUpdates(ctx context.Context, programs []string, opts ...grpc.CallOption) (<-chan *proto.TimestampedAccountUpdate, <-chan error, error)
  • func (c *Client) OnSlotUpdates(ctx context.Context, opts ...grpc.CallOption) (<-chan *proto.TimestampedSlotUpdate, <-chan error, error)
  • func (c *Client) OnTransactionUpdates(ctx context.Context) (<-chan *proto.TimestampedTransactionUpdate, <-chan error, error)
  • func (c *Client) SubscribeAccountUpdates(accounts []string, opts ...grpc.CallOption) (proto.Geyser_SubscribeAccountUpdatesClient, error)
  • func (c *Client) SubscribeBlockUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribeBlockUpdatesClient, error)
  • func (c *Client) SubscribePartialAccountUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribePartialAccountUpdatesClient, error)
  • func (c *Client) SubscribeProgramUpdates(programs []string, opts ...grpc.CallOption) (proto.Geyser_SubscribeProgramUpdatesClient, error)
  • func (c *Client) SubscribeSlotUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribeSlotUpdatesClient, error)
  • func (c *Client) SubscribeTransactionUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribeTransactionUpdatesClient, error)

Types

type Client

type Client struct {
	GrpcConn *grpc.ClientConn
	Ctx      context.Context

	Geyser proto.GeyserClient

	ErrChan <-chan error
}

func New

func New(ctx context.Context, grpcDialURL string, tlsConfig *tls.Config, opts ...grpc.DialOption) (*Client, error)

New creates a new RPC client and connects to the provided endpoint. A Geyser RPC URL is required.

func (*Client) OnAccountUpdates

func (c *Client) OnAccountUpdates(ctx context.Context, accounts []string, opts ...grpc.CallOption) (<-chan *proto.TimestampedAccountUpdate, <-chan error, error)

OnAccountUpdates is a wrapper of SubscribeAccountUpdates.

func (*Client) OnBlockUpdates

func (c *Client) OnBlockUpdates(ctx context.Context) (<-chan *proto.TimestampedBlockUpdate, <-chan error, error)

OnBlockUpdates is a wrapper of SubscribeBlockUpdates.

func (*Client) OnPartialAccountUpdates

func (c *Client) OnPartialAccountUpdates(ctx context.Context) (<-chan *proto.PartialAccountUpdate, <-chan error, error)

OnPartialAccountUpdates is a wrapper of SubscribePartialAccountUpdates.

func (*Client) OnProgramUpdates

func (c *Client) OnProgramUpdates(ctx context.Context, programs []string, opts ...grpc.CallOption) (<-chan *proto.TimestampedAccountUpdate, <-chan error, error)

OnProgramUpdates is a wrapper of SubscribeProgramUpdates.

func (*Client) OnSlotUpdates

func (c *Client) OnSlotUpdates(ctx context.Context, opts ...grpc.CallOption) (<-chan *proto.TimestampedSlotUpdate, <-chan error, error)

OnSlotUpdates is a wrapper of SubscribeSlotUpdates.

func (*Client) OnTransactionUpdates

func (c *Client) OnTransactionUpdates(ctx context.Context) (<-chan *proto.TimestampedTransactionUpdate, <-chan error, error)

OnTransactionUpdates is a wrapper of SubscribeTransactionUpdates.

func (*Client) SubscribeAccountUpdates

func (c *Client) SubscribeAccountUpdates(accounts []string, opts ...grpc.CallOption) (proto.Geyser_SubscribeAccountUpdatesClient, error)

func (*Client) SubscribeBlockUpdates

func (c *Client) SubscribeBlockUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribeBlockUpdatesClient, error)

func (*Client) SubscribePartialAccountUpdates

func (c *Client) SubscribePartialAccountUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribePartialAccountUpdatesClient, error)

func (*Client) SubscribeProgramUpdates

func (c *Client) SubscribeProgramUpdates(programs []string, opts ...grpc.CallOption) (proto.Geyser_SubscribeProgramUpdatesClient, error)

func (*Client) SubscribeSlotUpdates

func (c *Client) SubscribeSlotUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribeSlotUpdatesClient, error)

func (*Client) SubscribeTransactionUpdates

func (c *Client) SubscribeTransactionUpdates(opts ...grpc.CallOption) (proto.Geyser_SubscribeTransactionUpdatesClient, error)