searcher

package
v1.9.2 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_searcher_proto protoreflect.FileDescriptor
View Source 
var SearcherService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "searcher.SearcherService",
	HandlerType: (*SearcherServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendBundle",
			Handler:    _SearcherService_SendBundle_Handler,
		},
		{
			MethodName: "GetNextScheduledLeader",
			Handler:    _SearcherService_GetNextScheduledLeader_Handler,
		},
		{
			MethodName: "GetConnectedLeaders",
			Handler:    _SearcherService_GetConnectedLeaders_Handler,
		},
		{
			MethodName: "GetConnectedLeadersRegioned",
			Handler:    _SearcherService_GetConnectedLeadersRegioned_Handler,
		},
		{
			MethodName: "GetTipAccounts",
			Handler:    _SearcherService_GetTipAccounts_Handler,
		},
		{
			MethodName: "GetRegions",
			Handler:    _SearcherService_GetRegions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeBundleResults",
			Handler:       _SearcherService_SubscribeBundleResults_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMempool",
			Handler:       _SearcherService_SubscribeMempool_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "searcher.proto",
}

SearcherService_ServiceDesc is the grpc.ServiceDesc for SearcherService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSearcherServiceServer 

func RegisterSearcherServiceServer(s grpc.ServiceRegistrar, srv SearcherServiceServer)

Types

type ConnectedLeadersRegionedRequest 

