blockengine_client

Documentation

Index

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

Types

type Relayer

type Relayer struct {
	GrpcConn *grpc.ClientConn

	Client jito_pb.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) Close

func (c *Relayer) Close() error

func (*Relayer) OnStartExpiringPacketStream

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

OnStartExpiringPacketStream is a wrapper of StartExpiringPacketStream.

func (*Relayer) OnSubscribeAccountsOfInterest

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

OnSubscribeAccountsOfInterest is a wrapper of SubscribeAccountsOfInterest.

func (*Relayer) OnSubscribeProgramsOfInterest

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

OnSubscribeProgramsOfInterest is a wrapper of SubscribeProgramsOfInterest.

func (*Relayer) StartExpiringPacketStream

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

func (*Relayer) SubscribeAccountsOfInterest

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

func (*Relayer) SubscribeProgramsOfInterest

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

type Validator

type Validator struct {
	GrpcConn *grpc.ClientConn

	Client jito_pb.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) Close

func (c *Validator) Close() error

func (*Validator) GetBlockBuilderFeeInfo

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

func (*Validator) OnBundleSubscription

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

OnBundleSubscription is a wrapper of SubscribeBundles.

func (*Validator) OnPacketSubscription

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

OnPacketSubscription is a wrapper of SubscribePackets.

func (*Validator) SubscribeBundles

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

func (*Validator) SubscribePackets

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