proto

package
v0.0.0-...-78d1b80 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	AuthService_GenerateAuthChallenge_FullMethodName = "/auth.AuthService/GenerateAuthChallenge"
	AuthService_GenerateAuthTokens_FullMethodName    = "/auth.AuthService/GenerateAuthTokens"
	AuthService_RefreshAccessToken_FullMethodName    = "/auth.AuthService/RefreshAccessToken"
)
View Source 
const (
	BlockEngineValidator_SubscribePackets_FullMethodName       = "/block_engine.BlockEngineValidator/SubscribePackets"
	BlockEngineValidator_SubscribeBundles_FullMethodName       = "/block_engine.BlockEngineValidator/SubscribeBundles"
	BlockEngineValidator_GetBlockBuilderFeeInfo_FullMethodName = "/block_engine.BlockEngineValidator/GetBlockBuilderFeeInfo"
)
View Source 
const (
	BlockEngineRelayer_SubscribeAccountsOfInterest_FullMethodName = "/block_engine.BlockEngineRelayer/SubscribeAccountsOfInterest"
	BlockEngineRelayer_SubscribeProgramsOfInterest_FullMethodName = "/block_engine.BlockEngineRelayer/SubscribeProgramsOfInterest"
	BlockEngineRelayer_StartExpiringPacketStream_FullMethodName   = "/block_engine.BlockEngineRelayer/StartExpiringPacketStream"
)
View Source 
const (
	Relayer_GetTpuConfigs_FullMethodName    = "/relayer.Relayer/GetTpuConfigs"
	Relayer_SubscribePackets_FullMethodName = "/relayer.Relayer/SubscribePackets"
)
View Source 
const (
	SearcherService_SubscribeBundleResults_FullMethodName      = "/searcher.SearcherService/SubscribeBundleResults"
	SearcherService_SubscribeMempool_FullMethodName            = "/searcher.SearcherService/SubscribeMempool"
	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"
)
View Source 
const (
	Shredstream_SendHeartbeat_FullMethodName = "/shredstream.Shredstream/SendHeartbeat"
)

Variables

View Source 
var (
	Role_name = map[int32]string{
		0: "RELAYER",
		1: "SEARCHER",
		2: "VALIDATOR",
		3: "SHREDSTREAM_SUBSCRIBER",
	}
	Role_value = map[string]int32{
		"RELAYER":                0,
		"SEARCHER":               1,
		"VALIDATOR":              2,
		"SHREDSTREAM_SUBSCRIBER": 3,
	}
)

Enum value maps for Role.

View Source 
var (
	DroppedReason_name = map[int32]string{
		0: "BlockhashExpired",
		1: "PartiallyProcessed",
		2: "NotFinalized",
	}
	DroppedReason_value = map[string]int32{
		"BlockhashExpired":   0,
		"PartiallyProcessed": 1,
		"NotFinalized":       2,
	}
)

Enum value maps for DroppedReason.

View Source 
var AuthService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "auth.AuthService",
	HandlerType: (*AuthServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GenerateAuthChallenge",
			Handler:    _AuthService_GenerateAuthChallenge_Handler,
		},
		{
			MethodName: "GenerateAuthTokens",
			Handler:    _AuthService_GenerateAuthTokens_Handler,
		},
		{
			MethodName: "RefreshAccessToken",
			Handler:    _AuthService_RefreshAccessToken_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "auth.proto",
}

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

View Source 
var BlockEngineRelayer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "block_engine.BlockEngineRelayer",
	HandlerType: (*BlockEngineRelayerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeAccountsOfInterest",
			Handler:       _BlockEngineRelayer_SubscribeAccountsOfInterest_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeProgramsOfInterest",
			Handler:       _BlockEngineRelayer_SubscribeProgramsOfInterest_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StartExpiringPacketStream",
			Handler:       _BlockEngineRelayer_StartExpiringPacketStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "block_engine.proto",
}

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

View Source 
var BlockEngineValidator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "block_engine.BlockEngineValidator",
	HandlerType: (*BlockEngineValidatorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBlockBuilderFeeInfo",
			Handler:    _BlockEngineValidator_GetBlockBuilderFeeInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribePackets",
			Handler:       _BlockEngineValidator_SubscribePackets_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBundles",
			Handler:       _BlockEngineValidator_SubscribeBundles_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "block_engine.proto",
}

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

View Source 
var File_auth_proto protoreflect.FileDescriptor
View Source 
var File_block_engine_proto protoreflect.FileDescriptor
View Source 
var File_block_proto protoreflect.FileDescriptor
View Source 
var File_bundle_proto protoreflect.FileDescriptor
View Source 
var File_packet_proto protoreflect.FileDescriptor
View Source 
var File_relayer_proto protoreflect.FileDescriptor
View Source 
var File_searcher_proto protoreflect.FileDescriptor
View Source 
var File_shared_proto protoreflect.FileDescriptor
View Source 
var File_shredstream_proto protoreflect.FileDescriptor
View Source 
var File_trace_shred_proto protoreflect.FileDescriptor
View Source 
var Relayer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "relayer.Relayer",
	HandlerType: (*RelayerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetTpuConfigs",
			Handler:    _Relayer_GetTpuConfigs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribePackets",
			Handler:       _Relayer_SubscribePackets_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "relayer.proto",
}

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

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)

View Source 
var Shredstream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "shredstream.Shredstream",
	HandlerType: (*ShredstreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendHeartbeat",
			Handler:    _Shredstream_SendHeartbeat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "shredstream.proto",
}

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

Functions

func RegisterAuthServiceServer 

func RegisterAuthServiceServer(s grpc.ServiceRegistrar, srv AuthServiceServer)

func RegisterBlockEngineRelayerServer 

func RegisterBlockEngineRelayerServer(s grpc.ServiceRegistrar, srv BlockEngineRelayerServer)

func RegisterBlockEngineValidatorServer 

func RegisterBlockEngineValidatorServer(s grpc.ServiceRegistrar, srv BlockEngineValidatorServer)

func RegisterRelayerServer 

func RegisterRelayerServer(s grpc.ServiceRegistrar, srv RelayerServer)

func RegisterSearcherServiceServer 

func RegisterSearcherServiceServer(s grpc.ServiceRegistrar, srv SearcherServiceServer)

func RegisterShredstreamServer 

func RegisterShredstreamServer(s grpc.ServiceRegistrar, srv ShredstreamServer)

Types

type Accepted 

type Accepted struct {

	// Slot at which bundle was forwarded.
	Slot uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	// Validator identity bundle was forwarded to.
	ValidatorIdentity string `protobuf:"bytes,2,opt,name=validator_identity,json=validatorIdentity,proto3" json:"validator_identity,omitempty"`
	// contains filtered or unexported fields
}

Indicates the bundle was accepted and forwarded to a validator. NOTE: A single bundle may have multiple events emitted if forwarded to many validator.

func (*Accepted) Descriptor deprecated 

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

Deprecated: Use Accepted.ProtoReflect.Descriptor instead.

func (*Accepted) GetSlot 

func (x *Accepted) GetSlot() uint64

func (*Accepted) GetValidatorIdentity 

func (x *Accepted) GetValidatorIdentity() string

func (*Accepted) ProtoMessage 

func (*Accepted) ProtoMessage()

func (*Accepted) ProtoReflect 

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

func (*Accepted) Reset 

func (x *Accepted) Reset()

func (*Accepted) String 

func (x *Accepted) String() string

type AccountsOfInterest 