type ConnectedLeadersRegionedRequest struct {

	// Defaults to the currently connected region if no region provided.
	Regions []string `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectedLeadersRegionedRequest) Descriptor deprecated 

func (*ConnectedLeadersRegionedRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConnectedLeadersRegionedRequest.ProtoReflect.Descriptor instead.

func (*ConnectedLeadersRegionedRequest) GetRegions 

func (x *ConnectedLeadersRegionedRequest) GetRegions() []string

func (*ConnectedLeadersRegionedRequest) ProtoMessage 

func (*ConnectedLeadersRegionedRequest) ProtoMessage()

func (*ConnectedLeadersRegionedRequest) ProtoReflect 

func (x *ConnectedLeadersRegionedRequest) ProtoReflect() protoreflect.Message

func (*ConnectedLeadersRegionedRequest) Reset 

func (x *ConnectedLeadersRegionedRequest) Reset()

func (*ConnectedLeadersRegionedRequest) String 

func (x *ConnectedLeadersRegionedRequest) String() string

type ConnectedLeadersRegionedResponse 

type ConnectedLeadersRegionedResponse struct {
	ConnectedValidators map[string]*ConnectedLeadersResponse `` /* 206-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectedLeadersRegionedResponse) Descriptor deprecated 

func (*ConnectedLeadersRegionedResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConnectedLeadersRegionedResponse.ProtoReflect.Descriptor instead.

func (*ConnectedLeadersRegionedResponse) GetConnectedValidators 

func (x *ConnectedLeadersRegionedResponse) GetConnectedValidators() map[string]*ConnectedLeadersResponse

func (*ConnectedLeadersRegionedResponse) ProtoMessage 

func (*ConnectedLeadersRegionedResponse) ProtoMessage()

func (*ConnectedLeadersRegionedResponse) ProtoReflect 

func (x *ConnectedLeadersRegionedResponse) ProtoReflect() protoreflect.Message

func (*ConnectedLeadersRegionedResponse) Reset 

func (x *ConnectedLeadersRegionedResponse) Reset()

func (*ConnectedLeadersRegionedResponse) String 

func (x *ConnectedLeadersRegionedResponse) String() string

type ConnectedLeadersRequest 

type ConnectedLeadersRequest struct {
	// contains filtered or unexported fields
}

func (*ConnectedLeadersRequest) Descriptor deprecated 

func (*ConnectedLeadersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConnectedLeadersRequest.ProtoReflect.Descriptor instead.

func (*ConnectedLeadersRequest) ProtoMessage 

func (*ConnectedLeadersRequest) ProtoMessage()

func (*ConnectedLeadersRequest) ProtoReflect 

func (x *ConnectedLeadersRequest) ProtoReflect() protoreflect.Message

func (*ConnectedLeadersRequest) Reset 

func (x *ConnectedLeadersRequest) Reset()

func (*ConnectedLeadersRequest) String 

func (x *ConnectedLeadersRequest) String() string

type ConnectedLeadersResponse 

type ConnectedLeadersResponse struct {

	// Mapping of validator pubkey to leader slots for the current epoch.
	ConnectedValidators map[string]*SlotList `` /* 206-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectedLeadersResponse) Descriptor deprecated 

func (*ConnectedLeadersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConnectedLeadersResponse.ProtoReflect.Descriptor instead.

func (*ConnectedLeadersResponse) GetConnectedValidators 

func (x *ConnectedLeadersResponse) GetConnectedValidators() map[string]*SlotList

func (*ConnectedLeadersResponse) ProtoMessage 

func (*ConnectedLeadersResponse) ProtoMessage()

func (*ConnectedLeadersResponse) ProtoReflect 

func (x *ConnectedLeadersResponse) ProtoReflect() protoreflect.Message

func (*ConnectedLeadersResponse) Reset 

func (x *ConnectedLeadersResponse) Reset()

func (*ConnectedLeadersResponse) String 

func (x *ConnectedLeadersResponse) String() string

type GetRegionsRequest 

type GetRegionsRequest struct {
	// contains filtered or unexported fields
}

func (*GetRegionsRequest) Descriptor deprecated 

func (*GetRegionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRegionsRequest.ProtoReflect.Descriptor instead.

func (*GetRegionsRequest) ProtoMessage 

func (*GetRegionsRequest) ProtoMessage()

func (*GetRegionsRequest) ProtoReflect 

func (x *GetRegionsRequest) ProtoReflect() protoreflect.Message

func (*GetRegionsRequest) Reset 

func (x *GetRegionsRequest) Reset()

func (*GetRegionsRequest) String 

func (x *GetRegionsRequest) String() string

type GetRegionsResponse 

type GetRegionsResponse struct {

	// The region the client is currently connected to
	CurrentRegion string `protobuf:"bytes,1,opt,name=current_region,json=currentRegion,proto3" json:"current_region,omitempty"`
	// Regions that are online and ready for connections
	// All regions: https://jito-labs.gitbook.io/mev/systems/connecting/mainnet
	AvailableRegions []string `protobuf:"bytes,2,rep,name=available_regions,json=availableRegions,proto3" json:"available_regions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegionsResponse) Descriptor deprecated 

func (*GetRegionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRegionsResponse.ProtoReflect.Descriptor instead.

func (*GetRegionsResponse) GetAvailableRegions 

func (x *GetRegionsResponse) GetAvailableRegions() []string

func (*GetRegionsResponse) GetCurrentRegion 

func (x *GetRegionsResponse) GetCurrentRegion() string

func (*GetRegionsResponse) ProtoMessage 

func (*GetRegionsResponse) ProtoMessage()

func (*GetRegionsResponse) ProtoReflect 

func (x *GetRegionsResponse) ProtoReflect() protoreflect.Message

func (*GetRegionsResponse) Reset 

func (x *GetRegionsResponse) Reset()

func (*GetRegionsResponse) String 

func (x *GetRegionsResponse) String() string

type GetTipAccountsRequest 

type GetTipAccountsRequest struct {
	// contains filtered or unexported fields
}

func (*GetTipAccountsRequest) Descriptor deprecated 

func (*GetTipAccountsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTipAccountsRequest.ProtoReflect.Descriptor instead.

func (*GetTipAccountsRequest) ProtoMessage 

func (*GetTipAccountsRequest) ProtoMessage()

func (*GetTipAccountsRequest) ProtoReflect 

func (x *GetTipAccountsRequest) ProtoReflect() protoreflect.Message

func (*GetTipAccountsRequest) Reset 

func (x *GetTipAccountsRequest) Reset()

func (*GetTipAccountsRequest) String 

func (x *GetTipAccountsRequest) String() string

type GetTipAccountsResponse 

type GetTipAccountsResponse struct {
	Accounts []string `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTipAccountsResponse) Descriptor deprecated 

func (*GetTipAccountsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetTipAccountsResponse.ProtoReflect.Descriptor instead.

func (*GetTipAccountsResponse) GetAccounts 

func (x *GetTipAccountsResponse) GetAccounts() []string

func (*GetTipAccountsResponse) ProtoMessage 

func (*GetTipAccountsResponse) ProtoMessage()

func (*GetTipAccountsResponse) ProtoReflect 

func (x *GetTipAccountsResponse) ProtoReflect() protoreflect.Message

func (*GetTipAccountsResponse) Reset 

func (x *GetTipAccountsResponse) Reset()

func (*GetTipAccountsResponse) String 

func (x *GetTipAccountsResponse) String() string

type MempoolSubscription 

type MempoolSubscription struct {

	// Filter by program id or account pubkey
	//
	// Types that are assignable to Msg:
	//	*MempoolSubscription_ProgramV0Sub
	//	*MempoolSubscription_WlaV0Sub
	Msg isMempoolSubscription_Msg `protobuf_oneof:"msg"`
	// Filters transactions to originate from specified regions.
	// Defaults to the currently connected region.
	Regions []string `protobuf:"bytes,10,rep,name=regions,proto3" json:"regions,omitempty"`
	// contains filtered or unexported fields
}

func (*MempoolSubscription) Descriptor deprecated 

func (*MempoolSubscription) Descriptor() ([]byte, []int)

Deprecated: Use MempoolSubscription.ProtoReflect.Descriptor instead.

func (*MempoolSubscription) GetMsg 

func (m *MempoolSubscription) GetMsg() isMempoolSubscription_Msg

func (*MempoolSubscription) GetProgramV0Sub 

func (x *MempoolSubscription) GetProgramV0Sub() *ProgramSubscriptionV0

func (*MempoolSubscription) GetRegions 

func (x *MempoolSubscription) GetRegions() []string

func (*MempoolSubscription) GetWlaV0Sub 

func (x *MempoolSubscription) GetWlaV0Sub() *WriteLockedAccountSubscriptionV0

func (*MempoolSubscription) ProtoMessage 

func (*MempoolSubscription) ProtoMessage()

func (*MempoolSubscription) ProtoReflect 

func (x *MempoolSubscription) ProtoReflect() protoreflect.Message

func (*MempoolSubscription) Reset 

func (x *MempoolSubscription) Reset()

func (*MempoolSubscription) String 

func (x *MempoolSubscription) String() string

type MempoolSubscription_ProgramV0Sub 

type MempoolSubscription_ProgramV0Sub struct {
	ProgramV0Sub *ProgramSubscriptionV0 `protobuf:"bytes,1,opt,name=program_v0_sub,json=programV0Sub,proto3,oneof"`
}

type MempoolSubscription_WlaV0Sub 

type MempoolSubscription_WlaV0Sub struct {
	WlaV0Sub *WriteLockedAccountSubscriptionV0 `protobuf:"bytes,2,opt,name=wla_v0_sub,json=wlaV0Sub,proto3,oneof"` /// field numbers upto (and incl) 9 are reserved
}

type NextScheduledLeaderRequest 

type NextScheduledLeaderRequest struct {
	// contains filtered or unexported fields
}

func (*NextScheduledLeaderRequest) Descriptor deprecated 

func (*NextScheduledLeaderRequest) Descriptor() ([]byte, []int)

Deprecated: Use NextScheduledLeaderRequest.ProtoReflect.Descriptor instead.

func (*NextScheduledLeaderRequest) ProtoMessage 

func (*NextScheduledLeaderRequest) ProtoMessage()

func (*NextScheduledLeaderRequest) ProtoReflect 

func (x *NextScheduledLeaderRequest) ProtoReflect() protoreflect.Message

func (*NextScheduledLeaderRequest) Reset 

func (x *NextScheduledLeaderRequest) Reset()

func (*NextScheduledLeaderRequest) String 

func (x *NextScheduledLeaderRequest) String() string

type NextScheduledLeaderResponse 

type NextScheduledLeaderResponse struct {

	// the current slot the backend is on
	CurrentSlot uint64 `protobuf:"varint,1,opt,name=current_slot,json=currentSlot,proto3" json:"current_slot,omitempty"`
	// the slot and identity of the next leader
	NextLeaderSlot     uint64 `protobuf:"varint,2,opt,name=next_leader_slot,json=nextLeaderSlot,proto3" json:"next_leader_slot,omitempty"`
	NextLeaderIdentity string `protobuf:"bytes,3,opt,name=next_leader_identity,json=nextLeaderIdentity,proto3" json:"next_leader_identity,omitempty"`
	// contains filtered or unexported fields
}

func (*NextScheduledLeaderResponse) Descriptor deprecated 

func (*NextScheduledLeaderResponse) Descriptor() ([]byte, []int)

Deprecated: Use NextScheduledLeaderResponse.ProtoReflect.Descriptor instead.

func (*NextScheduledLeaderResponse) GetCurrentSlot 

func (x *NextScheduledLeaderResponse) GetCurrentSlot() uint64

func (*NextScheduledLeaderResponse) GetNextLeaderIdentity 

func (x *NextScheduledLeaderResponse) GetNextLeaderIdentity() string

func (*NextScheduledLeaderResponse) GetNextLeaderSlot 

func (x *NextScheduledLeaderResponse) GetNextLeaderSlot() uint64

func (*NextScheduledLeaderResponse) ProtoMessage 

func (*NextScheduledLeaderResponse) ProtoMessage()

func (*NextScheduledLeaderResponse) ProtoReflect 

func (x *NextScheduledLeaderResponse) ProtoReflect() protoreflect.Message

func (*NextScheduledLeaderResponse) Reset 

func (x *NextScheduledLeaderResponse) Reset()

func (*NextScheduledLeaderResponse) String 

func (x *NextScheduledLeaderResponse) String() string

type PendingTxNotification 

type PendingTxNotification struct {

	// server-side timestamp the transactions were generated at (for debugging/profiling purposes)
	ServerSideTs *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=server_side_ts,json=serverSideTs,proto3" json:"server_side_ts,omitempty"`
	// expiration time of the packet
	ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	// list of pending transactions
	Transactions []*packet.Packet `protobuf:"bytes,3,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingTxNotification) Descriptor deprecated 

func (*PendingTxNotification) Descriptor() ([]byte, []int)

Deprecated: Use PendingTxNotification.ProtoReflect.Descriptor instead.

func (*PendingTxNotification) GetExpirationTime 

func (x *PendingTxNotification) GetExpirationTime() *timestamppb.Timestamp

func (*PendingTxNotification) GetServerSideTs 

func (x *PendingTxNotification) GetServerSideTs() *timestamppb.Timestamp

func (*PendingTxNotification) GetTransactions 

func (x *PendingTxNotification) GetTransactions() []*packet.Packet

func (*PendingTxNotification) ProtoMessage 

func (*PendingTxNotification) ProtoMessage()

func (*PendingTxNotification) ProtoReflect 

func (x *PendingTxNotification) ProtoReflect() protoreflect.Message

func (*PendingTxNotification) Reset 

func (x *PendingTxNotification) Reset()

func (*PendingTxNotification) String 

func (x *PendingTxNotification) String() string

type ProgramSubscriptionV0 

type ProgramSubscriptionV0 struct {

	// Base58 encoded program id that transactions mention
	Programs []string `protobuf:"bytes,1,rep,name=programs,proto3" json:"programs,omitempty"`
	// contains filtered or unexported fields
}

func (*ProgramSubscriptionV0) Descriptor deprecated 

func (*ProgramSubscriptionV0) Descriptor() ([]byte, []int)

Deprecated: Use ProgramSubscriptionV0.ProtoReflect.Descriptor instead.

func (*ProgramSubscriptionV0) GetPrograms 

func (x *ProgramSubscriptionV0) GetPrograms() []string

func (*ProgramSubscriptionV0) ProtoMessage 

func (*ProgramSubscriptionV0) ProtoMessage()

func (*ProgramSubscriptionV0) ProtoReflect 

func (x *ProgramSubscriptionV0) ProtoReflect() protoreflect.Message

func (*ProgramSubscriptionV0) Reset 

func (x *ProgramSubscriptionV0) Reset()

func (*ProgramSubscriptionV0) String 

func (x *ProgramSubscriptionV0) String() string

type SearcherServiceClient 

type SearcherServiceClient interface {
	// Searchers can invoke this endpoint to subscribe to their respective bundle results.
	// A success result would indicate the bundle won its state auction and was submitted to the validator.
	SubscribeBundleResults(ctx context.Context, in *SubscribeBundleResultsRequest, opts ...grpc.CallOption) (SearcherService_SubscribeBundleResultsClient, error)
	// Subscribe to mempool transactions based on a few filters
	SubscribeMempool(ctx context.Context, in *MempoolSubscription, opts ...grpc.CallOption) (SearcherService_SubscribeMempoolClient, error)
	SendBundle(ctx context.Context, in *SendBundleRequest, opts ...grpc.CallOption) (*SendBundleResponse, error)
	// Returns the next scheduled leader connected to the block engine.
	GetNextScheduledLeader(ctx context.Context, in *NextScheduledLeaderRequest, opts ...grpc.CallOption) (*NextScheduledLeaderResponse, error)
	// Returns leader slots for connected jito validators during the current epoch. Only returns data for this region.
	GetConnectedLeaders(ctx context.Context, in *ConnectedLeadersRequest, opts ...grpc.CallOption) (*ConnectedLeadersResponse, error)
	// Returns leader slots for connected jito validators during the current epoch.
	GetConnectedLeadersRegioned(ctx context.Context, in *ConnectedLeadersRegionedRequest, opts ...grpc.CallOption) (*ConnectedLeadersRegionedResponse, error)
	// Returns the tip accounts searchers shall transfer funds to for the leader to claim.
	GetTipAccounts(ctx context.Context, in *GetTipAccountsRequest, opts ...grpc.CallOption) (*GetTipAccountsResponse, error)
	// Returns region the client is directly connected to, along with all available regions
	GetRegions(ctx context.Context, in *GetRegionsRequest, opts ...grpc.CallOption) (*GetRegionsResponse, error)
}

SearcherServiceClient is the client API for SearcherService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSearcherServiceClient 

func NewSearcherServiceClient(cc grpc.ClientConnInterface) SearcherServiceClient

type SearcherServiceServer 

type SearcherServiceServer interface {
	// Searchers can invoke this endpoint to subscribe to their respective bundle results.
	// A success result would indicate the bundle won its state auction and was submitted to the validator.
	SubscribeBundleResults(*SubscribeBundleResultsRequest, SearcherService_SubscribeBundleResultsServer) error
	// Subscribe to mempool transactions based on a few filters
	SubscribeMempool(*MempoolSubscription, SearcherService_SubscribeMempoolServer) error
	SendBundle(context.Context, *SendBundleRequest) (*SendBundleResponse, error)
	// Returns the next scheduled leader connected to the block engine.
	GetNextScheduledLeader(context.Context, *NextScheduledLeaderRequest) (*NextScheduledLeaderResponse, error)
	// Returns leader slots for connected jito validators during the current epoch. Only returns data for this region.
	GetConnectedLeaders(context.Context, *ConnectedLeadersRequest) (*ConnectedLeadersResponse, error)
	// Returns leader slots for connected jito validators during the current epoch.
	GetConnectedLeadersRegioned(context.Context, *ConnectedLeadersRegionedRequest) (*ConnectedLeadersRegionedResponse, error)
	// Returns the tip accounts searchers shall transfer funds to for the leader to claim.
	GetTipAccounts(context.Context, *GetTipAccountsRequest) (*GetTipAccountsResponse, error)
	// Returns region the client is directly connected to, along with all available regions
	GetRegions(context.Context, *GetRegionsRequest) (*GetRegionsResponse, error)
	// contains filtered or unexported methods
}

SearcherServiceServer is the server API for SearcherService service. All implementations must embed UnimplementedSearcherServiceServer for forward compatibility

type SearcherService_SubscribeBundleResultsClient 

type SearcherService_SubscribeBundleResultsClient interface {
	Recv() (*bundle.BundleResult, error)
	grpc.ClientStream
}

type SearcherService_SubscribeBundleResultsServer 

type SearcherService_SubscribeBundleResultsServer interface {
	Send(*bundle.BundleResult) error
	grpc.ServerStream
}

type SearcherService_SubscribeMempoolClient 

type SearcherService_SubscribeMempoolClient interface {
	Recv() (*PendingTxNotification, error)
	grpc.ClientStream
}

type SearcherService_SubscribeMempoolServer 

type SearcherService_SubscribeMempoolServer interface {
	Send(*PendingTxNotification) error
	grpc.ServerStream
}

type SendBundleRequest 

type SendBundleRequest struct {
	Bundle *bundle.Bundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	// contains filtered or unexported fields
}

func (*SendBundleRequest) Descriptor deprecated 

func (*SendBundleRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendBundleRequest.ProtoReflect.Descriptor instead.

func (*SendBundleRequest) GetBundle 

func (x *SendBundleRequest) GetBundle() *bundle.Bundle

func (*SendBundleRequest) ProtoMessage 

func (*SendBundleRequest) ProtoMessage()

func (*SendBundleRequest) ProtoReflect 

func (x *SendBundleRequest) ProtoReflect() protoreflect.Message

func (*SendBundleRequest) Reset 

func (x *SendBundleRequest) Reset()

func (*SendBundleRequest) String 

func (x *SendBundleRequest) String() string

type SendBundleResponse 

type SendBundleResponse struct {

	// server uuid for the bundle
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*SendBundleResponse) Descriptor deprecated 

func (*SendBundleResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendBundleResponse.ProtoReflect.Descriptor instead.

func (*SendBundleResponse) GetUuid 

func (x *SendBundleResponse) GetUuid() string

func (*SendBundleResponse) ProtoMessage 

func (*SendBundleResponse) ProtoMessage()

func (*SendBundleResponse) ProtoReflect 

func (x *SendBundleResponse) ProtoReflect() protoreflect.Message

func (*SendBundleResponse) Reset 

func (x *SendBundleResponse) Reset()

func (*SendBundleResponse) String 

func (x *SendBundleResponse) String() string

type SlotList 

type SlotList struct {
	Slots []uint64 `protobuf:"varint,1,rep,packed,name=slots,proto3" json:"slots,omitempty"`
	// contains filtered or unexported fields
}

func (*SlotList) Descriptor deprecated 

func (*SlotList) Descriptor() ([]byte, []int)

Deprecated: Use SlotList.ProtoReflect.Descriptor instead.

func (*SlotList) GetSlots 

func (x *SlotList) GetSlots() []uint64

func (*SlotList) ProtoMessage 

func (*SlotList) ProtoMessage()

func (*SlotList) ProtoReflect 

func (x *SlotList) ProtoReflect() protoreflect.Message

func (*SlotList) Reset 

func (x *SlotList) Reset()

func (*SlotList) String 

func (x *SlotList) String() string

type SubscribeBundleResultsRequest 

type SubscribeBundleResultsRequest struct {
	// contains filtered or unexported fields
}

func (*SubscribeBundleResultsRequest) Descriptor deprecated 

func (*SubscribeBundleResultsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubscribeBundleResultsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeBundleResultsRequest) ProtoMessage 

func (*SubscribeBundleResultsRequest) ProtoMessage()

func (*SubscribeBundleResultsRequest) ProtoReflect 

func (x *SubscribeBundleResultsRequest) ProtoReflect() protoreflect.Message

func (*SubscribeBundleResultsRequest) Reset 

func (x *SubscribeBundleResultsRequest) Reset()

func (*SubscribeBundleResultsRequest) String 

func (x *SubscribeBundleResultsRequest) String() string

type UnimplementedSearcherServiceServer 

type UnimplementedSearcherServiceServer struct {
}

UnimplementedSearcherServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSearcherServiceServer) GetConnectedLeaders 

func (UnimplementedSearcherServiceServer) GetConnectedLeaders(context.Context, *ConnectedLeadersRequest) (*ConnectedLeadersResponse, error)

func (UnimplementedSearcherServiceServer) GetConnectedLeadersRegioned 

func (UnimplementedSearcherServiceServer) GetConnectedLeadersRegioned(context.Context, *ConnectedLeadersRegionedRequest) (*ConnectedLeadersRegionedResponse, error)

func (UnimplementedSearcherServiceServer) GetNextScheduledLeader 

func (UnimplementedSearcherServiceServer) GetNextScheduledLeader(context.Context, *NextScheduledLeaderRequest) (*NextScheduledLeaderResponse, error)

func (UnimplementedSearcherServiceServer) GetRegions 

func (UnimplementedSearcherServiceServer) GetRegions(context.Context, *GetRegionsRequest) (*GetRegionsResponse, error)

func (UnimplementedSearcherServiceServer) GetTipAccounts 

func (UnimplementedSearcherServiceServer) GetTipAccounts(context.Context, *GetTipAccountsRequest) (*GetTipAccountsResponse, error)

func (UnimplementedSearcherServiceServer) SendBundle 

func (UnimplementedSearcherServiceServer) SendBundle(context.Context, *SendBundleRequest) (*SendBundleResponse, error)

func (UnimplementedSearcherServiceServer) SubscribeBundleResults 

func (UnimplementedSearcherServiceServer) SubscribeBundleResults(*SubscribeBundleResultsRequest, SearcherService_SubscribeBundleResultsServer) error

func (UnimplementedSearcherServiceServer) SubscribeMempool 

func (UnimplementedSearcherServiceServer) SubscribeMempool(*MempoolSubscription, SearcherService_SubscribeMempoolServer) error

type UnsafeSearcherServiceServer 

type UnsafeSearcherServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSearcherServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SearcherServiceServer will result in compilation errors.

type WriteLockedAccountSubscriptionV0 

type WriteLockedAccountSubscriptionV0 struct {

	// Base58 encoded account pubkey that transactions mention
	Accounts []string `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteLockedAccountSubscriptionV0) Descriptor deprecated 

func (*WriteLockedAccountSubscriptionV0) Descriptor() ([]byte, []int)

Deprecated: Use WriteLockedAccountSubscriptionV0.ProtoReflect.Descriptor instead.

func (*WriteLockedAccountSubscriptionV0) GetAccounts 

func (x *WriteLockedAccountSubscriptionV0) GetAccounts() []string

func (*WriteLockedAccountSubscriptionV0) ProtoMessage 

func (*WriteLockedAccountSubscriptionV0) ProtoMessage()

func (*WriteLockedAccountSubscriptionV0) ProtoReflect 

func (x *WriteLockedAccountSubscriptionV0) ProtoReflect() protoreflect.Message

func (*WriteLockedAccountSubscriptionV0) Reset 

func (x *WriteLockedAccountSubscriptionV0) Reset()

func (*WriteLockedAccountSubscriptionV0) String 

func (x *WriteLockedAccountSubscriptionV0) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.