Versions in this module Expand all Collapse all v1 v1.9.2 Sep 26, 2024 v1.9.1 Jun 28, 2024 Changes in this version + var File_searcher_proto protoreflect.FileDescriptor + var SearcherService_ServiceDesc = grpc.ServiceDesc + func RegisterSearcherServiceServer(s grpc.ServiceRegistrar, srv SearcherServiceServer) + type ConnectedLeadersRegionedRequest struct + Regions []string + func (*ConnectedLeadersRegionedRequest) Descriptor() ([]byte, []int) + func (*ConnectedLeadersRegionedRequest) ProtoMessage() + func (x *ConnectedLeadersRegionedRequest) GetRegions() []string + func (x *ConnectedLeadersRegionedRequest) ProtoReflect() protoreflect.Message + func (x *ConnectedLeadersRegionedRequest) Reset() + func (x *ConnectedLeadersRegionedRequest) String() string + type ConnectedLeadersRegionedResponse struct + ConnectedValidators map[string]*ConnectedLeadersResponse + func (*ConnectedLeadersRegionedResponse) Descriptor() ([]byte, []int) + func (*ConnectedLeadersRegionedResponse) ProtoMessage() + func (x *ConnectedLeadersRegionedResponse) GetConnectedValidators() map[string]*ConnectedLeadersResponse + func (x *ConnectedLeadersRegionedResponse) ProtoReflect() protoreflect.Message + func (x *ConnectedLeadersRegionedResponse) Reset() + func (x *ConnectedLeadersRegionedResponse) String() string + type ConnectedLeadersRequest struct + func (*ConnectedLeadersRequest) Descriptor() ([]byte, []int) + func (*ConnectedLeadersRequest) ProtoMessage() + func (x *ConnectedLeadersRequest) ProtoReflect() protoreflect.Message + func (x *ConnectedLeadersRequest) Reset() + func (x *ConnectedLeadersRequest) String() string + type ConnectedLeadersResponse struct + ConnectedValidators map[string]*SlotList + func (*ConnectedLeadersResponse) Descriptor() ([]byte, []int) + func (*ConnectedLeadersResponse) ProtoMessage() + func (x *ConnectedLeadersResponse) GetConnectedValidators() map[string]*SlotList + func (x *ConnectedLeadersResponse) ProtoReflect() protoreflect.Message + func (x *ConnectedLeadersResponse) Reset() + func (x *ConnectedLeadersResponse) String() string + type GetRegionsRequest struct + func (*GetRegionsRequest) Descriptor() ([]byte, []int) + func (*GetRegionsRequest) ProtoMessage() + func (x *GetRegionsRequest) ProtoReflect() protoreflect.Message + func (x *GetRegionsRequest) Reset() + func (x *GetRegionsRequest) String() string + type GetRegionsResponse struct + AvailableRegions []string + CurrentRegion string + func (*GetRegionsResponse) Descriptor() ([]byte, []int) + func (*GetRegionsResponse) ProtoMessage() + func (x *GetRegionsResponse) GetAvailableRegions() []string + func (x *GetRegionsResponse) GetCurrentRegion() string + func (x *GetRegionsResponse) ProtoReflect() protoreflect.Message + func (x *GetRegionsResponse) Reset() + func (x *GetRegionsResponse) String() string + type GetTipAccountsRequest struct + func (*GetTipAccountsRequest) Descriptor() ([]byte, []int) + func (*GetTipAccountsRequest) ProtoMessage() + func (x *GetTipAccountsRequest) ProtoReflect() protoreflect.Message + func (x *GetTipAccountsRequest) Reset() + func (x *GetTipAccountsRequest) String() string + type GetTipAccountsResponse struct + Accounts []string + func (*GetTipAccountsResponse) Descriptor() ([]byte, []int) + func (*GetTipAccountsResponse) ProtoMessage() + func (x *GetTipAccountsResponse) GetAccounts() []string + func (x *GetTipAccountsResponse) ProtoReflect() protoreflect.Message + func (x *GetTipAccountsResponse) Reset() + func (x *GetTipAccountsResponse) String() string + type MempoolSubscription struct + Msg isMempoolSubscription_Msg + Regions []string + func (*MempoolSubscription) Descriptor() ([]byte, []int) + func (*MempoolSubscription) ProtoMessage() + func (m *MempoolSubscription) GetMsg() isMempoolSubscription_Msg + func (x *MempoolSubscription) GetProgramV0Sub() *ProgramSubscriptionV0 + func (x *MempoolSubscription) GetRegions() []string + func (x *MempoolSubscription) GetWlaV0Sub() *WriteLockedAccountSubscriptionV0 + func (x *MempoolSubscription) ProtoReflect() protoreflect.Message + func (x *MempoolSubscription) Reset() + func (x *MempoolSubscription) String() string + type MempoolSubscription_ProgramV0Sub struct + ProgramV0Sub *ProgramSubscriptionV0 + type MempoolSubscription_WlaV0Sub struct + WlaV0Sub *WriteLockedAccountSubscriptionV0 + type NextScheduledLeaderRequest struct + func (*NextScheduledLeaderRequest) Descriptor() ([]byte, []int) + func (*NextScheduledLeaderRequest) ProtoMessage() + func (x *NextScheduledLeaderRequest) ProtoReflect() protoreflect.Message + func (x *NextScheduledLeaderRequest) Reset() + func (x *NextScheduledLeaderRequest) String() string + type NextScheduledLeaderResponse struct + CurrentSlot uint64 + NextLeaderIdentity string + NextLeaderSlot uint64 + func (*NextScheduledLeaderResponse) Descriptor() ([]byte, []int) + func (*NextScheduledLeaderResponse) ProtoMessage() + func (x *NextScheduledLeaderResponse) GetCurrentSlot() uint64 + func (x *NextScheduledLeaderResponse) GetNextLeaderIdentity() string + func (x *NextScheduledLeaderResponse) GetNextLeaderSlot() uint64 + func (x *NextScheduledLeaderResponse) ProtoReflect() protoreflect.Message + func (x *NextScheduledLeaderResponse) Reset() + func (x *NextScheduledLeaderResponse) String() string + type PendingTxNotification struct + ExpirationTime *timestamppb.Timestamp + ServerSideTs *timestamppb.Timestamp + Transactions []*packet.Packet + func (*PendingTxNotification) Descriptor() ([]byte, []int) + func (*PendingTxNotification) ProtoMessage() + func (x *PendingTxNotification) GetExpirationTime() *timestamppb.Timestamp + func (x *PendingTxNotification) GetServerSideTs() *timestamppb.Timestamp + func (x *PendingTxNotification) GetTransactions() []*packet.Packet + func (x *PendingTxNotification) ProtoReflect() protoreflect.Message + func (x *PendingTxNotification) Reset() + func (x *PendingTxNotification) String() string + type ProgramSubscriptionV0 struct + Programs []string + func (*ProgramSubscriptionV0) Descriptor() ([]byte, []int) + func (*ProgramSubscriptionV0) ProtoMessage() + func (x *ProgramSubscriptionV0) GetPrograms() []string + func (x *ProgramSubscriptionV0) ProtoReflect() protoreflect.Message + func (x *ProgramSubscriptionV0) Reset() + func (x *ProgramSubscriptionV0) String() string + type SearcherServiceClient interface + GetConnectedLeaders func(ctx context.Context, in *ConnectedLeadersRequest, opts ...grpc.CallOption) (*ConnectedLeadersResponse, error) + GetConnectedLeadersRegioned func(ctx context.Context, in *ConnectedLeadersRegionedRequest, ...) (*ConnectedLeadersRegionedResponse, error) + GetNextScheduledLeader func(ctx context.Context, in *NextScheduledLeaderRequest, opts ...grpc.CallOption) (*NextScheduledLeaderResponse, error) + GetRegions func(ctx context.Context, in *GetRegionsRequest, opts ...grpc.CallOption) (*GetRegionsResponse, error) + GetTipAccounts func(ctx context.Context, in *GetTipAccountsRequest, opts ...grpc.CallOption) (*GetTipAccountsResponse, error) + SendBundle func(ctx context.Context, in *SendBundleRequest, opts ...grpc.CallOption) (*SendBundleResponse, error) + SubscribeBundleResults func(ctx context.Context, in *SubscribeBundleResultsRequest, ...) (SearcherService_SubscribeBundleResultsClient, error) + SubscribeMempool func(ctx context.Context, in *MempoolSubscription, opts ...grpc.CallOption) (SearcherService_SubscribeMempoolClient, error) + func NewSearcherServiceClient(cc grpc.ClientConnInterface) SearcherServiceClient + type SearcherServiceServer interface + GetConnectedLeaders func(context.Context, *ConnectedLeadersRequest) (*ConnectedLeadersResponse, error) + GetConnectedLeadersRegioned func(context.Context, *ConnectedLeadersRegionedRequest) (*ConnectedLeadersRegionedResponse, error) + GetNextScheduledLeader func(context.Context, *NextScheduledLeaderRequest) (*NextScheduledLeaderResponse, error) + GetRegions func(context.Context, *GetRegionsRequest) (*GetRegionsResponse, error) + GetTipAccounts func(context.Context, *GetTipAccountsRequest) (*GetTipAccountsResponse, error) + SendBundle func(context.Context, *SendBundleRequest) (*SendBundleResponse, error) + SubscribeBundleResults func(*SubscribeBundleResultsRequest, SearcherService_SubscribeBundleResultsServer) error + SubscribeMempool func(*MempoolSubscription, SearcherService_SubscribeMempoolServer) error + type SearcherService_SubscribeBundleResultsClient interface + Recv func() (*bundle.BundleResult, error) + type SearcherService_SubscribeBundleResultsServer interface + Send func(*bundle.BundleResult) error + type SearcherService_SubscribeMempoolClient interface + Recv func() (*PendingTxNotification, error) + type SearcherService_SubscribeMempoolServer interface + Send func(*PendingTxNotification) error + type SendBundleRequest struct + Bundle *bundle.Bundle + func (*SendBundleRequest) Descriptor() ([]byte, []int) + func (*SendBundleRequest) ProtoMessage() + func (x *SendBundleRequest) GetBundle() *bundle.Bundle + func (x *SendBundleRequest) ProtoReflect() protoreflect.Message + func (x *SendBundleRequest) Reset() + func (x *SendBundleRequest) String() string + type SendBundleResponse struct + Uuid string + func (*SendBundleResponse) Descriptor() ([]byte, []int) + func (*SendBundleResponse) ProtoMessage() + func (x *SendBundleResponse) GetUuid() string + func (x *SendBundleResponse) ProtoReflect() protoreflect.Message + func (x *SendBundleResponse) Reset() + func (x *SendBundleResponse) String() string + type SlotList struct + Slots []uint64 + func (*SlotList) Descriptor() ([]byte, []int) + func (*SlotList) ProtoMessage() + func (x *SlotList) GetSlots() []uint64 + func (x *SlotList) ProtoReflect() protoreflect.Message + func (x *SlotList) Reset() + func (x *SlotList) String() string + type SubscribeBundleResultsRequest struct + func (*SubscribeBundleResultsRequest) Descriptor() ([]byte, []int) + func (*SubscribeBundleResultsRequest) ProtoMessage() + func (x *SubscribeBundleResultsRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeBundleResultsRequest) Reset() + func (x *SubscribeBundleResultsRequest) String() string + type UnimplementedSearcherServiceServer struct + func (UnimplementedSearcherServiceServer) GetConnectedLeaders(context.Context, *ConnectedLeadersRequest) (*ConnectedLeadersResponse, error) + func (UnimplementedSearcherServiceServer) GetConnectedLeadersRegioned(context.Context, *ConnectedLeadersRegionedRequest) (*ConnectedLeadersRegionedResponse, error) + func (UnimplementedSearcherServiceServer) GetNextScheduledLeader(context.Context, *NextScheduledLeaderRequest) (*NextScheduledLeaderResponse, error) + func (UnimplementedSearcherServiceServer) GetRegions(context.Context, *GetRegionsRequest) (*GetRegionsResponse, error) + func (UnimplementedSearcherServiceServer) GetTipAccounts(context.Context, *GetTipAccountsRequest) (*GetTipAccountsResponse, error) + func (UnimplementedSearcherServiceServer) SendBundle(context.Context, *SendBundleRequest) (*SendBundleResponse, error) + func (UnimplementedSearcherServiceServer) SubscribeBundleResults(*SubscribeBundleResultsRequest, SearcherService_SubscribeBundleResultsServer) error + func (UnimplementedSearcherServiceServer) SubscribeMempool(*MempoolSubscription, SearcherService_SubscribeMempoolServer) error + type UnsafeSearcherServiceServer interface + type WriteLockedAccountSubscriptionV0 struct + Accounts []string + func (*WriteLockedAccountSubscriptionV0) Descriptor() ([]byte, []int) + func (*WriteLockedAccountSubscriptionV0) ProtoMessage() + func (x *WriteLockedAccountSubscriptionV0) GetAccounts() []string + func (x *WriteLockedAccountSubscriptionV0) ProtoReflect() protoreflect.Message + func (x *WriteLockedAccountSubscriptionV0) Reset() + func (x *WriteLockedAccountSubscriptionV0) String() string
Go to main page