type AccountsOfInterest struct {

	// use * for all accounts
	Accounts []string `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountsOfInterest) Descriptor deprecated 

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

Deprecated: Use AccountsOfInterest.ProtoReflect.Descriptor instead.

func (*AccountsOfInterest) GetAccounts 

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

func (*AccountsOfInterest) ProtoMessage 

func (*AccountsOfInterest) ProtoMessage()

func (*AccountsOfInterest) ProtoReflect 

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

func (*AccountsOfInterest) Reset 

func (x *AccountsOfInterest) Reset()

func (*AccountsOfInterest) String 

func (x *AccountsOfInterest) String() string

type AccountsOfInterestRequest 

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

func (*AccountsOfInterestRequest) Descriptor deprecated 

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

Deprecated: Use AccountsOfInterestRequest.ProtoReflect.Descriptor instead.

func (*AccountsOfInterestRequest) ProtoMessage 

func (*AccountsOfInterestRequest) ProtoMessage()

func (*AccountsOfInterestRequest) ProtoReflect 

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

func (*AccountsOfInterestRequest) Reset 

func (x *AccountsOfInterestRequest) Reset()

func (*AccountsOfInterestRequest) String 

func (x *AccountsOfInterestRequest) String() string

type AccountsOfInterestUpdate 

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

func (*AccountsOfInterestUpdate) Descriptor deprecated 

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

Deprecated: Use AccountsOfInterestUpdate.ProtoReflect.Descriptor instead.

func (*AccountsOfInterestUpdate) GetAccounts 

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

func (*AccountsOfInterestUpdate) ProtoMessage 

func (*AccountsOfInterestUpdate) ProtoMessage()

func (*AccountsOfInterestUpdate) ProtoReflect 

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

func (*AccountsOfInterestUpdate) Reset 

func (x *AccountsOfInterestUpdate) Reset()

func (*AccountsOfInterestUpdate) String 

func (x *AccountsOfInterestUpdate) String() string

type AuthServiceClient 

type AuthServiceClient interface {
	// / Returns a challenge, client is expected to sign this challenge with an appropriate keypair in order to obtain access tokens.
	GenerateAuthChallenge(ctx context.Context, in *GenerateAuthChallengeRequest, opts ...grpc.CallOption) (*GenerateAuthChallengeResponse, error)
	// / Provides the client with the initial pair of auth tokens for API access.
	GenerateAuthTokens(ctx context.Context, in *GenerateAuthTokensRequest, opts ...grpc.CallOption) (*GenerateAuthTokensResponse, error)
	// / Call this method with a non-expired refresh token to obtain a new access token.
	RefreshAccessToken(ctx context.Context, in *RefreshAccessTokenRequest, opts ...grpc.CallOption) (*RefreshAccessTokenResponse, error)
}

AuthServiceClient is the client API for AuthService 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 NewAuthServiceClient 

func NewAuthServiceClient(cc grpc.ClientConnInterface) AuthServiceClient

type AuthServiceServer 

type AuthServiceServer interface {
	// / Returns a challenge, client is expected to sign this challenge with an appropriate keypair in order to obtain access tokens.
	GenerateAuthChallenge(context.Context, *GenerateAuthChallengeRequest) (*GenerateAuthChallengeResponse, error)
	// / Provides the client with the initial pair of auth tokens for API access.
	GenerateAuthTokens(context.Context, *GenerateAuthTokensRequest) (*GenerateAuthTokensResponse, error)
	// / Call this method with a non-expired refresh token to obtain a new access token.
	RefreshAccessToken(context.Context, *RefreshAccessTokenRequest) (*RefreshAccessTokenResponse, error)
	// contains filtered or unexported methods
}

AuthServiceServer is the server API for AuthService service. All implementations must embed UnimplementedAuthServiceServer for forward compatibility

type BlockBuilderFeeInfoRequest 

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

func (*BlockBuilderFeeInfoRequest) Descriptor deprecated 

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

Deprecated: Use BlockBuilderFeeInfoRequest.ProtoReflect.Descriptor instead.

func (*BlockBuilderFeeInfoRequest) ProtoMessage 

func (*BlockBuilderFeeInfoRequest) ProtoMessage()

func (*BlockBuilderFeeInfoRequest) ProtoReflect 

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

func (*BlockBuilderFeeInfoRequest) Reset 

func (x *BlockBuilderFeeInfoRequest) Reset()

func (*BlockBuilderFeeInfoRequest) String 

func (x *BlockBuilderFeeInfoRequest) String() string

type BlockBuilderFeeInfoResponse 

type BlockBuilderFeeInfoResponse struct {
	Pubkey string `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// commission (0-100)
	Commission uint64 `protobuf:"varint,2,opt,name=commission,proto3" json:"commission,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockBuilderFeeInfoResponse) Descriptor deprecated 

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

Deprecated: Use BlockBuilderFeeInfoResponse.ProtoReflect.Descriptor instead.

func (*BlockBuilderFeeInfoResponse) GetCommission 

func (x *BlockBuilderFeeInfoResponse) GetCommission() uint64

func (*BlockBuilderFeeInfoResponse) GetPubkey 

func (x *BlockBuilderFeeInfoResponse) GetPubkey() string

func (*BlockBuilderFeeInfoResponse) ProtoMessage 

func (*BlockBuilderFeeInfoResponse) ProtoMessage()

func (*BlockBuilderFeeInfoResponse) ProtoReflect 

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

func (*BlockBuilderFeeInfoResponse) Reset 

func (x *BlockBuilderFeeInfoResponse) Reset()

func (*BlockBuilderFeeInfoResponse) String 

func (x *BlockBuilderFeeInfoResponse) String() string

type BlockEngineRelayerClient 

type BlockEngineRelayerClient interface {
	// / The block engine feeds accounts of interest (AOI) updates to the relayer periodically.
	// / For all transactions the relayer receives, it forwards transactions to the block engine which write-lock
	// / any of the accounts in the AOI.
	SubscribeAccountsOfInterest(ctx context.Context, in *AccountsOfInterestRequest, opts ...grpc.CallOption) (BlockEngineRelayer_SubscribeAccountsOfInterestClient, error)
	SubscribeProgramsOfInterest(ctx context.Context, in *ProgramsOfInterestRequest, opts ...grpc.CallOption) (BlockEngineRelayer_SubscribeProgramsOfInterestClient, error)
	// Validators can subscribe to packets from the relayer and receive a multiplexed signal that contains a mixture
	// of packets and heartbeats.
	// NOTE: This is a bi-directional stream due to a bug with how Envoy handles half closed client-side streams.
	// The issue is being tracked here: https://github.com/envoyproxy/envoy/issues/22748. In the meantime, the
	// server will stream heartbeats to clients at some reasonable cadence.
	StartExpiringPacketStream(ctx context.Context, opts ...grpc.CallOption) (BlockEngineRelayer_StartExpiringPacketStreamClient, error)
}

BlockEngineRelayerClient is the client API for BlockEngineRelayer 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 NewBlockEngineRelayerClient 

func NewBlockEngineRelayerClient(cc grpc.ClientConnInterface) BlockEngineRelayerClient

type BlockEngineRelayerServer 

type BlockEngineRelayerServer interface {
	// / The block engine feeds accounts of interest (AOI) updates to the relayer periodically.
	// / For all transactions the relayer receives, it forwards transactions to the block engine which write-lock
	// / any of the accounts in the AOI.
	SubscribeAccountsOfInterest(*AccountsOfInterestRequest, BlockEngineRelayer_SubscribeAccountsOfInterestServer) error
	SubscribeProgramsOfInterest(*ProgramsOfInterestRequest, BlockEngineRelayer_SubscribeProgramsOfInterestServer) error
	// Validators can subscribe to packets from the relayer and receive a multiplexed signal that contains a mixture
	// of packets and heartbeats.
	// NOTE: This is a bi-directional stream due to a bug with how Envoy handles half closed client-side streams.
	// The issue is being tracked here: https://github.com/envoyproxy/envoy/issues/22748. In the meantime, the
	// server will stream heartbeats to clients at some reasonable cadence.
	StartExpiringPacketStream(BlockEngineRelayer_StartExpiringPacketStreamServer) error
	// contains filtered or unexported methods
}

BlockEngineRelayerServer is the server API for BlockEngineRelayer service. All implementations must embed UnimplementedBlockEngineRelayerServer for forward compatibility

type BlockEngineRelayer_StartExpiringPacketStreamClient 

type BlockEngineRelayer_StartExpiringPacketStreamClient interface {
	Send(*PacketBatchUpdate) error
	Recv() (*StartExpiringPacketStreamResponse, error)
	grpc.ClientStream
}

type BlockEngineRelayer_StartExpiringPacketStreamServer 

type BlockEngineRelayer_StartExpiringPacketStreamServer interface {
	Send(*StartExpiringPacketStreamResponse) error
	Recv() (*PacketBatchUpdate, error)
	grpc.ServerStream
}

type BlockEngineRelayer_SubscribeAccountsOfInterestClient 

type BlockEngineRelayer_SubscribeAccountsOfInterestClient interface {
	Recv() (*AccountsOfInterestUpdate, error)
	grpc.ClientStream
}

type BlockEngineRelayer_SubscribeAccountsOfInterestServer 

type BlockEngineRelayer_SubscribeAccountsOfInterestServer interface {
	Send(*AccountsOfInterestUpdate) error
	grpc.ServerStream
}

type BlockEngineRelayer_SubscribeProgramsOfInterestClient 

type BlockEngineRelayer_SubscribeProgramsOfInterestClient interface {
	Recv() (*ProgramsOfInterestUpdate, error)
	grpc.ClientStream
}

type BlockEngineRelayer_SubscribeProgramsOfInterestServer 

type BlockEngineRelayer_SubscribeProgramsOfInterestServer interface {
	Send(*ProgramsOfInterestUpdate) error
	grpc.ServerStream
}

type BlockEngineValidatorClient 

type BlockEngineValidatorClient interface {
	// / Validators can subscribe to the block engine to receive a stream of packets
	SubscribePackets(ctx context.Context, in *SubscribePacketsRequest, opts ...grpc.CallOption) (BlockEngineValidator_SubscribePacketsClient, error)
	// / Validators can subscribe to the block engine to receive a stream of simulated and profitable bundles
	SubscribeBundles(ctx context.Context, in *SubscribeBundlesRequest, opts ...grpc.CallOption) (BlockEngineValidator_SubscribeBundlesClient, error)
	// Block builders can optionally collect fees. This returns fee information if a block builder wants to
	// collect one.
	GetBlockBuilderFeeInfo(ctx context.Context, in *BlockBuilderFeeInfoRequest, opts ...grpc.CallOption) (*BlockBuilderFeeInfoResponse, error)
}

BlockEngineValidatorClient is the client API for BlockEngineValidator 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 NewBlockEngineValidatorClient 

func NewBlockEngineValidatorClient(cc grpc.ClientConnInterface) BlockEngineValidatorClient

type BlockEngineValidatorServer 

type BlockEngineValidatorServer interface {
	// / Validators can subscribe to the block engine to receive a stream of packets
	SubscribePackets(*SubscribePacketsRequest, BlockEngineValidator_SubscribePacketsServer) error
	// / Validators can subscribe to the block engine to receive a stream of simulated and profitable bundles
	SubscribeBundles(*SubscribeBundlesRequest, BlockEngineValidator_SubscribeBundlesServer) error
	// Block builders can optionally collect fees. This returns fee information if a block builder wants to
	// collect one.
	GetBlockBuilderFeeInfo(context.Context, *BlockBuilderFeeInfoRequest) (*BlockBuilderFeeInfoResponse, error)
	// contains filtered or unexported methods
}

BlockEngineValidatorServer is the server API for BlockEngineValidator service. All implementations must embed UnimplementedBlockEngineValidatorServer for forward compatibility

type BlockEngineValidator_SubscribeBundlesClient 

type BlockEngineValidator_SubscribeBundlesClient interface {
	Recv() (*SubscribeBundlesResponse, error)
	grpc.ClientStream
}

type BlockEngineValidator_SubscribeBundlesServer 

type BlockEngineValidator_SubscribeBundlesServer interface {
	Send(*SubscribeBundlesResponse) error
	grpc.ServerStream
}

type BlockEngineValidator_SubscribePacketsClient 

type BlockEngineValidator_SubscribePacketsClient interface {
	Recv() (*SubscribePacketsResponse, error)
	grpc.ClientStream
}

type BlockEngineValidator_SubscribePacketsServer 

type BlockEngineValidator_SubscribePacketsServer interface {
	Send(*SubscribePacketsResponse) error
	grpc.ServerStream
}

type Bundle 

type Bundle struct {
	Header  *Header   `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	Packets []*Packet `protobuf:"bytes,3,rep,name=packets,proto3" json:"packets,omitempty"`
	// contains filtered or unexported fields
}

