blockengine_client

Documentation

Index

• type Relayer
  • func NewRelayer(ctx context.Context, grpcDialURL string, privateKey solana.PrivateKey, ...) (*Relayer, error)
  • func (c *Relayer) OnStartExpiringPacketStream(ctx context.Context) (<-chan *proto.StartExpiringPacketStreamResponse, <-chan error, error)
  • func (c *Relayer) OnSubscribeAccountsOfInterest(ctx context.Context) (<-chan *proto.AccountsOfInterestUpdate, <-chan error, error)
  • func (c *Relayer) OnSubscribeProgramsOfInterest(ctx context.Context) (<-chan *proto.ProgramsOfInterestUpdate, <-chan error, error)
  • func (c *Relayer) StartExpiringPacketStream(opts ...grpc.CallOption) (proto.BlockEngineRelayer_StartExpiringPacketStreamClient, error)
  • func (c *Relayer) SubscribeAccountsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeAccountsOfInterestClient, error)
  • func (c *Relayer) SubscribeProgramsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeProgramsOfInterestClient, error)
• type Validator
  • func NewValidator(ctx context.Context, grpcDialURL string, privateKey solana.PrivateKey, ...) (*Validator, error)
  • func (c *Validator) GetBlockBuilderFeeInfo(opts ...grpc.CallOption) (*proto.BlockBuilderFeeInfoResponse, error)
  • func (c *Validator) OnBundleSubscription(ctx context.Context) (<-chan []*proto.BundleUuid, <-chan error, error)
  • func (c *Validator) OnPacketSubscription(ctx context.Context) (<-chan *proto.SubscribePacketsResponse, <-chan error, error)
  • func (c *Validator) SubscribeBundles() (proto.BlockEngineValidator_SubscribeBundlesClient, error)
  • func (c *Validator) SubscribePackets() (proto.BlockEngineValidator_SubscribePacketsClient, error)

Types

type Relayer

type Relayer struct {
	GrpcConn *grpc.ClientConn

	Client proto.BlockEngineRelayerClient

	Auth *pkg.AuthenticationService

	ErrChan <-chan error // ErrChan is used for dispatching errors from functions executed within goroutines.
}

func NewRelayer

func NewRelayer(ctx context.Context, grpcDialURL string, privateKey solana.PrivateKey, tlsConfig *tls.Config, opts ...grpc.DialOption) (*Relayer, error)

func (*Relayer) OnStartExpiringPacketStream

func (c *Relayer) OnStartExpiringPacketStream(ctx context.Context) (<-chan *proto.StartExpiringPacketStreamResponse, <-chan error, error)

OnStartExpiringPacketStream is a wrapper of StartExpiringPacketStream.

func (*Relayer) OnSubscribeAccountsOfInterest

func (c *Relayer) OnSubscribeAccountsOfInterest(ctx context.Context) (<-chan *proto.AccountsOfInterestUpdate, <-chan error, error)

OnSubscribeAccountsOfInterest is a wrapper of SubscribeAccountsOfInterest.

func (*Relayer) OnSubscribeProgramsOfInterest

func (c *Relayer) OnSubscribeProgramsOfInterest(ctx context.Context) (<-chan *proto.ProgramsOfInterestUpdate, <-chan error, error)

OnSubscribeProgramsOfInterest is a wrapper of SubscribeProgramsOfInterest.

func (*Relayer) StartExpiringPacketStream

func (c *Relayer) StartExpiringPacketStream(opts ...grpc.CallOption) (proto.BlockEngineRelayer_StartExpiringPacketStreamClient, error)

func (*Relayer) SubscribeAccountsOfInterest

func (c *Relayer) SubscribeAccountsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeAccountsOfInterestClient, error)

func (*Relayer) SubscribeProgramsOfInterest

func (c *Relayer) SubscribeProgramsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeProgramsOfInterestClient, error)

type Validator

type Validator struct {
	GrpcConn *grpc.ClientConn

	Client proto.BlockEngineValidatorClient

	Auth *pkg.AuthenticationService

	ErrChan <-chan error // ErrChan is used for dispatching errors from functions executed within goroutines.
}

func NewValidator

func NewValidator(ctx context.Context, grpcDialURL string, privateKey solana.PrivateKey, tlsConfig *tls.Config, opts ...grpc.DialOption) (*Validator, error)

func (*Validator) GetBlockBuilderFeeInfo

func (c *Validator) GetBlockBuilderFeeInfo(opts ...grpc.CallOption) (*proto.BlockBuilderFeeInfoResponse, error)

func (*Validator) OnBundleSubscription

func (c *Validator) OnBundleSubscription(ctx context.Context) (<-chan []*proto.BundleUuid, <-chan error, error)

OnBundleSubscription is a wrapper of SubscribeBundles.

func (*Validator) OnPacketSubscription

func (c *Validator) OnPacketSubscription(ctx context.Context) (<-chan *proto.SubscribePacketsResponse, <-chan error, error)

OnPacketSubscription is a wrapper of SubscribePackets.

func (*Validator) SubscribeBundles

func (c *Validator) SubscribeBundles() (proto.BlockEngineValidator_SubscribeBundlesClient, error)

func (*Validator) SubscribePackets

func (c *Validator) SubscribePackets() (proto.BlockEngineValidator_SubscribePacketsClient, error)