searcher

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SearcherService_SubscribeBundleResults_FullMethodName      = "/searcher.SearcherService/SubscribeBundleResults"
	SearcherService_SendBundle_FullMethodName                  = "/searcher.SearcherService/SendBundle"
	SearcherService_GetNextScheduledLeader_FullMethodName      = "/searcher.SearcherService/GetNextScheduledLeader"
	SearcherService_GetConnectedLeaders_FullMethodName         = "/searcher.SearcherService/GetConnectedLeaders"
	SearcherService_GetConnectedLeadersRegioned_FullMethodName = "/searcher.SearcherService/GetConnectedLeadersRegioned"
	SearcherService_GetTipAccounts_FullMethodName              = "/searcher.SearcherService/GetTipAccounts"
	SearcherService_GetRegions_FullMethodName                  = "/searcher.SearcherService/GetRegions"
)

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,
		},
	},
	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 NextScheduledLeaderRequest 

type NextScheduledLeaderRequest 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 (*NextScheduledLeaderRequest) Descriptor deprecated 

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

Deprecated: Use NextScheduledLeaderRequest.ProtoReflect.Descriptor instead.

func (*NextScheduledLeaderRequest) GetRegions 

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

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 of the next leader
	NextLeaderSlot uint64 `protobuf:"varint,2,opt,name=next_leader_slot,json=nextLeaderSlot,proto3" json:"next_leader_slot,omitempty"`
	// the identity pubkey (base58) of the next leader
	NextLeaderIdentity string `protobuf:"bytes,3,opt,name=next_leader_identity,json=nextLeaderIdentity,proto3" json:"next_leader_identity,omitempty"`
	// the block engine region of the next leader
	NextLeaderRegion string `protobuf:"bytes,4,opt,name=next_leader_region,json=nextLeaderRegion,proto3" json:"next_leader_region,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) GetNextLeaderRegion 

func (x *NextScheduledLeaderResponse) GetNextLeaderRegion() 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 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) (grpc.ServerStreamingClient[bundle.BundleResult], 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, grpc.ServerStreamingServer[bundle.BundleResult]) 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 = grpc.ServerStreamingClient[bundle.BundleResult]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SearcherService_SubscribeBundleResultsServer 

type SearcherService_SubscribeBundleResultsServer = grpc.ServerStreamingServer[bundle.BundleResult]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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, grpc.ServerStreamingServer[bundle.BundleResult]) 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.

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.