func (*Bundle) Descriptor deprecated 

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

Deprecated: Use Bundle.ProtoReflect.Descriptor instead.

func (*Bundle) GetHeader 

func (x *Bundle) GetHeader() *Header

func (*Bundle) GetPackets 

func (x *Bundle) GetPackets() []*Packet

func (*Bundle) ProtoMessage 

func (*Bundle) ProtoMessage()

func (*Bundle) ProtoReflect 

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

func (*Bundle) Reset 

func (x *Bundle) Reset()

func (*Bundle) String 

func (x *Bundle) String() string

type BundleResult 

type BundleResult struct {

	// Bundle's Uuid.
	BundleId string `protobuf:"bytes,1,opt,name=bundle_id,json=bundleId,proto3" json:"bundle_id,omitempty"`
	// Types that are assignable to Result:
	//
	//	*BundleResult_Accepted
	//	*BundleResult_Rejected
	//	*BundleResult_Finalized
	//	*BundleResult_Processed
	//	*BundleResult_Dropped
	Result isBundleResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*BundleResult) Descriptor deprecated 

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

Deprecated: Use BundleResult.ProtoReflect.Descriptor instead.

func (*BundleResult) GetAccepted 

func (x *BundleResult) GetAccepted() *Accepted

func (*BundleResult) GetBundleId 

func (x *BundleResult) GetBundleId() string

func (*BundleResult) GetDropped 

func (x *BundleResult) GetDropped() *Dropped

func (*BundleResult) GetFinalized 

func (x *BundleResult) GetFinalized() *Finalized

func (*BundleResult) GetProcessed 

func (x *BundleResult) GetProcessed() *Processed

func (*BundleResult) GetRejected 

func (x *BundleResult) GetRejected() *Rejected

func (*BundleResult) GetResult 

func (m *BundleResult) GetResult() isBundleResult_Result

func (*BundleResult) ProtoMessage 

func (*BundleResult) ProtoMessage()

func (*BundleResult) ProtoReflect 

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

func (*BundleResult) Reset 

func (x *BundleResult) Reset()

func (*BundleResult) String 

func (x *BundleResult) String() string

type BundleResult_Accepted 

type BundleResult_Accepted struct {
	// Indicated accepted by the block-engine and forwarded to a jito-solana validator.
	Accepted *Accepted `protobuf:"bytes,2,opt,name=accepted,proto3,oneof"`
}

type BundleResult_Dropped 

type BundleResult_Dropped struct {
	// Was accepted and forwarded by the block-engine but never landed on-chain.
	Dropped *Dropped `protobuf:"bytes,6,opt,name=dropped,proto3,oneof"`
}

type BundleResult_Finalized 

type BundleResult_Finalized struct {
	// Reached finalized commitment level.
	Finalized *Finalized `protobuf:"bytes,4,opt,name=finalized,proto3,oneof"`
}

type BundleResult_Processed 

type BundleResult_Processed struct {
	// Reached a processed commitment level.
	Processed *Processed `protobuf:"bytes,5,opt,name=processed,proto3,oneof"`
}

type BundleResult_Rejected 

type BundleResult_Rejected struct {
	// Rejected by the block-engine.
	Rejected *Rejected `protobuf:"bytes,3,opt,name=rejected,proto3,oneof"`
}

type BundleUuid 

type BundleUuid struct {
	Bundle *Bundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Uuid   string  `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*BundleUuid) Descriptor deprecated 

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

Deprecated: Use BundleUuid.ProtoReflect.Descriptor instead.

func (*BundleUuid) GetBundle 

func (x *BundleUuid) GetBundle() *Bundle

func (*BundleUuid) GetUuid 

func (x *BundleUuid) GetUuid() string

func (*BundleUuid) ProtoMessage 

func (*BundleUuid) ProtoMessage()

func (*BundleUuid) ProtoReflect 

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

func (*BundleUuid) Reset 

func (x *BundleUuid) Reset()

func (*BundleUuid) String 

func (x *BundleUuid) String() string

type CondensedBlock 

type CondensedBlock struct {
	Header                *Header  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	PreviousBlockhash     string   `protobuf:"bytes,2,opt,name=previous_blockhash,json=previousBlockhash,proto3" json:"previous_blockhash,omitempty"`
	Blockhash             string   `protobuf:"bytes,3,opt,name=blockhash,proto3" json:"blockhash,omitempty"`
	ParentSlot            uint64   `protobuf:"varint,4,opt,name=parent_slot,json=parentSlot,proto3" json:"parent_slot,omitempty"`
	VersionedTransactions [][]byte `protobuf:"bytes,5,rep,name=versioned_transactions,json=versionedTransactions,proto3" json:"versioned_transactions,omitempty"`
	Slot                  uint64   `protobuf:"varint,6,opt,name=slot,proto3" json:"slot,omitempty"`
	Commitment            string   `protobuf:"bytes,7,opt,name=commitment,proto3" json:"commitment,omitempty"`
	// contains filtered or unexported fields
}

Condensed block helpful for getting data around efficiently internal to our system.

func (*CondensedBlock) Descriptor deprecated 

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

Deprecated: Use CondensedBlock.ProtoReflect.Descriptor instead.

func (*CondensedBlock) GetBlockhash 

func (x *CondensedBlock) GetBlockhash() string

func (*CondensedBlock) GetCommitment 

func (x *CondensedBlock) GetCommitment() string

func (*CondensedBlock) GetHeader 

func (x *CondensedBlock) GetHeader() *Header

func (*CondensedBlock) GetParentSlot 

func (x *CondensedBlock) GetParentSlot() uint64

func (*CondensedBlock) GetPreviousBlockhash 

func (x *CondensedBlock) GetPreviousBlockhash() string

func (*CondensedBlock) GetSlot 

func (x *CondensedBlock) GetSlot() uint64

func (*CondensedBlock) GetVersionedTransactions 

func (x *CondensedBlock) GetVersionedTransactions() [][]byte

func (*CondensedBlock) ProtoMessage 

func (*CondensedBlock) ProtoMessage()

func (*CondensedBlock) ProtoReflect 

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

func (*CondensedBlock) Reset 

func (x *CondensedBlock) Reset()

func (*CondensedBlock) String 

func (x *CondensedBlock) String() string

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 Dropped 

type Dropped struct {
	Reason DroppedReason `protobuf:"varint,1,opt,name=reason,proto3,enum=bundle.DroppedReason" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Dropped) Descriptor deprecated 

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

Deprecated: Use Dropped.ProtoReflect.Descriptor instead.

func (*Dropped) GetReason 

func (x *Dropped) GetReason() DroppedReason

func (*Dropped) ProtoMessage 

func (*Dropped) ProtoMessage()

func (*Dropped) ProtoReflect 

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

func (*Dropped) Reset 

func (x *Dropped) Reset()

func (*Dropped) String 

func (x *Dropped) String() string

type DroppedBundle 

type DroppedBundle struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Bundle dropped (e.g. because no leader upcoming)

func (*DroppedBundle) Descriptor deprecated 

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

