blockengine_client

package
v0.0.0-...-b957f52 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*Validator) SubscribePackets

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL