geyser_client

Documentation

Index

• type Client
  • func NewGeyserClient(ctx context.Context, grpcDialURL string, tlsConfig *tls.Config, ...) (*Client, error)
  • func (c *Client) OnAccountUpdates(ctx context.Context, sub proto.Geyser_SubscribeAccountUpdatesClient, ...)
  • func (c *Client) OnBlockUpdates(ctx context.Context, sub proto.Geyser_SubscribeBlockUpdatesClient, ...)
  • func (c *Client) OnPartialAccountUpdates(ctx context.Context, sub proto.Geyser_SubscribePartialAccountUpdatesClient, ...)
  • func (c *Client) OnProgramUpdate(ctx context.Context, sub proto.Geyser_SubscribeProgramUpdatesClient, ...)
  • func (c *Client) OnSlotUpdates(ctx context.Context, sub proto.Geyser_SubscribeSlotUpdatesClient, ...)
  • func (c *Client) OnTransactionUpdates(ctx context.Context, sub proto.Geyser_SubscribeTransactionUpdatesClient, ...)
  • 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
	GrpcErrCh chan error
	Ctx       context.Context

	Geyser proto.GeyserClient

	ErrCh chan error
}

func NewGeyserClient

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

NewGeyserClient 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, sub proto.Geyser_SubscribeAccountUpdatesClient, ch chan *proto.AccountUpdate)

func (*Client) OnBlockUpdates

func (c *Client) OnBlockUpdates(ctx context.Context, sub proto.Geyser_SubscribeBlockUpdatesClient, ch chan *proto.BlockUpdate)

func (*Client) OnPartialAccountUpdates

func (c *Client) OnPartialAccountUpdates(ctx context.Context, sub proto.Geyser_SubscribePartialAccountUpdatesClient, ch chan *proto.PartialAccountUpdate)

func (*Client) OnProgramUpdate

func (c *Client) OnProgramUpdate(ctx context.Context, sub proto.Geyser_SubscribeProgramUpdatesClient, ch chan *proto.AccountUpdate)

func (*Client) OnSlotUpdates

func (c *Client) OnSlotUpdates(ctx context.Context, sub proto.Geyser_SubscribeSlotUpdatesClient, ch chan *proto.SlotUpdate)

func (*Client) OnTransactionUpdates

func (c *Client) OnTransactionUpdates(ctx context.Context, sub proto.Geyser_SubscribeTransactionUpdatesClient, ch chan *proto.TransactionUpdate)

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)