Deprecated: Use DroppedBundle.ProtoReflect.Descriptor instead.

func (*DroppedBundle) GetMsg 

func (x *DroppedBundle) GetMsg() string

func (*DroppedBundle) ProtoMessage 

func (*DroppedBundle) ProtoMessage()

func (*DroppedBundle) ProtoReflect 

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

func (*DroppedBundle) Reset 

func (x *DroppedBundle) Reset()

func (*DroppedBundle) String 

func (x *DroppedBundle) String() string

type DroppedReason 

type DroppedReason int32
const (
	DroppedReason_BlockhashExpired DroppedReason = 0
	// One or more transactions in the bundle landed on-chain, invalidating the bundle.
	DroppedReason_PartiallyProcessed DroppedReason = 1
	// This indicates bundle was processed but not finalized. This could occur during forks.
	DroppedReason_NotFinalized DroppedReason = 2
)

func (DroppedReason) Descriptor 

func (DroppedReason) Descriptor() protoreflect.EnumDescriptor

func (DroppedReason) Enum 

func (x DroppedReason) Enum() *DroppedReason

func (DroppedReason) EnumDescriptor deprecated 

func (DroppedReason) EnumDescriptor() ([]byte, []int)

Deprecated: Use DroppedReason.Descriptor instead.

func (DroppedReason) Number 

func (x DroppedReason) Number() protoreflect.EnumNumber

func (DroppedReason) String 

func (x DroppedReason) String() string

func (DroppedReason) Type 

func (DroppedReason) Type() protoreflect.EnumType

type ExpiringPacketBatch 

type ExpiringPacketBatch struct {
	Header   *Header      `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Batch    *PacketBatch `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	ExpiryMs uint32       `protobuf:"varint,3,opt,name=expiry_ms,json=expiryMs,proto3" json:"expiry_ms,omitempty"`
	// contains filtered or unexported fields
}

A series of packets with an expiration attached to them. The header contains a timestamp for when this packet was generated. The expiry is how long the packet batches have before they expire and are forwarded to the validator. This provides a more censorship resistant method to MEV than block engines receiving packets directly.

func (*ExpiringPacketBatch) Descriptor deprecated 

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

Deprecated: Use ExpiringPacketBatch.ProtoReflect.Descriptor instead.

func (*ExpiringPacketBatch) GetBatch 

func (x *ExpiringPacketBatch) GetBatch() *PacketBatch

func (*ExpiringPacketBatch) GetExpiryMs 

func (x *ExpiringPacketBatch) GetExpiryMs() uint32

func (*ExpiringPacketBatch) GetHeader 

func (x *ExpiringPacketBatch) GetHeader() *Header

func (*ExpiringPacketBatch) ProtoMessage 

func (*ExpiringPacketBatch) ProtoMessage()

func (*ExpiringPacketBatch) ProtoReflect 

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

func (*ExpiringPacketBatch) Reset 

func (x *ExpiringPacketBatch) Reset()

func (*ExpiringPacketBatch) String 

func (x *ExpiringPacketBatch) String() string

type Finalized 

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

func (*Finalized) Descriptor deprecated 

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

Deprecated: Use Finalized.ProtoReflect.Descriptor instead.

func (*Finalized) ProtoMessage 

func (*Finalized) ProtoMessage()

func (*Finalized) ProtoReflect 

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

func (*Finalized) Reset 

func (x *Finalized) Reset()

func (*Finalized) String 

func (x *Finalized) String() string

type GenerateAuthChallengeRequest 

type GenerateAuthChallengeRequest struct {

	// / Role the client is attempting to generate tokens for.
	Role Role `protobuf:"varint,1,opt,name=role,proto3,enum=auth.Role" json:"role,omitempty"`
	// / Client's 32 byte pubkey.
	Pubkey []byte `protobuf:"bytes,2,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateAuthChallengeRequest) Descriptor deprecated 

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

Deprecated: Use GenerateAuthChallengeRequest.ProtoReflect.Descriptor instead.

func (*GenerateAuthChallengeRequest) GetPubkey 

func (x *GenerateAuthChallengeRequest) GetPubkey() []byte

func (*GenerateAuthChallengeRequest) GetRole 

func (x *GenerateAuthChallengeRequest) GetRole() Role

func (*GenerateAuthChallengeRequest) ProtoMessage 

func (*GenerateAuthChallengeRequest) ProtoMessage()

func (*GenerateAuthChallengeRequest) ProtoReflect 

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

func (*GenerateAuthChallengeRequest) Reset 

func (x *GenerateAuthChallengeRequest) Reset()

func (*GenerateAuthChallengeRequest) String 

func (x *GenerateAuthChallengeRequest) String() string

type GenerateAuthChallengeResponse 

type GenerateAuthChallengeResponse struct {
	Challenge string `protobuf:"bytes,1,opt,name=challenge,proto3" json:"challenge,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateAuthChallengeResponse) Descriptor deprecated 

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

Deprecated: Use GenerateAuthChallengeResponse.ProtoReflect.Descriptor instead.

func (*GenerateAuthChallengeResponse) GetChallenge 

func (x *GenerateAuthChallengeResponse) GetChallenge() string

func (*GenerateAuthChallengeResponse) ProtoMessage 

func (*GenerateAuthChallengeResponse) ProtoMessage()

func (*GenerateAuthChallengeResponse) ProtoReflect 

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

func (*GenerateAuthChallengeResponse) Reset 

func (x *GenerateAuthChallengeResponse) Reset()

func (*GenerateAuthChallengeResponse) String 

func (x *GenerateAuthChallengeResponse) String() string

type GenerateAuthTokensRequest 

type GenerateAuthTokensRequest struct {

	// / The pre-signed challenge.
	Challenge string `protobuf:"bytes,1,opt,name=challenge,proto3" json:"challenge,omitempty"`
	// / The signing keypair's corresponding 32 byte pubkey.
	ClientPubkey []byte `protobuf:"bytes,2,opt,name=client_pubkey,json=clientPubkey,proto3" json:"client_pubkey,omitempty"`
	// / The 64 byte signature of the challenge signed by the client's private key. The private key must correspond to
	// the pubkey passed in the [GenerateAuthChallenge] method. The client is expected to sign the challenge token
	// prepended with their pubkey. For example sign(pubkey, challenge).
	SignedChallenge []byte `protobuf:"bytes,3,opt,name=signed_challenge,json=signedChallenge,proto3" json:"signed_challenge,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateAuthTokensRequest) Descriptor deprecated 

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

Deprecated: Use GenerateAuthTokensRequest.ProtoReflect.Descriptor instead.

func (*GenerateAuthTokensRequest) GetChallenge 

func (x *GenerateAuthTokensRequest) GetChallenge() string

func (*GenerateAuthTokensRequest) GetClientPubkey 

func (x *GenerateAuthTokensRequest) GetClientPubkey() []byte

func (*GenerateAuthTokensRequest) GetSignedChallenge 

func (x *GenerateAuthTokensRequest) GetSignedChallenge() []byte

func (*GenerateAuthTokensRequest) ProtoMessage 

func (*GenerateAuthTokensRequest) ProtoMessage()

func (*GenerateAuthTokensRequest) ProtoReflect 

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

func (*GenerateAuthTokensRequest) Reset 

func (x *GenerateAuthTokensRequest) Reset()

func (*GenerateAuthTokensRequest) String 

func (x *GenerateAuthTokensRequest) String() string

type GenerateAuthTokensResponse 

type GenerateAuthTokensResponse struct {

	// / The token granting access to resources.
	AccessToken *Token `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// / The token used to refresh the access_token. This has a longer TTL than the access_token.
	RefreshToken *Token `protobuf:"bytes,2,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateAuthTokensResponse) Descriptor deprecated 

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

Deprecated: Use GenerateAuthTokensResponse.ProtoReflect.Descriptor instead.

func (*GenerateAuthTokensResponse) GetAccessToken 

func (x *GenerateAuthTokensResponse) GetAccessToken() *Token

func (*GenerateAuthTokensResponse) GetRefreshToken 

func (x *GenerateAuthTokensResponse) GetRefreshToken() *Token

func (*GenerateAuthTokensResponse) ProtoMessage 

func (*GenerateAuthTokensResponse) ProtoMessage()

func (*GenerateAuthTokensResponse) ProtoReflect 

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

func (*GenerateAuthTokensResponse) Reset 

func (x *GenerateAuthTokensResponse) Reset()

func (*GenerateAuthTokensResponse) String 

func (x *GenerateAuthTokensResponse) 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 GetTpuConfigsRequest 

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

func (*GetTpuConfigsRequest) Descriptor deprecated 

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

Deprecated: Use GetTpuConfigsRequest.ProtoReflect.Descriptor instead.

func (*GetTpuConfigsRequest) ProtoMessage 

func (*GetTpuConfigsRequest) ProtoMessage()

func (*GetTpuConfigsRequest) ProtoReflect 

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

func (*GetTpuConfigsRequest) Reset 

func (x *GetTpuConfigsRequest) Reset()

func (*GetTpuConfigsRequest) String 

func (x *GetTpuConfigsRequest) String() string

type GetTpuConfigsResponse 

type GetTpuConfigsResponse struct {
	Tpu        *Socket `protobuf:"bytes,1,opt,name=tpu,proto3" json:"tpu,omitempty"`
	TpuForward *Socket `protobuf:"bytes,2,opt,name=tpu_forward,json=tpuForward,proto3" json:"tpu_forward,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTpuConfigsResponse) Descriptor deprecated 

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

Deprecated: Use GetTpuConfigsResponse.ProtoReflect.Descriptor instead.

func (*GetTpuConfigsResponse) GetTpu 

func (x *GetTpuConfigsResponse) GetTpu() *Socket

func (*GetTpuConfigsResponse) GetTpuForward 

func (x *GetTpuConfigsResponse) GetTpuForward() *Socket

func (*GetTpuConfigsResponse) ProtoMessage 

func (*GetTpuConfigsResponse) ProtoMessage()

func (*GetTpuConfigsResponse) ProtoReflect 

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

func (*GetTpuConfigsResponse) Reset 

func (x *GetTpuConfigsResponse) Reset()

func (*GetTpuConfigsResponse) String 

func (x *GetTpuConfigsResponse) String() string
type Header struct {
	Ts *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetTs 

func (x *Header) GetTs() *timestamppb.Timestamp

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type Heartbeat 

type Heartbeat struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*Heartbeat) Descriptor deprecated 

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

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*Heartbeat) GetCount 

func (x *Heartbeat) GetCount() uint64

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) ProtoReflect 

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

