blockengine_client

Documentation

Index

• type RelayerBlockEngineClient
  • func NewRelayerBlockEngineClient(grpcDialURL string, rpcClient *rpc.Client, privateKey solana.PrivateKey, ...) (*RelayerBlockEngineClient, error)
  • func (c *RelayerBlockEngineClient) BlockEngineRelayerClientStartExpiringPacketStream(opts ...grpc.CallOption) (proto.BlockEngineRelayer_StartExpiringPacketStreamClient, error)
  • func (c *RelayerBlockEngineClient) BlockEngineRelayerClientSubscribeAccountsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeAccountsOfInterestClient, error)
  • func (c *RelayerBlockEngineClient) BlockEngineRelayerClientSubscribeProgramsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeProgramsOfInterestClient, error)
• type ValidatorBlockEngineClient
  • func NewValidatorBlockEngineClient(grpcDialURL string, rpcClient *rpc.Client, privateKey solana.PrivateKey, ...) (*ValidatorBlockEngineClient, error)
  • func (c *ValidatorBlockEngineClient) BlockEngineValidatorClientGetBlockBuilderFeeInfo(opts ...grpc.CallOption) (*proto.BlockBuilderFeeInfoResponse, error)
  • func (c *ValidatorBlockEngineClient) BlockEngineValidatorClientSubscribeBundles() (proto.BlockEngineValidator_SubscribeBundlesClient, error)
  • func (c *ValidatorBlockEngineClient) BlockEngineValidatorClientSubscribePackets() (proto.BlockEngineValidator_SubscribePacketsClient, error)
  • func (c *ValidatorBlockEngineClient) HandleBundleSubscription(ctx context.Context, ch chan []*proto.BundleUuid) (proto.BlockEngineValidator_SubscribeBundlesClient, error)
  • func (c *ValidatorBlockEngineClient) HandlePacketSubscription(ctx context.Context, ch chan *proto.PacketBatch) (proto.BlockEngineValidator_SubscribePacketsClient, error)

Types

type RelayerBlockEngineClient

type RelayerBlockEngineClient struct {
	GrpcConn  *grpc.ClientConn
	GrpcErrCh chan error
	RpcConn   *rpc.Client
	ErrCh     chan error

	BlockEngineRelayerClient proto.BlockEngineRelayerClient

	Auth *pkg.AuthenticationService
}

func NewRelayerBlockEngineClient

func NewRelayerBlockEngineClient(grpcDialURL string, rpcClient *rpc.Client, privateKey solana.PrivateKey, tlsConfig *tls.Config, opts ...grpc.DialOption) (*RelayerBlockEngineClient, error)

func (*RelayerBlockEngineClient) BlockEngineRelayerClientStartExpiringPacketStream

func (c *RelayerBlockEngineClient) BlockEngineRelayerClientStartExpiringPacketStream(opts ...grpc.CallOption) (proto.BlockEngineRelayer_StartExpiringPacketStreamClient, error)

func (*RelayerBlockEngineClient) BlockEngineRelayerClientSubscribeAccountsOfInterest

func (c *RelayerBlockEngineClient) BlockEngineRelayerClientSubscribeAccountsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeAccountsOfInterestClient, error)

func (*RelayerBlockEngineClient) BlockEngineRelayerClientSubscribeProgramsOfInterest

func (c *RelayerBlockEngineClient) BlockEngineRelayerClientSubscribeProgramsOfInterest(opts ...grpc.CallOption) (proto.BlockEngineRelayer_SubscribeProgramsOfInterestClient, error)

type ValidatorBlockEngineClient

type ValidatorBlockEngineClient struct {
	GrpcConn  *grpc.ClientConn
	GrpcErrCh chan error
	RpcConn   *rpc.Client
	ErrCh     chan error

	BlockEngineValidatorClient proto.BlockEngineValidatorClient

	Auth *pkg.AuthenticationService
}

func NewValidatorBlockEngineClient

func NewValidatorBlockEngineClient(grpcDialURL string, rpcClient *rpc.Client, privateKey solana.PrivateKey, tlsConfig *tls.Config, opts ...grpc.DialOption) (*ValidatorBlockEngineClient, error)

func (*ValidatorBlockEngineClient) BlockEngineValidatorClientGetBlockBuilderFeeInfo

func (c *ValidatorBlockEngineClient) BlockEngineValidatorClientGetBlockBuilderFeeInfo(opts ...grpc.CallOption) (*proto.BlockBuilderFeeInfoResponse, error)

func (*ValidatorBlockEngineClient) BlockEngineValidatorClientSubscribeBundles

func (c *ValidatorBlockEngineClient) BlockEngineValidatorClientSubscribeBundles() (proto.BlockEngineValidator_SubscribeBundlesClient, error)

func (*ValidatorBlockEngineClient) BlockEngineValidatorClientSubscribePackets

func (c *ValidatorBlockEngineClient) BlockEngineValidatorClientSubscribePackets() (proto.BlockEngineValidator_SubscribePacketsClient, error)

func (*ValidatorBlockEngineClient) HandleBundleSubscription

func (c *ValidatorBlockEngineClient) HandleBundleSubscription(ctx context.Context, ch chan []*proto.BundleUuid) (proto.BlockEngineValidator_SubscribeBundlesClient, error)

func (*ValidatorBlockEngineClient) HandlePacketSubscription

func (c *ValidatorBlockEngineClient) HandlePacketSubscription(ctx context.Context, ch chan *proto.PacketBatch) (proto.BlockEngineValidator_SubscribePacketsClient, error)