Versions in this module Expand all Collapse all v1 v1.0.1 Jan 26, 2025 Changes in this version type SearcherClient + func NewSearcherClientNoAuth(ctx context.Context, grpcAddr string, jitoRPCClient, rpcClient *rpc.Client, ...) (*SearcherClient, error) v1.0.0 Nov 28, 2024 Changes in this version + const CheckBundleRetries + const CheckBundleRetryDelay + const SignaturesConfirmationRetryDelay + const SignaturesConfirmationTimeout + func NewDroppedBundle(message string) error + func NewInternalError(message string) error + func NewSimulationFailureError(tx string, message string) error + func NewStateAuctionBidRejectedError(auction string, tip uint64) error + func NewWinningBatchBidRejectedError(auction string, tip uint64) error + type BundleRejectionError struct + Message string + func (e BundleRejectionError) Error() string + type BundleResponse struct + BundleResponse *searcher_pb.SendBundleResponse + Signatures []solana.Signature + type Relayer struct + AuthenticationService *pkg.AuthenticationService + Client block_engine_pb.BlockEngineRelayerClient + ErrChan <-chan error + GRPCConn *grpc.ClientConn + func NewRelayer(ctx context.Context, grpcAddr string, keyPair *solana.PrivateKey, ...) (*Relayer, error) + func (r *Relayer) OnStartExpiringPacketStream(ctx context.Context) (<-chan *block_engine_pb.StartExpiringPacketStreamResponse, <-chan error, error) + func (r *Relayer) OnSubscribeAccountsOfInterest(ctx context.Context) (<-chan *block_engine_pb.AccountsOfInterestUpdate, <-chan error, error) + func (r *Relayer) OnSubscribeProgramsOfInterest(ctx context.Context) (<-chan *block_engine_pb.ProgramsOfInterestUpdate, <-chan error, error) + func (r *Relayer) StartExpiringPacketStream(opts ...grpc.CallOption) (block_engine_pb.BlockEngineRelayer_StartExpiringPacketStreamClient, error) + func (r *Relayer) SubscribeAccountsOfInterest(opts ...grpc.CallOption) (block_engine_pb.BlockEngineRelayer_SubscribeAccountsOfInterestClient, error) + func (r *Relayer) SubscribeProgramsOfInterest(opts ...grpc.CallOption) (block_engine_pb.BlockEngineRelayer_SubscribeProgramsOfInterestClient, error) + type SearcherClient struct + AuthenticationService *pkg.AuthenticationService + BundleStreamSubscription searcher_pb.SearcherService_SubscribeBundleResultsClient + ErrChan <-chan error + GRPCConn *grpc.ClientConn + JitoRPCConn *rpc.Client + RPCConn *rpc.Client + SearcherService searcher_pb.SearcherServiceClient + func NewSearcherClient(ctx context.Context, grpcAddr string, jitoRPCClient, rpcClient *rpc.Client, ...) (*SearcherClient, error) + func (c *SearcherClient) GetConnectedLeaders(opts ...grpc.CallOption) (*searcher_pb.ConnectedLeadersResponse, error) + func (c *SearcherClient) GetConnectedLeadersRegioned(regions []string, opts ...grpc.CallOption) (*searcher_pb.ConnectedLeadersRegionedResponse, error) + func (c *SearcherClient) GetNextScheduledLeader(regions []string, opts ...grpc.CallOption) (*searcher_pb.NextScheduledLeaderResponse, error) + func (c *SearcherClient) GetRandomTipAccount(opts ...grpc.CallOption) (string, error) + func (c *SearcherClient) GetRegions(opts ...grpc.CallOption) (*searcher_pb.GetRegionsResponse, error) + func (c *SearcherClient) GetTipAccounts(opts ...grpc.CallOption) (*searcher_pb.GetTipAccountsResponse, error) + func (c *SearcherClient) NewBundle(transactions []*solana.Transaction) (*bundle_pb.Bundle, error) + func (c *SearcherClient) NewBundleSubscriptionResults(opts ...grpc.CallOption) (searcher_pb.SearcherService_SubscribeBundleResultsClient, error) + func (c *SearcherClient) SendBundle(transactions []*solana.Transaction, opts ...grpc.CallOption) (*searcher_pb.SendBundleResponse, error) + func (c *SearcherClient) SendBundleWithConfirmation(ctx context.Context, transactions []*solana.Transaction, ...) (*BundleResponse, error) + type Validator struct + AuthenticationService *pkg.AuthenticationService + Client block_engine_pb.BlockEngineValidatorClient + ErrChan <-chan error + GRPCConn *grpc.ClientConn + func NewValidator(ctx context.Context, grpcAddr string, keyPair *solana.PrivateKey, ...) (*Validator, error) + func (v *Validator) GetBlockBuilderFeeInfo(opts ...grpc.CallOption) (*block_engine_pb.BlockBuilderFeeInfoResponse, error) + func (v *Validator) OnBundleSubscription(ctx context.Context) (<-chan []*bundle_pb.BundleUuid, <-chan error, error) + func (v *Validator) OnPacketSubscription(ctx context.Context) (<-chan *block_engine_pb.SubscribePacketsResponse, <-chan error, error) + func (v *Validator) SubscribeBundles(opts ...grpc.CallOption) (block_engine_pb.BlockEngineValidator_SubscribeBundlesClient, error) + func (v *Validator) SubscribePackets(opts ...grpc.CallOption) (block_engine_pb.BlockEngineValidator_SubscribePacketsClient, error)
Go to main page