func (*Heartbeat) Reset 

func (x *Heartbeat) Reset()

func (*Heartbeat) String 

func (x *Heartbeat) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {

	// client must respond within `ttl_ms` to keep stream alive
	TtlMs uint32 `protobuf:"varint,1,opt,name=ttl_ms,json=ttlMs,proto3" json:"ttl_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetTtlMs 

func (x *HeartbeatResponse) GetTtlMs() uint32

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type HeartbeatShredStream 

type HeartbeatShredStream struct {

	// don't trust IP:PORT from tcp header since it can be tampered over the wire
	// `socket.ip` must match incoming packet's ip. this prevents spamming an unwitting destination
	Socket *Socket `protobuf:"bytes,1,opt,name=socket,proto3" json:"socket,omitempty"`
	// regions for shredstream proxy to receive shreds from
	// list of valid regions: https://jito-labs.gitbook.io/mev/systems/connecting/mainnet
	Regions []string `protobuf:"bytes,2,rep,name=regions,proto3" json:"regions,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatShredStream) Descriptor deprecated 

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

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*HeartbeatShredStream) GetRegions 

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

func (*HeartbeatShredStream) GetSocket 

func (x *HeartbeatShredStream) GetSocket() *Socket

func (*HeartbeatShredStream) ProtoMessage 

func (*HeartbeatShredStream) ProtoMessage()

func (*HeartbeatShredStream) ProtoReflect 

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

func (*HeartbeatShredStream) Reset 

func (x *HeartbeatShredStream) Reset()

func (*HeartbeatShredStream) String 

func (x *HeartbeatShredStream) String() string

type InternalError 

type InternalError struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Bundle dropped due to an internal error.

func (*InternalError) Descriptor deprecated 

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

Deprecated: Use InternalError.ProtoReflect.Descriptor instead.

func (*InternalError) GetMsg 

func (x *InternalError) GetMsg() string

func (*InternalError) ProtoMessage 

func (*InternalError) ProtoMessage()

func (*InternalError) ProtoReflect 

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

func (*InternalError) Reset 

func (x *InternalError) Reset()

func (*InternalError) String 

func (x *InternalError) 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 Meta 

type Meta struct {
	Size        uint64       `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Addr        string       `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Port        uint32       `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Flags       *PacketFlags `protobuf:"bytes,4,opt,name=flags,proto3" json:"flags,omitempty"`
	SenderStake uint64       `protobuf:"varint,5,opt,name=sender_stake,json=senderStake,proto3" json:"sender_stake,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated 

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

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetAddr 

func (x *Meta) GetAddr() string

func (*Meta) GetFlags 

func (x *Meta) GetFlags() *PacketFlags

func (*Meta) GetPort 

func (x *Meta) GetPort() uint32

func (*Meta) GetSenderStake 

func (x *Meta) GetSenderStake() uint64

func (*Meta) GetSize 

func (x *Meta) GetSize() uint64

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

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

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) 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 Packet 

type Packet struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Meta *Meta  `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Packet) Descriptor deprecated 

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetData 

func (x *Packet) GetData() []byte

func (*Packet) GetMeta 

func (x *Packet) GetMeta() *Meta

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect 

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

func (*Packet) Reset 

func (x *Packet) Reset()

func (*Packet) String 

func (x *Packet) String() string

type PacketBatch 

type PacketBatch struct {
	Packets []*Packet `protobuf:"bytes,1,rep,name=packets,proto3" json:"packets,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketBatch) Descriptor deprecated 

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

Deprecated: Use PacketBatch.ProtoReflect.Descriptor instead.

func (*PacketBatch) GetPackets 

func (x *PacketBatch) GetPackets() []*Packet

func (*PacketBatch) ProtoMessage 

func (*PacketBatch) ProtoMessage()

func (*PacketBatch) ProtoReflect 

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

func (*PacketBatch) Reset 

func (x *PacketBatch) Reset()

func (*PacketBatch) String 

func (x *PacketBatch) String() string

type PacketBatchUpdate 

type PacketBatchUpdate struct {

	// Types that are assignable to Msg:
	//
	//	*PacketBatchUpdate_Batches
	//	*PacketBatchUpdate_Heartbeat
	Msg isPacketBatchUpdate_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

Packets and heartbeats are sent over the same stream. ExpiringPacketBatches have an expiration attached to them so the block engine can track how long it has until the relayer forwards the packets to the validator. Heartbeats contain a timestamp from the system and is used as a simple and naive time-sync mechanism so the block engine has some idea on how far their clocks are apart.

func (*PacketBatchUpdate) Descriptor deprecated 

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

Deprecated: Use PacketBatchUpdate.ProtoReflect.Descriptor instead.

func (*PacketBatchUpdate) GetBatches 

func (x *PacketBatchUpdate) GetBatches() *ExpiringPacketBatch

func (*PacketBatchUpdate) GetHeartbeat 

func (x *PacketBatchUpdate) GetHeartbeat() *Heartbeat

func (*PacketBatchUpdate) GetMsg 

func (m *PacketBatchUpdate) GetMsg() isPacketBatchUpdate_Msg

func (*PacketBatchUpdate) ProtoMessage 

func (*PacketBatchUpdate) ProtoMessage()

func (*PacketBatchUpdate) ProtoReflect 

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

func (*PacketBatchUpdate) Reset 

func (x *PacketBatchUpdate) Reset()

func (*PacketBatchUpdate) String 

func (x *PacketBatchUpdate) String() string

type PacketBatchUpdate_Batches 

type PacketBatchUpdate_Batches struct {
	Batches *ExpiringPacketBatch `protobuf:"bytes,1,opt,name=batches,proto3,oneof"`
}

type PacketBatchUpdate_Heartbeat 

type PacketBatchUpdate_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,2,opt,name=heartbeat,proto3,oneof"`
}

type PacketFlags 

type PacketFlags struct {
	Discard      bool `protobuf:"varint,1,opt,name=discard,proto3" json:"discard,omitempty"`
	Forwarded    bool `protobuf:"varint,2,opt,name=forwarded,proto3" json:"forwarded,omitempty"`
	Repair       bool `protobuf:"varint,3,opt,name=repair,proto3" json:"repair,omitempty"`
	SimpleVoteTx bool `protobuf:"varint,4,opt,name=simple_vote_tx,json=simpleVoteTx,proto3" json:"simple_vote_tx,omitempty"`
	TracerPacket bool `protobuf:"varint,5,opt,name=tracer_packet,json=tracerPacket,proto3" json:"tracer_packet,omitempty"`
	// contains filtered or unexported fields
}

func (*PacketFlags) Descriptor deprecated 

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

Deprecated: Use PacketFlags.ProtoReflect.Descriptor instead.

func (*PacketFlags) GetDiscard 

func (x *PacketFlags) GetDiscard() bool

func (*PacketFlags) GetForwarded 

func (x *PacketFlags) GetForwarded() bool

func (*PacketFlags) GetRepair 

func (x *PacketFlags) GetRepair() bool

func (*PacketFlags) GetSimpleVoteTx 

func (x *PacketFlags) GetSimpleVoteTx() bool

func (*PacketFlags) GetTracerPacket 

func (x *PacketFlags) GetTracerPacket() bool

func (*PacketFlags) ProtoMessage 

func (*PacketFlags) ProtoMessage()

func (*PacketFlags) ProtoReflect 

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

func (*PacketFlags) Reset 

func (x *PacketFlags) Reset()

func (*PacketFlags) String 

func (x *PacketFlags) 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 `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

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 Processed 

type Processed struct {
	ValidatorIdentity string `protobuf:"bytes,1,opt,name=validator_identity,json=validatorIdentity,proto3" json:"validator_identity,omitempty"`
	Slot              uint64 `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"`
	// / Index within the block.
	BundleIndex uint64 `protobuf:"varint,3,opt,name=bundle_index,json=bundleIndex,proto3" json:"bundle_index,omitempty"`
	// contains filtered or unexported fields
}

func (*Processed) Descriptor deprecated 

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

Deprecated: Use Processed.ProtoReflect.Descriptor instead.

func (*Processed) GetBundleIndex 

func (x *Processed) GetBundleIndex() uint64

func (*Processed) GetSlot 

func (x *Processed) GetSlot() uint64

func (*Processed) GetValidatorIdentity 

func (x *Processed) GetValidatorIdentity() string

func (*Processed) ProtoMessage 

func (*Processed) ProtoMessage()

func (*Processed) ProtoReflect 

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

func (*Processed) Reset 

func (x *Processed) Reset()

func (*Processed) String 

func (x *Processed) 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 ProgramsOfInterestRequest 

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

func (*ProgramsOfInterestRequest) Descriptor deprecated 

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

Deprecated: Use ProgramsOfInterestRequest.ProtoReflect.Descriptor instead.

func (*ProgramsOfInterestRequest) ProtoMessage 

func (*ProgramsOfInterestRequest) ProtoMessage()

func (*ProgramsOfInterestRequest) ProtoReflect 

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

func (*ProgramsOfInterestRequest) Reset 

func (x *ProgramsOfInterestRequest) Reset()

func (*ProgramsOfInterestRequest) String 

func (x *ProgramsOfInterestRequest) String() string

type ProgramsOfInterestUpdate 

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

func (*ProgramsOfInterestUpdate) Descriptor deprecated 

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

Deprecated: Use ProgramsOfInterestUpdate.ProtoReflect.Descriptor instead.

func (*ProgramsOfInterestUpdate) GetPrograms 

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

func (*ProgramsOfInterestUpdate) ProtoMessage 

func (*ProgramsOfInterestUpdate) ProtoMessage()

func (*ProgramsOfInterestUpdate) ProtoReflect 

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

func (*ProgramsOfInterestUpdate) Reset 

func (x *ProgramsOfInterestUpdate) Reset()

func (*ProgramsOfInterestUpdate) String 

func (x *ProgramsOfInterestUpdate) String() string

type RefreshAccessTokenRequest 

type RefreshAccessTokenRequest struct {

	// / Non-expired refresh token obtained from the [GenerateAuthTokens] method.
	RefreshToken string `protobuf:"bytes,1,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshAccessTokenRequest) Descriptor deprecated 

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

Deprecated: Use RefreshAccessTokenRequest.ProtoReflect.Descriptor instead.

func (*RefreshAccessTokenRequest) GetRefreshToken 

func (x *RefreshAccessTokenRequest) GetRefreshToken() string

func (*RefreshAccessTokenRequest) ProtoMessage 

func (*RefreshAccessTokenRequest) ProtoMessage()

func (*RefreshAccessTokenRequest) ProtoReflect 

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

func (*RefreshAccessTokenRequest) Reset 

func (x *RefreshAccessTokenRequest) Reset()

func (*RefreshAccessTokenRequest) String 

func (x *RefreshAccessTokenRequest) String() string

type RefreshAccessTokenResponse 

type RefreshAccessTokenResponse struct {

	// / Fresh access_token.
	AccessToken *Token `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshAccessTokenResponse) Descriptor deprecated 

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

Deprecated: Use RefreshAccessTokenResponse.ProtoReflect.Descriptor instead.

func (*RefreshAccessTokenResponse) GetAccessToken 

func (x *RefreshAccessTokenResponse) GetAccessToken() *Token

func (*RefreshAccessTokenResponse) ProtoMessage 

func (*RefreshAccessTokenResponse) ProtoMessage()

func (*RefreshAccessTokenResponse) ProtoReflect 

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

func (*RefreshAccessTokenResponse) Reset 

func (x *RefreshAccessTokenResponse) Reset()

func (*RefreshAccessTokenResponse) String 

func (x *RefreshAccessTokenResponse) String() string

type Rejected 

type Rejected struct {

	// Types that are assignable to Reason:
	//
	//	*Rejected_StateAuctionBidRejected
	//	*Rejected_WinningBatchBidRejected
	//	*Rejected_SimulationFailure
	//	*Rejected_InternalError
	//	*Rejected_DroppedBundle
	Reason isRejected_Reason `protobuf_oneof:"reason"`
	// contains filtered or unexported fields
}

Indicates the bundle was dropped and therefore not forwarded to any validator.

func (*Rejected) Descriptor deprecated 

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

Deprecated: Use Rejected.ProtoReflect.Descriptor instead.

func (*Rejected) GetDroppedBundle 

func (x *Rejected) GetDroppedBundle() *DroppedBundle

func (*Rejected) GetInternalError 

func (x *Rejected) GetInternalError() *InternalError

func (*Rejected) GetReason 

func (m *Rejected) GetReason() isRejected_Reason

func (*Rejected) GetSimulationFailure 

func (x *Rejected) GetSimulationFailure() *SimulationFailure

func (*Rejected) GetStateAuctionBidRejected 

func (x *Rejected) GetStateAuctionBidRejected() *StateAuctionBidRejected

func (*Rejected) GetWinningBatchBidRejected 

func (x *Rejected) GetWinningBatchBidRejected() *WinningBatchBidRejected

func (*Rejected) ProtoMessage 

func (*Rejected) ProtoMessage()

func (*Rejected) ProtoReflect 

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

func (*Rejected) Reset 

func (x *Rejected) Reset()

func (*Rejected) String 

func (x *Rejected) String() string

type Rejected_DroppedBundle 

type Rejected_DroppedBundle struct {
	DroppedBundle *DroppedBundle `protobuf:"bytes,5,opt,name=dropped_bundle,json=droppedBundle,proto3,oneof"`
}

type Rejected_InternalError 

type Rejected_InternalError struct {
	InternalError *InternalError `protobuf:"bytes,4,opt,name=internal_error,json=internalError,proto3,oneof"`
}

type Rejected_SimulationFailure 

type Rejected_SimulationFailure struct {
	SimulationFailure *SimulationFailure `protobuf:"bytes,3,opt,name=simulation_failure,json=simulationFailure,proto3,oneof"`
}

type Rejected_StateAuctionBidRejected 

type Rejected_StateAuctionBidRejected struct {
	StateAuctionBidRejected *StateAuctionBidRejected `protobuf:"bytes,1,opt,name=state_auction_bid_rejected,json=stateAuctionBidRejected,proto3,oneof"`
}

type Rejected_WinningBatchBidRejected 

type Rejected_WinningBatchBidRejected struct {
	WinningBatchBidRejected *WinningBatchBidRejected `protobuf:"bytes,2,opt,name=winning_batch_bid_rejected,json=winningBatchBidRejected,proto3,oneof"`
}

type RelayerClient 

type RelayerClient interface {
	// The relayer has TPU and TPU forward sockets that validator-watcher can leverage.
	// A validator can fetch this config and change its TPU and TPU forward port in gossip.
	GetTpuConfigs(ctx context.Context, in *GetTpuConfigsRequest, opts ...grpc.CallOption) (*GetTpuConfigsResponse, error)
	// Validators can subscribe to packets from the relayer and receive a multiplexed signal that contains a mixture
	// of packets and heartbeats
	SubscribePackets(ctx context.Context, in *SubscribePacketsRequest, opts ...grpc.CallOption) (Relayer_SubscribePacketsClient, error)
}

RelayerClient is the client API for Relayer 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 NewRelayerClient 

func NewRelayerClient(cc grpc.ClientConnInterface) RelayerClient

type RelayerServer 

type RelayerServer interface {
	// The relayer has TPU and TPU forward sockets that validator-watcher can leverage.
	// A validator can fetch this config and change its TPU and TPU forward port in gossip.
	GetTpuConfigs(context.Context, *GetTpuConfigsRequest) (*GetTpuConfigsResponse, error)
	// Validators can subscribe to packets from the relayer and receive a multiplexed signal that contains a mixture
	// of packets and heartbeats
	SubscribePackets(*SubscribePacketsRequest, Relayer_SubscribePacketsServer) error
	// contains filtered or unexported methods
}

RelayerServer is the server API for Relayer service. All implementations must embed UnimplementedRelayerServer for forward compatibility

type Relayer_SubscribePacketsClient 

type Relayer_SubscribePacketsClient interface {
	Recv() (*SubscribePacketsResponse, error)
	grpc.ClientStream
}

type Relayer_SubscribePacketsServer 

type Relayer_SubscribePacketsServer interface {
	Send(*SubscribePacketsResponse) error
	grpc.ServerStream
}

type Role 

type Role int32
const (
	Role_RELAYER                Role = 0
	Role_SEARCHER               Role = 1
	Role_VALIDATOR              Role = 2
	Role_SHREDSTREAM_SUBSCRIBER Role = 3
)

func (Role) Descriptor 

func (Role) Descriptor() protoreflect.EnumDescriptor

func (Role) Enum 

func (x Role) Enum() *Role

func (Role) EnumDescriptor deprecated 

func (Role) EnumDescriptor() ([]byte, []int)

Deprecated: Use Role.Descriptor instead.

func (Role) Number 

func (x Role) Number() protoreflect.EnumNumber

func (Role) String 

func (x Role) String() string

func (Role) Type 

func (Role) Type() protoreflect.EnumType

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 validator 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 validator 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 validator-watcher during the current epoch. Only returns data for this region.
	GetConnectedLeaders(context.Context, *ConnectedLeadersRequest) (*ConnectedLeadersResponse, error)
	// Returns leader slots for connected jito validator-watcher 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() (*BundleResult, error)
	grpc.ClientStream
}

type SearcherService_SubscribeBundleResultsServer 

type SearcherService_SubscribeBundleResultsServer interface {
	Send(*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 `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

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 ShredstreamClient 

type ShredstreamClient interface {
	// RPC endpoint to send heartbeats to keep shreds flowing
	SendHeartbeat(ctx context.Context, in *Heartbeat, opts ...grpc.CallOption) (*HeartbeatResponse, error)
}

ShredstreamClient is the client API for Shredstream 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 NewShredstreamClient 

func NewShredstreamClient(cc grpc.ClientConnInterface) ShredstreamClient

type ShredstreamServer 

type ShredstreamServer interface {
	// RPC endpoint to send heartbeats to keep shreds flowing
	SendHeartbeat(context.Context, *Heartbeat) (*HeartbeatResponse, error)
	// contains filtered or unexported methods
}

ShredstreamServer is the server API for Shredstream service. All implementations must embed UnimplementedShredstreamServer for forward compatibility

type SimulationFailure 

type SimulationFailure struct {

	// Signature of the offending transaction.
	TxSignature string  `protobuf:"bytes,1,opt,name=tx_signature,json=txSignature,proto3" json:"tx_signature,omitempty"`
	Msg         *string `protobuf:"bytes,2,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Bundle dropped due to simulation failure.

func (*SimulationFailure) Descriptor deprecated 

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

Deprecated: Use SimulationFailure.ProtoReflect.Descriptor instead.

func (*SimulationFailure) GetMsg 

func (x *SimulationFailure) GetMsg() string

func (*SimulationFailure) GetTxSignature 

func (x *SimulationFailure) GetTxSignature() string

func (*SimulationFailure) ProtoMessage 

func (*SimulationFailure) ProtoMessage()

func (*SimulationFailure) ProtoReflect 

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

func (*SimulationFailure) Reset 

func (x *SimulationFailure) Reset()

func (*SimulationFailure) String 

func (x *SimulationFailure) 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 Socket 

type Socket struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port int64  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Socket) Descriptor deprecated 

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

Deprecated: Use Socket.ProtoReflect.Descriptor instead.

func (*Socket) GetIp 

func (x *Socket) GetIp() string

func (*Socket) GetPort 

func (x *Socket) GetPort() int64

func (*Socket) ProtoMessage 

func (*Socket) ProtoMessage()

func (*Socket) ProtoReflect 

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

func (*Socket) Reset 

func (x *Socket) Reset()

func (*Socket) String 

func (x *Socket) String() string

type StartExpiringPacketStreamResponse 

type StartExpiringPacketStreamResponse struct {
	Heartbeat *Heartbeat `protobuf:"bytes,1,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	// contains filtered or unexported fields
}

func (*StartExpiringPacketStreamResponse) Descriptor deprecated 

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

Deprecated: Use StartExpiringPacketStreamResponse.ProtoReflect.Descriptor instead.

func (*StartExpiringPacketStreamResponse) GetHeartbeat 

func (x *StartExpiringPacketStreamResponse) GetHeartbeat() *Heartbeat

func (*StartExpiringPacketStreamResponse) ProtoMessage 

func (*StartExpiringPacketStreamResponse) ProtoMessage()

func (*StartExpiringPacketStreamResponse) ProtoReflect 

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

func (*StartExpiringPacketStreamResponse) Reset 

func (x *StartExpiringPacketStreamResponse) Reset()

func (*StartExpiringPacketStreamResponse) String 

func (x *StartExpiringPacketStreamResponse) String() string

type StateAuctionBidRejected 

type StateAuctionBidRejected struct {

	// Auction's unique identifier.
	AuctionId string `protobuf:"bytes,1,opt,name=auction_id,json=auctionId,proto3" json:"auction_id,omitempty"`
	// Bundle's simulated bid.
	SimulatedBidLamports uint64  `protobuf:"varint,2,opt,name=simulated_bid_lamports,json=simulatedBidLamports,proto3" json:"simulated_bid_lamports,omitempty"`
	Msg                  *string `protobuf:"bytes,3,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Indicates the bundle's bid was __not__ high enough to be included in its state auction's set of winners.

func (*StateAuctionBidRejected) Descriptor deprecated 

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

Deprecated: Use StateAuctionBidRejected.ProtoReflect.Descriptor instead.

func (*StateAuctionBidRejected) GetAuctionId 

func (x *StateAuctionBidRejected) GetAuctionId() string

func (*StateAuctionBidRejected) GetMsg 

func (x *StateAuctionBidRejected) GetMsg() string

func (*StateAuctionBidRejected) GetSimulatedBidLamports 

func (x *StateAuctionBidRejected) GetSimulatedBidLamports() uint64

func (*StateAuctionBidRejected) ProtoMessage 

func (*StateAuctionBidRejected) ProtoMessage()

func (*StateAuctionBidRejected) ProtoReflect 

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

func (*StateAuctionBidRejected) Reset 

func (x *StateAuctionBidRejected) Reset()

func (*StateAuctionBidRejected) String 

func (x *StateAuctionBidRejected) 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 SubscribeBundlesRequest 

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

func (*SubscribeBundlesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeBundlesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeBundlesRequest) ProtoMessage 

func (*SubscribeBundlesRequest) ProtoMessage()

func (*SubscribeBundlesRequest) ProtoReflect 

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

func (*SubscribeBundlesRequest) Reset 

func (x *SubscribeBundlesRequest) Reset()

func (*SubscribeBundlesRequest) String 

func (x *SubscribeBundlesRequest) String() string

type SubscribeBundlesResponse 

type SubscribeBundlesResponse struct {
	Bundles []*BundleUuid `protobuf:"bytes,1,rep,name=bundles,proto3" json:"bundles,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeBundlesResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeBundlesResponse.ProtoReflect.Descriptor instead.

func (*SubscribeBundlesResponse) GetBundles 

func (x *SubscribeBundlesResponse) GetBundles() []*BundleUuid

func (*SubscribeBundlesResponse) ProtoMessage 

func (*SubscribeBundlesResponse) ProtoMessage()

func (*SubscribeBundlesResponse) ProtoReflect 

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

func (*SubscribeBundlesResponse) Reset 

func (x *SubscribeBundlesResponse) Reset()

func (*SubscribeBundlesResponse) String 

func (x *SubscribeBundlesResponse) String() string

type SubscribePacketsRequest 

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

func (*SubscribePacketsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribePacketsRequest.ProtoReflect.Descriptor instead.

func (*SubscribePacketsRequest) ProtoMessage 

func (*SubscribePacketsRequest) ProtoMessage()

func (*SubscribePacketsRequest) ProtoReflect 

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

func (*SubscribePacketsRequest) Reset 

func (x *SubscribePacketsRequest) Reset()

func (*SubscribePacketsRequest) String 

func (x *SubscribePacketsRequest) String() string

type SubscribePacketsRequestRelayer 

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

func (*SubscribePacketsRequestRelayer) Descriptor deprecated 

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

Deprecated: Use SubscribePacketsRequest.ProtoReflect.Descriptor instead.

func (*SubscribePacketsRequestRelayer) ProtoMessage 

func (*SubscribePacketsRequestRelayer) ProtoMessage()

func (*SubscribePacketsRequestRelayer) ProtoReflect 

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

func (*SubscribePacketsRequestRelayer) Reset 

func (x *SubscribePacketsRequestRelayer) Reset()

func (*SubscribePacketsRequestRelayer) String 

func (x *SubscribePacketsRequestRelayer) String() string

type SubscribePacketsResponse 

type SubscribePacketsResponse struct {
	Header *Header      `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Batch  *PacketBatch `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribePacketsResponse) Descriptor deprecated 

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

Deprecated: Use SubscribePacketsResponse.ProtoReflect.Descriptor instead.

func (*SubscribePacketsResponse) GetBatch 

func (x *SubscribePacketsResponse) GetBatch() *PacketBatch

func (*SubscribePacketsResponse) GetHeader 

func (x *SubscribePacketsResponse) GetHeader() *Header

func (*SubscribePacketsResponse) ProtoMessage 

func (*SubscribePacketsResponse) ProtoMessage()

func (*SubscribePacketsResponse) ProtoReflect 

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

func (*SubscribePacketsResponse) Reset 

func (x *SubscribePacketsResponse) Reset()

func (*SubscribePacketsResponse) String 

func (x *SubscribePacketsResponse) String() string

type SubscribePacketsResponseRelayer 

type SubscribePacketsResponseRelayer struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Types that are assignable to Msg:
	//
	//	*SubscribePacketsResponse_Heartbeat
	//	*SubscribePacketsResponse_Batch
	Msg isSubscribePacketsResponse_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*SubscribePacketsResponseRelayer) Descriptor deprecated 

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

Deprecated: Use SubscribePacketsResponse.ProtoReflect.Descriptor instead.

func (*SubscribePacketsResponseRelayer) GetBatch 

func (x *SubscribePacketsResponseRelayer) GetBatch() *PacketBatch

func (*SubscribePacketsResponseRelayer) GetHeader 

func (x *SubscribePacketsResponseRelayer) GetHeader() *Header

func (*SubscribePacketsResponseRelayer) GetHeartbeat 

func (x *SubscribePacketsResponseRelayer) GetHeartbeat() *Heartbeat

func (*SubscribePacketsResponseRelayer) GetMsg 

func (m *SubscribePacketsResponseRelayer) GetMsg() isSubscribePacketsResponse_Msg

func (*SubscribePacketsResponseRelayer) ProtoMessage 

func (*SubscribePacketsResponseRelayer) ProtoMessage()

func (*SubscribePacketsResponseRelayer) ProtoReflect 

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

func (*SubscribePacketsResponseRelayer) Reset 

func (x *SubscribePacketsResponseRelayer) Reset()

func (*SubscribePacketsResponseRelayer) String 

func (x *SubscribePacketsResponseRelayer) String() string

type SubscribePacketsResponse_Batch 

type SubscribePacketsResponse_Batch struct {
	Batch *PacketBatch `protobuf:"bytes,3,opt,name=batch,proto3,oneof"`
}

type SubscribePacketsResponse_Heartbeat 

type SubscribePacketsResponse_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,2,opt,name=heartbeat,proto3,oneof"`
}

type Token 

type Token struct {

	// / The token.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// / When the token will expire.
	ExpiresAtUtc *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at_utc,json=expiresAtUtc,proto3" json:"expires_at_utc,omitempty"`
	// contains filtered or unexported fields
}

func (*Token) Descriptor deprecated 

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

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetExpiresAtUtc 

func (x *Token) GetExpiresAtUtc() *timestamppb.Timestamp

func (*Token) GetValue 

func (x *Token) GetValue() string

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) ProtoReflect 

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

func (*Token) Reset 

func (x *Token) Reset()

func (*Token) String 

func (x *Token) String() string

type TraceShred 

type TraceShred struct {

	// source region, one of: https://jito-labs.gitbook.io/mev/systems/connecting/mainnet
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// timestamp of creation
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// monotonically increases, resets upon service restart
	SeqNum uint32 `protobuf:"varint,3,opt,name=seq_num,json=seqNum,proto3" json:"seq_num,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceShred) Descriptor deprecated 

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

Deprecated: Use TraceShred.ProtoReflect.Descriptor instead.

func (*TraceShred) GetCreatedAt 

func (x *TraceShred) GetCreatedAt() *timestamppb.Timestamp

func (*TraceShred) GetRegion 

func (x *TraceShred) GetRegion() string

func (*TraceShred) GetSeqNum 

func (x *TraceShred) GetSeqNum() uint32

func (*TraceShred) ProtoMessage 

func (*TraceShred) ProtoMessage()

func (*TraceShred) ProtoReflect 

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

func (*TraceShred) Reset 

func (x *TraceShred) Reset()

func (*TraceShred) String 

func (x *TraceShred) String() string

type UnimplementedAuthServiceServer 

type UnimplementedAuthServiceServer struct {
}

UnimplementedAuthServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAuthServiceServer) GenerateAuthChallenge 

func (UnimplementedAuthServiceServer) GenerateAuthChallenge(context.Context, *GenerateAuthChallengeRequest) (*GenerateAuthChallengeResponse, error)

func (UnimplementedAuthServiceServer) GenerateAuthTokens 

func (UnimplementedAuthServiceServer) GenerateAuthTokens(context.Context, *GenerateAuthTokensRequest) (*GenerateAuthTokensResponse, error)

func (UnimplementedAuthServiceServer) RefreshAccessToken 

func (UnimplementedAuthServiceServer) RefreshAccessToken(context.Context, *RefreshAccessTokenRequest) (*RefreshAccessTokenResponse, error)

type UnimplementedBlockEngineRelayerServer 

type UnimplementedBlockEngineRelayerServer struct {
}

UnimplementedBlockEngineRelayerServer must be embedded to have forward compatible implementations.

func (UnimplementedBlockEngineRelayerServer) StartExpiringPacketStream 

func (UnimplementedBlockEngineRelayerServer) StartExpiringPacketStream(BlockEngineRelayer_StartExpiringPacketStreamServer) error

func (UnimplementedBlockEngineRelayerServer) SubscribeAccountsOfInterest 

func (UnimplementedBlockEngineRelayerServer) SubscribeAccountsOfInterest(*AccountsOfInterestRequest, BlockEngineRelayer_SubscribeAccountsOfInterestServer) error

func (UnimplementedBlockEngineRelayerServer) SubscribeProgramsOfInterest 

func (UnimplementedBlockEngineRelayerServer) SubscribeProgramsOfInterest(*ProgramsOfInterestRequest, BlockEngineRelayer_SubscribeProgramsOfInterestServer) error

type UnimplementedBlockEngineValidatorServer 

type UnimplementedBlockEngineValidatorServer struct {
}

UnimplementedBlockEngineValidatorServer must be embedded to have forward compatible implementations.

func (UnimplementedBlockEngineValidatorServer) GetBlockBuilderFeeInfo 

func (UnimplementedBlockEngineValidatorServer) GetBlockBuilderFeeInfo(context.Context, *BlockBuilderFeeInfoRequest) (*BlockBuilderFeeInfoResponse, error)

func (UnimplementedBlockEngineValidatorServer) SubscribeBundles 

func (UnimplementedBlockEngineValidatorServer) SubscribeBundles(*SubscribeBundlesRequest, BlockEngineValidator_SubscribeBundlesServer) error

func (UnimplementedBlockEngineValidatorServer) SubscribePackets 

func (UnimplementedBlockEngineValidatorServer) SubscribePackets(*SubscribePacketsRequest, BlockEngineValidator_SubscribePacketsServer) error

type UnimplementedRelayerServer 

type UnimplementedRelayerServer struct {
}

UnimplementedRelayerServer must be embedded to have forward compatible implementations.

func (UnimplementedRelayerServer) GetTpuConfigs 

func (UnimplementedRelayerServer) GetTpuConfigs(context.Context, *GetTpuConfigsRequest) (*GetTpuConfigsResponse, error)

func (UnimplementedRelayerServer) SubscribePackets 

func (UnimplementedRelayerServer) SubscribePackets(*SubscribePacketsRequest, Relayer_SubscribePacketsServer) error

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 UnimplementedShredstreamServer 

type UnimplementedShredstreamServer struct {
}

UnimplementedShredstreamServer must be embedded to have forward compatible implementations.

func (UnimplementedShredstreamServer) SendHeartbeat 

func (UnimplementedShredstreamServer) SendHeartbeat(context.Context, *Heartbeat) (*HeartbeatResponse, error)

type UnsafeAuthServiceServer 

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

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

type UnsafeBlockEngineRelayerServer 

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

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

type UnsafeBlockEngineValidatorServer 

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

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

type UnsafeRelayerServer 

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

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

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 UnsafeShredstreamServer 

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

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

type WinningBatchBidRejected 

type WinningBatchBidRejected struct {

	// Auction's unique identifier.
	AuctionId string `protobuf:"bytes,1,opt,name=auction_id,json=auctionId,proto3" json:"auction_id,omitempty"`
	// Bundle's simulated bid.
	SimulatedBidLamports uint64  `protobuf:"varint,2,opt,name=simulated_bid_lamports,json=simulatedBidLamports,proto3" json:"simulated_bid_lamports,omitempty"`
	Msg                  *string `protobuf:"bytes,3,opt,name=msg,proto3,oneof" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Indicates the bundle's bid was high enough to win its state auction. However, not high enough relative to other state auction winners and therefore excluded from being forwarded.

func (*WinningBatchBidRejected) Descriptor deprecated 

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

Deprecated: Use WinningBatchBidRejected.ProtoReflect.Descriptor instead.

func (*WinningBatchBidRejected) GetAuctionId 

func (x *WinningBatchBidRejected) GetAuctionId() string

func (*WinningBatchBidRejected) GetMsg 

func (x *WinningBatchBidRejected) GetMsg() string

func (*WinningBatchBidRejected) GetSimulatedBidLamports 

func (x *WinningBatchBidRejected) GetSimulatedBidLamports() uint64

func (*WinningBatchBidRejected) ProtoMessage 

func (*WinningBatchBidRejected) ProtoMessage()

func (*WinningBatchBidRejected) ProtoReflect 

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

func (*WinningBatchBidRejected) Reset 

func (x *WinningBatchBidRejected) Reset()

func (*WinningBatchBidRejected) String 

func (x *WinningBatchBidRejected) String() string

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.