proto

package
v0.0.0-...-58d048d Latest Latest
Warning

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

 Go to latest Published: Aug 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 (
	Geyser_GetHeartbeatInterval_FullMethodName           = "/solana.geyser.Geyser/GetHeartbeatInterval"
	Geyser_SubscribeAccountUpdates_FullMethodName        = "/solana.geyser.Geyser/SubscribeAccountUpdates"
	Geyser_SubscribeProgramUpdates_FullMethodName        = "/solana.geyser.Geyser/SubscribeProgramUpdates"
	Geyser_SubscribePartialAccountUpdates_FullMethodName = "/solana.geyser.Geyser/SubscribePartialAccountUpdates"
	Geyser_SubscribeSlotUpdates_FullMethodName           = "/solana.geyser.Geyser/SubscribeSlotUpdates"
	Geyser_SubscribeTransactionUpdates_FullMethodName    = "/solana.geyser.Geyser/SubscribeTransactionUpdates"
	Geyser_SubscribeBlockUpdates_FullMethodName          = "/solana.geyser.Geyser/SubscribeBlockUpdates"
)
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 (
	RewardType_name = map[int32]string{
		0: "Unspecified",
		1: "Fee",
		2: "Rent",
		3: "Staking",
		4: "Voting",
	}
	RewardType_value = map[string]int32{
		"Unspecified": 0,
		"Fee":         1,
		"Rent":        2,
		"Staking":     3,
		"Voting":      4,
	}
)

Enum value maps for RewardType.

View Source 
var (
	SlotUpdateStatus_name = map[int32]string{
		0: "CONFIRMED",
		1: "PROCESSED",
		2: "ROOTED",
	}
	SlotUpdateStatus_value = map[string]int32{
		"CONFIRMED": 0,
		"PROCESSED": 1,
		"ROOTED":    2,
	}
)

Enum value maps for SlotUpdateStatus.

View Source 
var (
	TransactionErrorType_name = map[int32]string{
		0:  "ACCOUNT_IN_USE",
		1:  "ACCOUNT_LOADED_TWICE",
		2:  "ACCOUNT_NOT_FOUND",
		3:  "PROGRAM_ACCOUNT_NOT_FOUND",
		4:  "INSUFFICIENT_FUNDS_FOR_FEE",
		5:  "INVALID_ACCOUNT_FOR_FEE",
		6:  "ALREADY_PROCESSED",
		7:  "BLOCKHASH_NOT_FOUND",
		8:  "INSTRUCTION_ERROR",
		9:  "CALL_CHAIN_TOO_DEEP",
		10: "MISSING_SIGNATURE_FOR_FEE",
		11: "INVALID_ACCOUNT_INDEX",
		12: "SIGNATURE_FAILURE",
		13: "INVALID_PROGRAM_FOR_EXECUTION",
		14: "SANITIZE_FAILURE",
		15: "CLUSTER_MAINTENANCE",
		16: "ACCOUNT_BORROW_OUTSTANDING_TX",
		17: "WOULD_EXCEED_MAX_BLOCK_COST_LIMIT",
		18: "UNSUPPORTED_VERSION",
		19: "INVALID_WRITABLE_ACCOUNT",
		20: "WOULD_EXCEED_MAX_ACCOUNT_COST_LIMIT",
		21: "WOULD_EXCEED_ACCOUNT_DATA_BLOCK_LIMIT",
		22: "TOO_MANY_ACCOUNT_LOCKS",
		23: "ADDRESS_LOOKUP_TABLE_NOT_FOUND",
		24: "INVALID_ADDRESS_LOOKUP_TABLE_OWNER",
		25: "INVALID_ADDRESS_LOOKUP_TABLE_DATA",
		26: "INVALID_ADDRESS_LOOKUP_TABLE_INDEX",
		27: "INVALID_RENT_PAYING_ACCOUNT",
		28: "WOULD_EXCEED_MAX_VOTE_COST_LIMIT",
		29: "WOULD_EXCEED_ACCOUNT_DATA_TOTAL_LIMIT",
		30: "DUPLICATE_INSTRUCTION",
		31: "INSUFFICIENT_FUNDS_FOR_RENT",
		32: "MAX_LOADED_ACCOUNTS_DATA_SIZE_EXCEEDED",
		33: "INVALID_LOADED_ACCOUNTS_DATA_SIZE_LIMIT",
		34: "RESANITIZATION_NEEDED",
		35: "PROGRAM_EXECUTION_TEMPORARILY_RESTRICTED",
		36: "UNBALANCED_TRANSACTION",
	}
	TransactionErrorType_value = map[string]int32{
		"ACCOUNT_IN_USE":                           0,
		"ACCOUNT_LOADED_TWICE":                     1,
		"ACCOUNT_NOT_FOUND":                        2,
		"PROGRAM_ACCOUNT_NOT_FOUND":                3,
		"INSUFFICIENT_FUNDS_FOR_FEE":               4,
		"INVALID_ACCOUNT_FOR_FEE":                  5,
		"ALREADY_PROCESSED":                        6,
		"BLOCKHASH_NOT_FOUND":                      7,
		"INSTRUCTION_ERROR":                        8,
		"CALL_CHAIN_TOO_DEEP":                      9,
		"MISSING_SIGNATURE_FOR_FEE":                10,
		"INVALID_ACCOUNT_INDEX":                    11,
		"SIGNATURE_FAILURE":                        12,
		"INVALID_PROGRAM_FOR_EXECUTION":            13,
		"SANITIZE_FAILURE":                         14,
		"CLUSTER_MAINTENANCE":                      15,
		"ACCOUNT_BORROW_OUTSTANDING_TX":            16,
		"WOULD_EXCEED_MAX_BLOCK_COST_LIMIT":        17,
		"UNSUPPORTED_VERSION":                      18,
		"INVALID_WRITABLE_ACCOUNT":                 19,
		"WOULD_EXCEED_MAX_ACCOUNT_COST_LIMIT":      20,
		"WOULD_EXCEED_ACCOUNT_DATA_BLOCK_LIMIT":    21,
		"TOO_MANY_ACCOUNT_LOCKS":                   22,
		"ADDRESS_LOOKUP_TABLE_NOT_FOUND":           23,
		"INVALID_ADDRESS_LOOKUP_TABLE_OWNER":       24,
		"INVALID_ADDRESS_LOOKUP_TABLE_DATA":        25,
		"INVALID_ADDRESS_LOOKUP_TABLE_INDEX":       26,
		"INVALID_RENT_PAYING_ACCOUNT":              27,
		"WOULD_EXCEED_MAX_VOTE_COST_LIMIT":         28,
		"WOULD_EXCEED_ACCOUNT_DATA_TOTAL_LIMIT":    29,
		"DUPLICATE_INSTRUCTION":                    30,
		"INSUFFICIENT_FUNDS_FOR_RENT":              31,
		"MAX_LOADED_ACCOUNTS_DATA_SIZE_EXCEEDED":   32,
		"INVALID_LOADED_ACCOUNTS_DATA_SIZE_LIMIT":  33,
		"RESANITIZATION_NEEDED":                    34,
		"PROGRAM_EXECUTION_TEMPORARILY_RESTRICTED": 35,
		"UNBALANCED_TRANSACTION":                   36,
	}
)

Enum value maps for TransactionErrorType.

View Source 
var (
	InstructionErrorType_name = map[int32]string{
		0:  "GENERIC_ERROR",
		1:  "INVALID_ARGUMENT",
		2:  "INVALID_INSTRUCTION_DATA",
		3:  "INVALID_ACCOUNT_DATA",
		4:  "ACCOUNT_DATA_TOO_SMALL",
		5:  "INSUFFICIENT_FUNDS",
		6:  "INCORRECT_PROGRAM_ID",
		7:  "MISSING_REQUIRED_SIGNATURE",
		8:  "ACCOUNT_ALREADY_INITIALIZED",
		9:  "UNINITIALIZED_ACCOUNT",
		10: "UNBALANCED_INSTRUCTION",
		11: "MODIFIED_PROGRAM_ID",
		12: "EXTERNAL_ACCOUNT_LAMPORT_SPEND",
		13: "EXTERNAL_ACCOUNT_DATA_MODIFIED",
		14: "READONLY_LAMPORT_CHANGE",
		15: "READONLY_DATA_MODIFIED",
		16: "DUPLICATE_ACCOUNT_INDEX",
		17: "EXECUTABLE_MODIFIED",
		18: "RENT_EPOCH_MODIFIED",
		19: "NOT_ENOUGH_ACCOUNT_KEYS",
		20: "ACCOUNT_DATA_SIZE_CHANGED",
		21: "ACCOUNT_NOT_EXECUTABLE",
		22: "ACCOUNT_BORROW_FAILED",
		23: "ACCOUNT_BORROW_OUTSTANDING",
		24: "DUPLICATE_ACCOUNT_OUT_OF_SYNC",
		25: "CUSTOM",
		26: "INVALID_ERROR",
		27: "EXECUTABLE_DATA_MODIFIED",
		28: "EXECUTABLE_LAMPORT_CHANGE",
		29: "EXECUTABLE_ACCOUNT_NOT_RENT_EXEMPT",
		30: "UNSUPPORTED_PROGRAM_ID",
		31: "CALL_DEPTH",
		32: "MISSING_ACCOUNT",
		33: "REENTRANCY_NOT_ALLOWED",
		34: "MAX_SEED_LENGTH_EXCEEDED",
		35: "INVALID_SEEDS",
		36: "INVALID_REALLOC",
		37: "COMPUTATIONAL_BUDGET_EXCEEDED",
		38: "PRIVILEGE_ESCALATION",
		39: "PROGRAM_ENVIRONMENT_SETUP_FAILURE",
		40: "PROGRAM_FAILED_TO_COMPLETE",
		41: "PROGRAM_FAILED_TO_COMPILE",
		42: "IMMUTABLE",
		43: "INCORRECT_AUTHORITY",
		44: "BORSH_IO_ERROR",
		45: "ACCOUNT_NOT_RENT_EXEMPT",
		46: "INVALID_ACCOUNT_OWNER",
		47: "ARITHMETIC_OVERFLOW",
		48: "UNSUPPORTED_SYSVAR",
		49: "ILLEGAL_OWNER",
		50: "MAX_ACCOUNTS_DATA_ALLOCATIONS_EXCEEDED",
		51: "MAX_ACCOUNTS_EXCEEDED",
		52: "MAX_INSTRUCTION_TRACE_LENGTH_EXCEEDED",
		53: "BUILTIN_PROGRAMS_MUST_CONSUME_COMPUTE_UNITS",
	}
	InstructionErrorType_value = map[string]int32{
		"GENERIC_ERROR":                               0,
		"INVALID_ARGUMENT":                            1,
		"INVALID_INSTRUCTION_DATA":                    2,
		"INVALID_ACCOUNT_DATA":                        3,
		"ACCOUNT_DATA_TOO_SMALL":                      4,
		"INSUFFICIENT_FUNDS":                          5,
		"INCORRECT_PROGRAM_ID":                        6,
		"MISSING_REQUIRED_SIGNATURE":                  7,
		"ACCOUNT_ALREADY_INITIALIZED":                 8,
		"UNINITIALIZED_ACCOUNT":                       9,
		"UNBALANCED_INSTRUCTION":                      10,
		"MODIFIED_PROGRAM_ID":                         11,
		"EXTERNAL_ACCOUNT_LAMPORT_SPEND":              12,
		"EXTERNAL_ACCOUNT_DATA_MODIFIED":              13,
		"READONLY_LAMPORT_CHANGE":                     14,
		"READONLY_DATA_MODIFIED":                      15,
		"DUPLICATE_ACCOUNT_INDEX":                     16,
		"EXECUTABLE_MODIFIED":                         17,
		"RENT_EPOCH_MODIFIED":                         18,
		"NOT_ENOUGH_ACCOUNT_KEYS":                     19,
		"ACCOUNT_DATA_SIZE_CHANGED":                   20,
		"ACCOUNT_NOT_EXECUTABLE":                      21,
		"ACCOUNT_BORROW_FAILED":                       22,
		"ACCOUNT_BORROW_OUTSTANDING":                  23,
		"DUPLICATE_ACCOUNT_OUT_OF_SYNC":               24,
		"CUSTOM":                                      25,
		"INVALID_ERROR":                               26,
		"EXECUTABLE_DATA_MODIFIED":                    27,
		"EXECUTABLE_LAMPORT_CHANGE":                   28,
		"EXECUTABLE_ACCOUNT_NOT_RENT_EXEMPT":          29,
		"UNSUPPORTED_PROGRAM_ID":                      30,
		"CALL_DEPTH":                                  31,
		"MISSING_ACCOUNT":                             32,
		"REENTRANCY_NOT_ALLOWED":                      33,
		"MAX_SEED_LENGTH_EXCEEDED":                    34,
		"INVALID_SEEDS":                               35,
		"INVALID_REALLOC":                             36,
		"COMPUTATIONAL_BUDGET_EXCEEDED":               37,
		"PRIVILEGE_ESCALATION":                        38,
		"PROGRAM_ENVIRONMENT_SETUP_FAILURE":           39,
		"PROGRAM_FAILED_TO_COMPLETE":                  40,
		"PROGRAM_FAILED_TO_COMPILE":                   41,
		"IMMUTABLE":                                   42,
		"INCORRECT_AUTHORITY":                         43,
		"BORSH_IO_ERROR":                              44,
		"ACCOUNT_NOT_RENT_EXEMPT":                     45,
		"INVALID_ACCOUNT_OWNER":                       46,
		"ARITHMETIC_OVERFLOW":                         47,
		"UNSUPPORTED_SYSVAR":                          48,
		"ILLEGAL_OWNER":                               49,
		"MAX_ACCOUNTS_DATA_ALLOCATIONS_EXCEEDED":      50,
		"MAX_ACCOUNTS_EXCEEDED":                       51,
		"MAX_INSTRUCTION_TRACE_LENGTH_EXCEEDED":       52,
		"BUILTIN_PROGRAMS_MUST_CONSUME_COMPUTE_UNITS": 53,
	}
)

Enum value maps for InstructionErrorType.

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_confirmed_block_proto protoreflect.FileDescriptor
View Source 
var File_geyser_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 File_transaction_by_addr_proto protoreflect.FileDescriptor
View Source 
var Geyser_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "solana.geyser.Geyser",
	HandlerType: (*GeyserServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetHeartbeatInterval",
			Handler:    _Geyser_GetHeartbeatInterval_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeAccountUpdates",
			Handler:       _Geyser_SubscribeAccountUpdates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeProgramUpdates",
			Handler:       _Geyser_SubscribeProgramUpdates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribePartialAccountUpdates",
			Handler:       _Geyser_SubscribePartialAccountUpdates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeSlotUpdates",
			Handler:       _Geyser_SubscribeSlotUpdates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeTransactionUpdates",
			Handler:       _Geyser_SubscribeTransactionUpdates_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBlockUpdates",
			Handler:       _Geyser_SubscribeBlockUpdates_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "geyser.proto",
}

Geyser_ServiceDesc is the grpc.ServiceDesc for Geyser 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 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 RegisterGeyserServer 

func RegisterGeyserServer(s grpc.ServiceRegistrar, srv GeyserServer)

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 AccountUpdate 

type AccountUpdate struct {

	// Slot this update occurred.
	Slot uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	// Account's pubkey.
	Pubkey []byte `protobuf:"bytes,2,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// Account's lamports post update.
	Lamports uint64 `protobuf:"varint,3,opt,name=lamports,proto3" json:"lamports,omitempty"`
	// Account's owner.
	Owner []byte `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	// Flags whether an account is executable.
	IsExecutable bool `protobuf:"varint,5,opt,name=is_executable,json=isExecutable,proto3" json:"is_executable,omitempty"`
	// The epoch at which this account will next owe rent.
	RentEpoch uint64 `protobuf:"varint,6,opt,name=rent_epoch,json=rentEpoch,proto3" json:"rent_epoch,omitempty"`
	// Account's data post update.
	Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// A monotonically increasing number specifying the order of this update.
	// Can be used to determine what the latest update for an account was at
	// a given slot, assuming there were multiple updates.
	Seq uint64 `protobuf:"varint,8,opt,name=seq,proto3" json:"seq,omitempty"`
	// Flags whether this update was streamed as part of startup i.e. not a real-time update.
	IsStartup bool `protobuf:"varint,9,opt,name=is_startup,json=isStartup,proto3" json:"is_startup,omitempty"`
	// Transaction signature that caused this update.
	TxSignature *string `protobuf:"bytes,10,opt,name=tx_signature,json=txSignature,proto3,oneof" json:"tx_signature,omitempty"`
	// AccountReplica version.
	ReplicaVersion uint32 `protobuf:"varint,11,opt,name=replica_version,json=replicaVersion,proto3" json:"replica_version,omitempty"`
	// contains filtered or unexported fields
}

func (*AccountUpdate) Descriptor deprecated 

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

Deprecated: Use AccountUpdate.ProtoReflect.Descriptor instead.

func (*AccountUpdate) GetData 

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

func (*AccountUpdate) GetIsExecutable 

func (x *AccountUpdate) GetIsExecutable() bool

func (*AccountUpdate) GetIsStartup 

func (x *AccountUpdate) GetIsStartup() bool

func (*AccountUpdate) GetLamports 

func (x *AccountUpdate) GetLamports() uint64

func (*AccountUpdate) GetOwner 

func (x *AccountUpdate) GetOwner() []byte

func (*AccountUpdate) GetPubkey 

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

func (*AccountUpdate) GetRentEpoch 

func (x *AccountUpdate) GetRentEpoch() uint64

func (*AccountUpdate) GetReplicaVersion 

func (x *AccountUpdate) GetReplicaVersion() uint32

func (*AccountUpdate) GetSeq 

func (x *AccountUpdate) GetSeq() uint64

func (*AccountUpdate) GetSlot 

func (x *AccountUpdate) GetSlot() uint64

func (*AccountUpdate) GetTxSignature 

func (x *AccountUpdate) GetTxSignature() string

func (*AccountUpdate) ProtoMessage 

func (*AccountUpdate) ProtoMessage()

func (*AccountUpdate) ProtoReflect 

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

func (*AccountUpdate) Reset 

func (x *AccountUpdate) Reset()

func (*AccountUpdate) String 

func (x *AccountUpdate) 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 BlockHeight 

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

func (*BlockHeight) Descriptor deprecated 

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

Deprecated: Use BlockHeight.ProtoReflect.Descriptor instead.

func (*BlockHeight) GetBlockHeight 

func (x *BlockHeight) GetBlockHeight() uint64

func (*BlockHeight) ProtoMessage 

func (*BlockHeight) ProtoMessage()

func (*BlockHeight) ProtoReflect 

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

func (*BlockHeight) Reset 

func (x *BlockHeight) Reset()

func (*BlockHeight) String 

func (x *BlockHeight) String() string

type BlockUpdate 

type BlockUpdate struct {
	Slot                     uint64                 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Blockhash                string                 `protobuf:"bytes,2,opt,name=blockhash,proto3" json:"blockhash,omitempty"`
	Rewards                  []*Reward              `protobuf:"bytes,3,rep,name=rewards,proto3" json:"rewards,omitempty"`
	BlockTime                *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	BlockHeight              *uint64                `protobuf:"varint,5,opt,name=block_height,json=blockHeight,proto3,oneof" json:"block_height,omitempty"`
	ExecutedTransactionCount *uint64                `` /* 142-byte string literal not displayed */
	EntryCount               *uint64                `protobuf:"varint,7,opt,name=entry_count,json=entryCount,proto3,oneof" json:"entry_count,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockUpdate) Descriptor deprecated 

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

Deprecated: Use BlockUpdate.ProtoReflect.Descriptor instead.

func (*BlockUpdate) GetBlockHeight 

func (x *BlockUpdate) GetBlockHeight() uint64

func (*BlockUpdate) GetBlockTime 

func (x *BlockUpdate) GetBlockTime() *timestamppb.Timestamp

func (*BlockUpdate) GetBlockhash 

func (x *BlockUpdate) GetBlockhash() string

func (*BlockUpdate) GetEntryCount 

func (x *BlockUpdate) GetEntryCount() uint64

func (*BlockUpdate) GetExecutedTransactionCount 

func (x *BlockUpdate) GetExecutedTransactionCount() uint64

func (*BlockUpdate) GetRewards 

func (x *BlockUpdate) GetRewards() []*Reward

func (*BlockUpdate) GetSlot 

func (x *BlockUpdate) GetSlot() uint64

func (*BlockUpdate) ProtoMessage 

func (*BlockUpdate) ProtoMessage()

func (*BlockUpdate) ProtoReflect 

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

func (*BlockUpdate) Reset 

func (x *BlockUpdate) Reset()

func (*BlockUpdate) String 

func (x *BlockUpdate) String() string

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 CompiledInstruction 

type CompiledInstruction struct {
	ProgramIdIndex uint32 `protobuf:"varint,1,opt,name=program_id_index,json=programIdIndex,proto3" json:"program_id_index,omitempty"`
	Accounts       []byte `protobuf:"bytes,2,opt,name=accounts,proto3" json:"accounts,omitempty"`
	Data           []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CompiledInstruction) Descriptor deprecated 

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

Deprecated: Use CompiledInstruction.ProtoReflect.Descriptor instead.

func (*CompiledInstruction) GetAccounts 

func (x *CompiledInstruction) GetAccounts() []byte

func (*CompiledInstruction) GetData 

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

func (*CompiledInstruction) GetProgramIdIndex 

func (x *CompiledInstruction) GetProgramIdIndex() uint32

func (*CompiledInstruction) ProtoMessage 

func (*CompiledInstruction) ProtoMessage()

func (*CompiledInstruction) ProtoReflect 

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

func (*CompiledInstruction) Reset 

func (x *CompiledInstruction) Reset()

func (*CompiledInstruction) String 

func (x *CompiledInstruction) 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 ConfirmedBlock 

type ConfirmedBlock struct {
	PreviousBlockhash string                  `protobuf:"bytes,1,opt,name=previous_blockhash,json=previousBlockhash,proto3" json:"previous_blockhash,omitempty"`
	Blockhash         string                  `protobuf:"bytes,2,opt,name=blockhash,proto3" json:"blockhash,omitempty"`
	ParentSlot        uint64                  `protobuf:"varint,3,opt,name=parent_slot,json=parentSlot,proto3" json:"parent_slot,omitempty"`
	Transactions      []*ConfirmedTransaction `protobuf:"bytes,4,rep,name=transactions,proto3" json:"transactions,omitempty"`
	Rewards           []*Reward               `protobuf:"bytes,5,rep,name=rewards,proto3" json:"rewards,omitempty"`
	BlockTime         *UnixTimestamp          `protobuf:"bytes,6,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	BlockHeight       *BlockHeight            `protobuf:"bytes,7,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmedBlock) Descriptor deprecated 

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

Deprecated: Use ConfirmedBlock.ProtoReflect.Descriptor instead.

func (*ConfirmedBlock) GetBlockHeight 

func (x *ConfirmedBlock) GetBlockHeight() *BlockHeight

func (*ConfirmedBlock) GetBlockTime 

func (x *ConfirmedBlock) GetBlockTime() *UnixTimestamp

func (*ConfirmedBlock) GetBlockhash 

func (x *ConfirmedBlock) GetBlockhash() string

func (*ConfirmedBlock) GetParentSlot 

func (x *ConfirmedBlock) GetParentSlot() uint64

func (*ConfirmedBlock) GetPreviousBlockhash 

func (x *ConfirmedBlock) GetPreviousBlockhash() string

func (*ConfirmedBlock) GetRewards 

func (x *ConfirmedBlock) GetRewards() []*Reward

func (*ConfirmedBlock) GetTransactions 

func (x *ConfirmedBlock) GetTransactions() []*ConfirmedTransaction

func (*ConfirmedBlock) ProtoMessage 

func (*ConfirmedBlock) ProtoMessage()

func (*ConfirmedBlock) ProtoReflect 

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

func (*ConfirmedBlock) Reset 

func (x *ConfirmedBlock) Reset()

func (*ConfirmedBlock) String 

func (x *ConfirmedBlock) String() string

type ConfirmedTransaction 

type ConfirmedTransaction struct {
	Transaction *Transaction           `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Meta        *TransactionStatusMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfirmedTransaction) Descriptor deprecated 

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

Deprecated: Use ConfirmedTransaction.ProtoReflect.Descriptor instead.

func (*ConfirmedTransaction) GetMeta 

func (x *ConfirmedTransaction) GetMeta() *TransactionStatusMeta

func (*ConfirmedTransaction) GetTransaction 

func (x *ConfirmedTransaction) GetTransaction() *Transaction

func (*ConfirmedTransaction) ProtoMessage 

func (*ConfirmedTransaction) ProtoMessage()

func (*ConfirmedTransaction) ProtoReflect 

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

func (*ConfirmedTransaction) Reset 

func (x *ConfirmedTransaction) Reset()

func (*ConfirmedTransaction) String 

func (x *ConfirmedTransaction) 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 CustomError 

type CustomError struct {
	Custom uint32 `protobuf:"varint,1,opt,name=custom,proto3" json:"custom,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomError) Descriptor deprecated 

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

Deprecated: Use CustomError.ProtoReflect.Descriptor instead.

func (*CustomError) GetCustom 

func (x *CustomError) GetCustom() uint32

func (*CustomError) ProtoMessage 

func (*CustomError) ProtoMessage()

func (*CustomError) ProtoReflect 

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

func (*CustomError) Reset 

func (x *CustomError) Reset()

func (*CustomError) String 

func (x *CustomError) 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 EmptyRequest 

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

func (*EmptyRequest) Descriptor deprecated 

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

Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead.

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect 

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

func (*EmptyRequest) Reset 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (x *EmptyRequest) String() string

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 GetHeartbeatIntervalResponse 

type GetHeartbeatIntervalResponse struct {
	HeartbeatIntervalMs uint64 `protobuf:"varint,1,opt,name=heartbeat_interval_ms,json=heartbeatIntervalMs,proto3" json:"heartbeat_interval_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHeartbeatIntervalResponse) Descriptor deprecated 

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

Deprecated: Use GetHeartbeatIntervalResponse.ProtoReflect.Descriptor instead.

func (*GetHeartbeatIntervalResponse) GetHeartbeatIntervalMs 

func (x *GetHeartbeatIntervalResponse) GetHeartbeatIntervalMs() uint64

func (*GetHeartbeatIntervalResponse) ProtoMessage 

func (*GetHeartbeatIntervalResponse) ProtoMessage()

func (*GetHeartbeatIntervalResponse) ProtoReflect 

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

func (*GetHeartbeatIntervalResponse) Reset 

func (x *GetHeartbeatIntervalResponse) Reset()

func (*GetHeartbeatIntervalResponse) String 

func (x *GetHeartbeatIntervalResponse) 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 GeyserClient 

type GeyserClient interface {
	// Invoke to get the expected heartbeat interval.
	GetHeartbeatInterval(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*GetHeartbeatIntervalResponse, error)
	// Subscribes to account updates in the accounts database; additionally pings clients with empty heartbeats.
	// Upon initially connecting the client can expect a `highest_write_slot` set in the http headers.
	// Subscribe to account updates
	SubscribeAccountUpdates(ctx context.Context, in *SubscribeAccountUpdatesRequest, opts ...grpc.CallOption) (Geyser_SubscribeAccountUpdatesClient, error)
	// Subscribes to updates given a list of program IDs. When an account update comes in that's owned by a provided
	// program id, one will receive an update
	SubscribeProgramUpdates(ctx context.Context, in *SubscribeProgramsUpdatesRequest, opts ...grpc.CallOption) (Geyser_SubscribeProgramUpdatesClient, error)
	// Functions similarly to `SubscribeAccountUpdates`, but consumes less bandwidth.
	// Returns the highest slot seen thus far in the http headers named `highest-write-slot`.
	SubscribePartialAccountUpdates(ctx context.Context, in *SubscribePartialAccountUpdatesRequest, opts ...grpc.CallOption) (Geyser_SubscribePartialAccountUpdatesClient, error)
	// Subscribes to slot updates.
	// Returns the highest slot seen thus far in the http headers named `highest-write-slot`.
	SubscribeSlotUpdates(ctx context.Context, in *SubscribeSlotUpdateRequest, opts ...grpc.CallOption) (Geyser_SubscribeSlotUpdatesClient, error)
	// Subscribes to transaction updates.
	SubscribeTransactionUpdates(ctx context.Context, in *SubscribeTransactionUpdatesRequest, opts ...grpc.CallOption) (Geyser_SubscribeTransactionUpdatesClient, error)
	// Subscribes to block updates.
	SubscribeBlockUpdates(ctx context.Context, in *SubscribeBlockUpdatesRequest, opts ...grpc.CallOption) (Geyser_SubscribeBlockUpdatesClient, error)
}

GeyserClient is the client API for Geyser 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 NewGeyserClient 

func NewGeyserClient(cc grpc.ClientConnInterface) GeyserClient

type GeyserServer 

type GeyserServer interface {
	// Invoke to get the expected heartbeat interval.
	GetHeartbeatInterval(context.Context, *EmptyRequest) (*GetHeartbeatIntervalResponse, error)
	// Subscribes to account updates in the accounts database; additionally pings clients with empty heartbeats.
	// Upon initially connecting the client can expect a `highest_write_slot` set in the http headers.
	// Subscribe to account updates
	SubscribeAccountUpdates(*SubscribeAccountUpdatesRequest, Geyser_SubscribeAccountUpdatesServer) error
	// Subscribes to updates given a list of program IDs. When an account update comes in that's owned by a provided
	// program id, one will receive an update
	SubscribeProgramUpdates(*SubscribeProgramsUpdatesRequest, Geyser_SubscribeProgramUpdatesServer) error
	// Functions similarly to `SubscribeAccountUpdates`, but consumes less bandwidth.
	// Returns the highest slot seen thus far in the http headers named `highest-write-slot`.
	SubscribePartialAccountUpdates(*SubscribePartialAccountUpdatesRequest, Geyser_SubscribePartialAccountUpdatesServer) error
	// Subscribes to slot updates.
	// Returns the highest slot seen thus far in the http headers named `highest-write-slot`.
	SubscribeSlotUpdates(*SubscribeSlotUpdateRequest, Geyser_SubscribeSlotUpdatesServer) error
	// Subscribes to transaction updates.
	SubscribeTransactionUpdates(*SubscribeTransactionUpdatesRequest, Geyser_SubscribeTransactionUpdatesServer) error
	// Subscribes to block updates.
	SubscribeBlockUpdates(*SubscribeBlockUpdatesRequest, Geyser_SubscribeBlockUpdatesServer) error
	// contains filtered or unexported methods
}

GeyserServer is the server API for Geyser service. All implementations must embed UnimplementedGeyserServer for forward compatibility

type Geyser_SubscribeAccountUpdatesClient 

type Geyser_SubscribeAccountUpdatesClient interface {
	Recv() (*TimestampedAccountUpdate, error)
	grpc.ClientStream
}

type Geyser_SubscribeAccountUpdatesServer 

type Geyser_SubscribeAccountUpdatesServer interface {
	Send(*TimestampedAccountUpdate) error
	grpc.ServerStream
}

type Geyser_SubscribeBlockUpdatesClient 

type Geyser_SubscribeBlockUpdatesClient interface {
	Recv() (*TimestampedBlockUpdate, error)
	grpc.ClientStream
}

type Geyser_SubscribeBlockUpdatesServer 

type Geyser_SubscribeBlockUpdatesServer interface {
	Send(*TimestampedBlockUpdate) error
	grpc.ServerStream
}

type Geyser_SubscribePartialAccountUpdatesClient 

type Geyser_SubscribePartialAccountUpdatesClient interface {
	Recv() (*MaybePartialAccountUpdate, error)
	grpc.ClientStream
}

type Geyser_SubscribePartialAccountUpdatesServer 

type Geyser_SubscribePartialAccountUpdatesServer interface {
	Send(*MaybePartialAccountUpdate) error
	grpc.ServerStream
}

type Geyser_SubscribeProgramUpdatesClient 

type Geyser_SubscribeProgramUpdatesClient interface {
	Recv() (*TimestampedAccountUpdate, error)
	grpc.ClientStream
}

type Geyser_SubscribeProgramUpdatesServer 

type Geyser_SubscribeProgramUpdatesServer interface {
	Send(*TimestampedAccountUpdate) error
	grpc.ServerStream
}

type Geyser_SubscribeSlotUpdatesClient 

type Geyser_SubscribeSlotUpdatesClient interface {
	Recv() (*TimestampedSlotUpdate, error)
	grpc.ClientStream
}

type Geyser_SubscribeSlotUpdatesServer 

type Geyser_SubscribeSlotUpdatesServer interface {
	Send(*TimestampedSlotUpdate) error
	grpc.ServerStream
}

type Geyser_SubscribeTransactionUpdatesClient 

type Geyser_SubscribeTransactionUpdatesClient interface {
	Recv() (*TimestampedTransactionUpdate, error)
	grpc.ClientStream
}

type Geyser_SubscribeTransactionUpdatesServer 

type Geyser_SubscribeTransactionUpdatesServer interface {
	Send(*TimestampedTransactionUpdate) error
	grpc.ServerStream
}
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 HeartbeatGeyser 

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

func (*HeartbeatGeyser) Descriptor deprecated 

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

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*HeartbeatGeyser) ProtoMessage 

func (*HeartbeatGeyser) ProtoMessage()

func (*HeartbeatGeyser) ProtoReflect 

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

func (*HeartbeatGeyser) Reset 

func (x *HeartbeatGeyser) Reset()

func (*HeartbeatGeyser) String 

func (x *HeartbeatGeyser) 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 InnerInstruction 

type InnerInstruction struct {
	ProgramIdIndex uint32 `protobuf:"varint,1,opt,name=program_id_index,json=programIdIndex,proto3" json:"program_id_index,omitempty"`
	Accounts       []byte `protobuf:"bytes,2,opt,name=accounts,proto3" json:"accounts,omitempty"`
	Data           []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// Invocation stack height of an inner instruction.
	// Available since Solana v1.14.6
	// Set to `None` for txs executed on earlier versions.
	StackHeight *uint32 `protobuf:"varint,4,opt,name=stack_height,json=stackHeight,proto3,oneof" json:"stack_height,omitempty"`
	// contains filtered or unexported fields
}

func (*InnerInstruction) Descriptor deprecated 

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

Deprecated: Use InnerInstruction.ProtoReflect.Descriptor instead.

func (*InnerInstruction) GetAccounts 

func (x *InnerInstruction) GetAccounts() []byte

func (*InnerInstruction) GetData 

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

func (*InnerInstruction) GetProgramIdIndex 

func (x *InnerInstruction) GetProgramIdIndex() uint32

func (*InnerInstruction) GetStackHeight 

func (x *InnerInstruction) GetStackHeight() uint32

func (*InnerInstruction) ProtoMessage 

func (*InnerInstruction) ProtoMessage()

func (*InnerInstruction) ProtoReflect 

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

func (*InnerInstruction) Reset 

func (x *InnerInstruction) Reset()

func (*InnerInstruction) String 

func (x *InnerInstruction) String() string

type InnerInstructions 

type InnerInstructions struct {
	Index        uint32              `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Instructions []*InnerInstruction `protobuf:"bytes,2,rep,name=instructions,proto3" json:"instructions,omitempty"`
	// contains filtered or unexported fields
}

func (*InnerInstructions) Descriptor deprecated 

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

Deprecated: Use InnerInstructions.ProtoReflect.Descriptor instead.

func (*InnerInstructions) GetIndex 

func (x *InnerInstructions) GetIndex() uint32

func (*InnerInstructions) GetInstructions 

func (x *InnerInstructions) GetInstructions() []*InnerInstruction

func (*InnerInstructions) ProtoMessage 

func (*InnerInstructions) ProtoMessage()

func (*InnerInstructions) ProtoReflect 

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

func (*InnerInstructions) Reset 

func (x *InnerInstructions) Reset()

func (*InnerInstructions) String 

func (x *InnerInstructions) String() string

type InstructionError 

type InstructionError struct {
	Index  uint32               `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Error  InstructionErrorType `protobuf:"varint,2,opt,name=error,proto3,enum=solana.storage.TransactionByAddr.InstructionErrorType" json:"error,omitempty"`
	Custom *CustomError         `protobuf:"bytes,3,opt,name=custom,proto3" json:"custom,omitempty"`
	// contains filtered or unexported fields
}

func (*InstructionError) Descriptor deprecated 

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

Deprecated: Use InstructionError.ProtoReflect.Descriptor instead.

func (*InstructionError) GetCustom 

func (x *InstructionError) GetCustom() *CustomError

func (*InstructionError) GetError 

func (x *InstructionError) GetError() InstructionErrorType

func (*InstructionError) GetIndex 

func (x *InstructionError) GetIndex() uint32

func (*InstructionError) ProtoMessage 

func (*InstructionError) ProtoMessage()

func (*InstructionError) ProtoReflect 

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

func (*InstructionError) Reset 

func (x *InstructionError) Reset()

func (*InstructionError) String 

func (x *InstructionError) String() string

type InstructionErrorType 

type InstructionErrorType int32
const (
	InstructionErrorType_GENERIC_ERROR                               InstructionErrorType = 0
	InstructionErrorType_INVALID_ARGUMENT                            InstructionErrorType = 1
	InstructionErrorType_INVALID_INSTRUCTION_DATA                    InstructionErrorType = 2
	InstructionErrorType_INVALID_ACCOUNT_DATA                        InstructionErrorType = 3
	InstructionErrorType_ACCOUNT_DATA_TOO_SMALL                      InstructionErrorType = 4
	InstructionErrorType_INSUFFICIENT_FUNDS                          InstructionErrorType = 5
	InstructionErrorType_INCORRECT_PROGRAM_ID                        InstructionErrorType = 6
	InstructionErrorType_MISSING_REQUIRED_SIGNATURE                  InstructionErrorType = 7
	InstructionErrorType_ACCOUNT_ALREADY_INITIALIZED                 InstructionErrorType = 8
	InstructionErrorType_UNINITIALIZED_ACCOUNT                       InstructionErrorType = 9
	InstructionErrorType_UNBALANCED_INSTRUCTION                      InstructionErrorType = 10
	InstructionErrorType_MODIFIED_PROGRAM_ID                         InstructionErrorType = 11
	InstructionErrorType_EXTERNAL_ACCOUNT_LAMPORT_SPEND              InstructionErrorType = 12
	InstructionErrorType_EXTERNAL_ACCOUNT_DATA_MODIFIED              InstructionErrorType = 13
	InstructionErrorType_READONLY_LAMPORT_CHANGE                     InstructionErrorType = 14
	InstructionErrorType_READONLY_DATA_MODIFIED                      InstructionErrorType = 15
	InstructionErrorType_DUPLICATE_ACCOUNT_INDEX                     InstructionErrorType = 16
	InstructionErrorType_EXECUTABLE_MODIFIED                         InstructionErrorType = 17
	InstructionErrorType_RENT_EPOCH_MODIFIED                         InstructionErrorType = 18
	InstructionErrorType_NOT_ENOUGH_ACCOUNT_KEYS                     InstructionErrorType = 19
	InstructionErrorType_ACCOUNT_DATA_SIZE_CHANGED                   InstructionErrorType = 20
	InstructionErrorType_ACCOUNT_NOT_EXECUTABLE                      InstructionErrorType = 21
	InstructionErrorType_ACCOUNT_BORROW_FAILED                       InstructionErrorType = 22
	InstructionErrorType_ACCOUNT_BORROW_OUTSTANDING                  InstructionErrorType = 23
	InstructionErrorType_DUPLICATE_ACCOUNT_OUT_OF_SYNC               InstructionErrorType = 24
	InstructionErrorType_CUSTOM                                      InstructionErrorType = 25
	InstructionErrorType_INVALID_ERROR                               InstructionErrorType = 26
	InstructionErrorType_EXECUTABLE_DATA_MODIFIED                    InstructionErrorType = 27
	InstructionErrorType_EXECUTABLE_LAMPORT_CHANGE                   InstructionErrorType = 28
	InstructionErrorType_EXECUTABLE_ACCOUNT_NOT_RENT_EXEMPT          InstructionErrorType = 29
	InstructionErrorType_UNSUPPORTED_PROGRAM_ID                      InstructionErrorType = 30
	InstructionErrorType_CALL_DEPTH                                  InstructionErrorType = 31
	InstructionErrorType_MISSING_ACCOUNT                             InstructionErrorType = 32
	InstructionErrorType_REENTRANCY_NOT_ALLOWED                      InstructionErrorType = 33
	InstructionErrorType_MAX_SEED_LENGTH_EXCEEDED                    InstructionErrorType = 34
	InstructionErrorType_INVALID_SEEDS                               InstructionErrorType = 35
	InstructionErrorType_INVALID_REALLOC                             InstructionErrorType = 36
	InstructionErrorType_COMPUTATIONAL_BUDGET_EXCEEDED               InstructionErrorType = 37
	InstructionErrorType_PRIVILEGE_ESCALATION                        InstructionErrorType = 38
	InstructionErrorType_PROGRAM_ENVIRONMENT_SETUP_FAILURE           InstructionErrorType = 39
	InstructionErrorType_PROGRAM_FAILED_TO_COMPLETE                  InstructionErrorType = 40
	InstructionErrorType_PROGRAM_FAILED_TO_COMPILE                   InstructionErrorType = 41
	InstructionErrorType_IMMUTABLE                                   InstructionErrorType = 42
	InstructionErrorType_INCORRECT_AUTHORITY                         InstructionErrorType = 43
	InstructionErrorType_BORSH_IO_ERROR                              InstructionErrorType = 44
	InstructionErrorType_ACCOUNT_NOT_RENT_EXEMPT                     InstructionErrorType = 45
	InstructionErrorType_INVALID_ACCOUNT_OWNER                       InstructionErrorType = 46
	InstructionErrorType_ARITHMETIC_OVERFLOW                         InstructionErrorType = 47
	InstructionErrorType_UNSUPPORTED_SYSVAR                          InstructionErrorType = 48
	InstructionErrorType_ILLEGAL_OWNER                               InstructionErrorType = 49
	InstructionErrorType_MAX_ACCOUNTS_DATA_ALLOCATIONS_EXCEEDED      InstructionErrorType = 50
	InstructionErrorType_MAX_ACCOUNTS_EXCEEDED                       InstructionErrorType = 51
	InstructionErrorType_MAX_INSTRUCTION_TRACE_LENGTH_EXCEEDED       InstructionErrorType = 52
	InstructionErrorType_BUILTIN_PROGRAMS_MUST_CONSUME_COMPUTE_UNITS InstructionErrorType = 53
)

func (InstructionErrorType) Descriptor 

func (InstructionErrorType) Descriptor() protoreflect.EnumDescriptor

func (InstructionErrorType) Enum 

func (x InstructionErrorType) Enum() *InstructionErrorType

func (InstructionErrorType) EnumDescriptor deprecated 

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

Deprecated: Use InstructionErrorType.Descriptor instead.

func (InstructionErrorType) Number 

func (x InstructionErrorType) Number() protoreflect.EnumNumber

func (InstructionErrorType) String 

func (x InstructionErrorType) String() string

func (InstructionErrorType) Type 

func (InstructionErrorType) Type() protoreflect.EnumType

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 MaybePartialAccountUpdate 

type MaybePartialAccountUpdate struct {

	// Types that are assignable to Msg:
	//
	//	*MaybePartialAccountUpdate_PartialAccountUpdate
	//	*MaybePartialAccountUpdate_Hb
	Msg isMaybePartialAccountUpdate_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*MaybePartialAccountUpdate) Descriptor deprecated 

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

Deprecated: Use MaybePartialAccountUpdate.ProtoReflect.Descriptor instead.

func (*MaybePartialAccountUpdate) GetHb 

func (x *MaybePartialAccountUpdate) GetHb() *Heartbeat

func (*MaybePartialAccountUpdate) GetMsg 

func (m *MaybePartialAccountUpdate) GetMsg() isMaybePartialAccountUpdate_Msg

func (*MaybePartialAccountUpdate) GetPartialAccountUpdate 

func (x *MaybePartialAccountUpdate) GetPartialAccountUpdate() *PartialAccountUpdate

func (*MaybePartialAccountUpdate) ProtoMessage 

func (*MaybePartialAccountUpdate) ProtoMessage()

func (*MaybePartialAccountUpdate) ProtoReflect 

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

func (*MaybePartialAccountUpdate) Reset 

func (x *MaybePartialAccountUpdate) Reset()

func (*MaybePartialAccountUpdate) String 

func (x *MaybePartialAccountUpdate) String() string

type MaybePartialAccountUpdate_Hb 

type MaybePartialAccountUpdate_Hb struct {
	Hb *Heartbeat `protobuf:"bytes,2,opt,name=hb,proto3,oneof"`
}

type MaybePartialAccountUpdate_PartialAccountUpdate 

type MaybePartialAccountUpdate_PartialAccountUpdate struct {
	PartialAccountUpdate *PartialAccountUpdate `protobuf:"bytes,1,opt,name=partial_account_update,json=partialAccountUpdate,proto3,oneof"`
}

type Memo 

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

func (*Memo) Descriptor deprecated 

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

Deprecated: Use Memo.ProtoReflect.Descriptor instead.

func (*Memo) GetMemo 

func (x *Memo) GetMemo() string

func (*Memo) ProtoMessage 

func (*Memo) ProtoMessage()

func (*Memo) ProtoReflect 

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

func (*Memo) Reset 

func (x *Memo) Reset()

func (*Memo) String 

func (x *Memo) 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 Message 

type Message struct {
	Header              *MessageHeader               `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	AccountKeys         [][]byte                     `protobuf:"bytes,2,rep,name=account_keys,json=accountKeys,proto3" json:"account_keys,omitempty"`
	RecentBlockhash     []byte                       `protobuf:"bytes,3,opt,name=recent_blockhash,json=recentBlockhash,proto3" json:"recent_blockhash,omitempty"`
	Instructions        []*CompiledInstruction       `protobuf:"bytes,4,rep,name=instructions,proto3" json:"instructions,omitempty"`
	Versioned           bool                         `protobuf:"varint,5,opt,name=versioned,proto3" json:"versioned,omitempty"`
	AddressTableLookups []*MessageAddressTableLookup `protobuf:"bytes,6,rep,name=address_table_lookups,json=addressTableLookups,proto3" json:"address_table_lookups,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetAccountKeys 

func (x *Message) GetAccountKeys() [][]byte

func (*Message) GetAddressTableLookups 

func (x *Message) GetAddressTableLookups() []*MessageAddressTableLookup

func (*Message) GetHeader 

func (x *Message) GetHeader() *MessageHeader

func (*Message) GetInstructions 

func (x *Message) GetInstructions() []*CompiledInstruction

func (*Message) GetRecentBlockhash 

func (x *Message) GetRecentBlockhash() []byte

func (*Message) GetVersioned 

func (x *Message) GetVersioned() bool

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageAddressTableLookup 

type MessageAddressTableLookup struct {
	AccountKey      []byte `protobuf:"bytes,1,opt,name=account_key,json=accountKey,proto3" json:"account_key,omitempty"`
	WritableIndexes []byte `protobuf:"bytes,2,opt,name=writable_indexes,json=writableIndexes,proto3" json:"writable_indexes,omitempty"`
	ReadonlyIndexes []byte `protobuf:"bytes,3,opt,name=readonly_indexes,json=readonlyIndexes,proto3" json:"readonly_indexes,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageAddressTableLookup) Descriptor deprecated 

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

Deprecated: Use MessageAddressTableLookup.ProtoReflect.Descriptor instead.

func (*MessageAddressTableLookup) GetAccountKey 

func (x *MessageAddressTableLookup) GetAccountKey() []byte

func (*MessageAddressTableLookup) GetReadonlyIndexes 

func (x *MessageAddressTableLookup) GetReadonlyIndexes() []byte

func (*MessageAddressTableLookup) GetWritableIndexes 

func (x *MessageAddressTableLookup) GetWritableIndexes() []byte

func (*MessageAddressTableLookup) ProtoMessage 

func (*MessageAddressTableLookup) ProtoMessage()

func (*MessageAddressTableLookup) ProtoReflect 

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

func (*MessageAddressTableLookup) Reset 

func (x *MessageAddressTableLookup) Reset()

func (*MessageAddressTableLookup) String 

func (x *MessageAddressTableLookup) String() string

type MessageHeader 

type MessageHeader struct {
	NumRequiredSignatures       uint32 `` /* 127-byte string literal not displayed */
	NumReadonlySignedAccounts   uint32 `` /* 141-byte string literal not displayed */
	NumReadonlyUnsignedAccounts uint32 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MessageHeader) Descriptor deprecated 

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

Deprecated: Use MessageHeader.ProtoReflect.Descriptor instead.

func (*MessageHeader) GetNumReadonlySignedAccounts 

func (x *MessageHeader) GetNumReadonlySignedAccounts() uint32

func (*MessageHeader) GetNumReadonlyUnsignedAccounts 

func (x *MessageHeader) GetNumReadonlyUnsignedAccounts() uint32

func (*MessageHeader) GetNumRequiredSignatures 

func (x *MessageHeader) GetNumRequiredSignatures() uint32

func (*MessageHeader) ProtoMessage 

func (*MessageHeader) ProtoMessage()

func (*MessageHeader) ProtoReflect 

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

func (*MessageHeader) Reset 

func (x *MessageHeader) Reset()

func (*MessageHeader) String 

func (x *MessageHeader) String() string

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 PartialAccountUpdate 

type PartialAccountUpdate struct {

	// Slot this update occurred.
	Slot uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	// Account's pubkey.
	Pubkey []byte `protobuf:"bytes,2,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// Account's owner.
	Owner []byte `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	// Flags whether this update was streamed as part of startup, hence not a realtime update.
	IsStartup bool `protobuf:"varint,4,opt,name=is_startup,json=isStartup,proto3" json:"is_startup,omitempty"`
	// A monotonically increasing number specifying the order of this update.
	// Can be used to determine what the latest update for an account was at
	// a given slot, assuming there were multiple updates.
	Seq uint64 `protobuf:"varint,5,opt,name=seq,proto3" json:"seq,omitempty"`
	// Transaction signature that caused this update.
	TxSignature *string `protobuf:"bytes,6,opt,name=tx_signature,json=txSignature,proto3,oneof" json:"tx_signature,omitempty"`
	// AccountReplica version.
	ReplicaVersion uint32 `protobuf:"varint,7,opt,name=replica_version,json=replicaVersion,proto3" json:"replica_version,omitempty"`
	// contains filtered or unexported fields
}

func (*PartialAccountUpdate) Descriptor deprecated 

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

Deprecated: Use PartialAccountUpdate.ProtoReflect.Descriptor instead.

func (*PartialAccountUpdate) GetIsStartup 

func (x *PartialAccountUpdate) GetIsStartup() bool

func (*PartialAccountUpdate) GetOwner 

func (x *PartialAccountUpdate) GetOwner() []byte

func (*PartialAccountUpdate) GetPubkey 

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

func (*PartialAccountUpdate) GetReplicaVersion 

func (x *PartialAccountUpdate) GetReplicaVersion() uint32

func (*PartialAccountUpdate) GetSeq 

func (x *PartialAccountUpdate) GetSeq() uint64

func (*PartialAccountUpdate) GetSlot 

func (x *PartialAccountUpdate) GetSlot() uint64

func (*PartialAccountUpdate) GetTxSignature 

func (x *PartialAccountUpdate) GetTxSignature() string

func (*PartialAccountUpdate) ProtoMessage 

func (*PartialAccountUpdate) ProtoMessage()

func (*PartialAccountUpdate) ProtoReflect 

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

func (*PartialAccountUpdate) Reset 

func (x *PartialAccountUpdate) Reset()

func (*PartialAccountUpdate) String 

func (x *PartialAccountUpdate) 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 ReturnData 

type ReturnData struct {
	ProgramId []byte `protobuf:"bytes,1,opt,name=program_id,json=programId,proto3" json:"program_id,omitempty"`
	Data      []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReturnData) Descriptor deprecated 

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

Deprecated: Use ReturnData.ProtoReflect.Descriptor instead.

func (*ReturnData) GetData 

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

func (*ReturnData) GetProgramId 

func (x *ReturnData) GetProgramId() []byte

func (*ReturnData) ProtoMessage 

func (*ReturnData) ProtoMessage()

func (*ReturnData) ProtoReflect 

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

func (*ReturnData) Reset 

func (x *ReturnData) Reset()

func (*ReturnData) String 

func (x *ReturnData) String() string

type Reward 

type Reward struct {
	Pubkey      string     `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	Lamports    int64      `protobuf:"varint,2,opt,name=lamports,proto3" json:"lamports,omitempty"`
	PostBalance uint64     `protobuf:"varint,3,opt,name=post_balance,json=postBalance,proto3" json:"post_balance,omitempty"`
	RewardType  RewardType `` /* 138-byte string literal not displayed */
	Commission  string     `protobuf:"bytes,5,opt,name=commission,proto3" json:"commission,omitempty"`
	// contains filtered or unexported fields
}

func (*Reward) Descriptor deprecated 

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

Deprecated: Use Reward.ProtoReflect.Descriptor instead.

func (*Reward) GetCommission 

func (x *Reward) GetCommission() string

func (*Reward) GetLamports 

func (x *Reward) GetLamports() int64

func (*Reward) GetPostBalance 

func (x *Reward) GetPostBalance() uint64

func (*Reward) GetPubkey 

func (x *Reward) GetPubkey() string

func (*Reward) GetRewardType 

func (x *Reward) GetRewardType() RewardType

func (*Reward) ProtoMessage 

func (*Reward) ProtoMessage()

func (*Reward) ProtoReflect 

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

func (*Reward) Reset 

func (x *Reward) Reset()

func (*Reward) String 

func (x *Reward) String() string

type RewardType 

type RewardType int32
const (
	RewardType_Unspecified RewardType = 0
	RewardType_Fee         RewardType = 1
	RewardType_Rent        RewardType = 2
	RewardType_Staking     RewardType = 3
	RewardType_Voting      RewardType = 4
)

func (RewardType) Descriptor 

func (RewardType) Descriptor() protoreflect.EnumDescriptor

func (RewardType) Enum 

func (x RewardType) Enum() *RewardType

func (RewardType) EnumDescriptor deprecated 

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

Deprecated: Use RewardType.Descriptor instead.

func (RewardType) Number 

func (x RewardType) Number() protoreflect.EnumNumber

func (RewardType) String 

func (x RewardType) String() string

func (RewardType) Type 

func (RewardType) Type() protoreflect.EnumType

type Rewards 

type Rewards struct {
	Rewards []*Reward `protobuf:"bytes,1,rep,name=rewards,proto3" json:"rewards,omitempty"`
	// contains filtered or unexported fields
}

func (*Rewards) Descriptor deprecated 

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

Deprecated: Use Rewards.ProtoReflect.Descriptor instead.

func (*Rewards) GetRewards 

func (x *Rewards) GetRewards() []*Reward

func (*Rewards) ProtoMessage 

func (*Rewards) ProtoMessage()

func (*Rewards) ProtoReflect 

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

func (*Rewards) Reset 

func (x *Rewards) Reset()

func (*Rewards) String 

func (x *Rewards) String() string

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 SlotUpdate 

type SlotUpdate struct {
	Slot       uint64           `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	ParentSlot *uint64          `protobuf:"varint,2,opt,name=parent_slot,json=parentSlot,proto3,oneof" json:"parent_slot,omitempty"`
	Status     SlotUpdateStatus `protobuf:"varint,3,opt,name=status,proto3,enum=solana.geyser.SlotUpdateStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SlotUpdate) Descriptor deprecated 

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

Deprecated: Use SlotUpdate.ProtoReflect.Descriptor instead.

func (*SlotUpdate) GetParentSlot 

func (x *SlotUpdate) GetParentSlot() uint64

func (*SlotUpdate) GetSlot 

func (x *SlotUpdate) GetSlot() uint64

func (*SlotUpdate) GetStatus 

func (x *SlotUpdate) GetStatus() SlotUpdateStatus

func (*SlotUpdate) ProtoMessage 

func (*SlotUpdate) ProtoMessage()

func (*SlotUpdate) ProtoReflect 

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

func (*SlotUpdate) Reset 

func (x *SlotUpdate) Reset()

func (*SlotUpdate) String 

func (x *SlotUpdate) String() string

type SlotUpdateStatus 

type SlotUpdateStatus int32
const (
	SlotUpdateStatus_CONFIRMED SlotUpdateStatus = 0
	SlotUpdateStatus_PROCESSED SlotUpdateStatus = 1
	SlotUpdateStatus_ROOTED    SlotUpdateStatus = 2
)

func (SlotUpdateStatus) Descriptor 

func (SlotUpdateStatus) Descriptor() protoreflect.EnumDescriptor

func (SlotUpdateStatus) Enum 

func (x SlotUpdateStatus) Enum() *SlotUpdateStatus

func (SlotUpdateStatus) EnumDescriptor deprecated 

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

Deprecated: Use SlotUpdateStatus.Descriptor instead.

func (SlotUpdateStatus) Number 

func (x SlotUpdateStatus) Number() protoreflect.EnumNumber

func (SlotUpdateStatus) String 

func (x SlotUpdateStatus) String() string

func (SlotUpdateStatus) Type 

func (SlotUpdateStatus) Type() protoreflect.EnumType

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 SubscribeAccountUpdatesRequest 

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

func (*SubscribeAccountUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeAccountUpdatesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeAccountUpdatesRequest) GetAccounts 

func (x *SubscribeAccountUpdatesRequest) GetAccounts() [][]byte

func (*SubscribeAccountUpdatesRequest) ProtoMessage 

func (*SubscribeAccountUpdatesRequest) ProtoMessage()

func (*SubscribeAccountUpdatesRequest) ProtoReflect 

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

func (*SubscribeAccountUpdatesRequest) Reset 

func (x *SubscribeAccountUpdatesRequest) Reset()

func (*SubscribeAccountUpdatesRequest) String 

func (x *SubscribeAccountUpdatesRequest) String() string

type SubscribeBlockUpdatesRequest 

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

func (*SubscribeBlockUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeBlockUpdatesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeBlockUpdatesRequest) ProtoMessage 

func (*SubscribeBlockUpdatesRequest) ProtoMessage()

func (*SubscribeBlockUpdatesRequest) ProtoReflect 

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

func (*SubscribeBlockUpdatesRequest) Reset 

func (x *SubscribeBlockUpdatesRequest) Reset()

func (*SubscribeBlockUpdatesRequest) String 

func (x *SubscribeBlockUpdatesRequest) 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 SubscribePartialAccountUpdatesRequest 

type SubscribePartialAccountUpdatesRequest struct {

	// If true, will not stream vote account updates.
	SkipVoteAccounts bool `protobuf:"varint,1,opt,name=skip_vote_accounts,json=skipVoteAccounts,proto3" json:"skip_vote_accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribePartialAccountUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribePartialAccountUpdatesRequest.ProtoReflect.Descriptor instead.

func (*SubscribePartialAccountUpdatesRequest) GetSkipVoteAccounts 

func (x *SubscribePartialAccountUpdatesRequest) GetSkipVoteAccounts() bool

func (*SubscribePartialAccountUpdatesRequest) ProtoMessage 

func (*SubscribePartialAccountUpdatesRequest) ProtoMessage()

func (*SubscribePartialAccountUpdatesRequest) ProtoReflect 

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

func (*SubscribePartialAccountUpdatesRequest) Reset 

func (x *SubscribePartialAccountUpdatesRequest) Reset()

func (*SubscribePartialAccountUpdatesRequest) String 

func (x *SubscribePartialAccountUpdatesRequest) String() string

type SubscribeProgramsUpdatesRequest 

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

func (*SubscribeProgramsUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeProgramsUpdatesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeProgramsUpdatesRequest) GetPrograms 

func (x *SubscribeProgramsUpdatesRequest) GetPrograms() [][]byte

func (*SubscribeProgramsUpdatesRequest) ProtoMessage 

func (*SubscribeProgramsUpdatesRequest) ProtoMessage()

func (*SubscribeProgramsUpdatesRequest) ProtoReflect 

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

func (*SubscribeProgramsUpdatesRequest) Reset 

func (x *SubscribeProgramsUpdatesRequest) Reset()

func (*SubscribeProgramsUpdatesRequest) String 

func (x *SubscribeProgramsUpdatesRequest) String() string

type SubscribeSlotUpdateRequest 

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

func (*SubscribeSlotUpdateRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeSlotUpdateRequest.ProtoReflect.Descriptor instead.

func (*SubscribeSlotUpdateRequest) ProtoMessage 

func (*SubscribeSlotUpdateRequest) ProtoMessage()

func (*SubscribeSlotUpdateRequest) ProtoReflect 

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

func (*SubscribeSlotUpdateRequest) Reset 

func (x *SubscribeSlotUpdateRequest) Reset()

func (*SubscribeSlotUpdateRequest) String 

func (x *SubscribeSlotUpdateRequest) String() string

type SubscribeTransactionUpdatesRequest 

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

func (*SubscribeTransactionUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeTransactionUpdatesRequest.ProtoReflect.Descriptor instead.

func (*SubscribeTransactionUpdatesRequest) ProtoMessage 

func (*SubscribeTransactionUpdatesRequest) ProtoMessage()

func (*SubscribeTransactionUpdatesRequest) ProtoReflect 

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

func (*SubscribeTransactionUpdatesRequest) Reset 

func (x *SubscribeTransactionUpdatesRequest) Reset()

func (*SubscribeTransactionUpdatesRequest) String 

func (x *SubscribeTransactionUpdatesRequest) String() string

type TimestampedAccountUpdate 

type TimestampedAccountUpdate struct {

	// Time at which the message was generated
	Ts *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// Account update
	AccountUpdate *AccountUpdate `protobuf:"bytes,2,opt,name=account_update,json=accountUpdate,proto3" json:"account_update,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampedAccountUpdate) Descriptor deprecated 

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

Deprecated: Use TimestampedAccountUpdate.ProtoReflect.Descriptor instead.

func (*TimestampedAccountUpdate) GetAccountUpdate 

func (x *TimestampedAccountUpdate) GetAccountUpdate() *AccountUpdate

func (*TimestampedAccountUpdate) GetTs 

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

func (*TimestampedAccountUpdate) ProtoMessage 

func (*TimestampedAccountUpdate) ProtoMessage()

func (*TimestampedAccountUpdate) ProtoReflect 

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

func (*TimestampedAccountUpdate) Reset 

func (x *TimestampedAccountUpdate) Reset()

func (*TimestampedAccountUpdate) String 

func (x *TimestampedAccountUpdate) String() string

type TimestampedBlockUpdate 

type TimestampedBlockUpdate struct {

	// Time at which the message was generated
	Ts *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// Block contents
	BlockUpdate *BlockUpdate `protobuf:"bytes,2,opt,name=block_update,json=blockUpdate,proto3" json:"block_update,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampedBlockUpdate) Descriptor deprecated 

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

Deprecated: Use TimestampedBlockUpdate.ProtoReflect.Descriptor instead.

func (*TimestampedBlockUpdate) GetBlockUpdate 

func (x *TimestampedBlockUpdate) GetBlockUpdate() *BlockUpdate

func (*TimestampedBlockUpdate) GetTs 

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

func (*TimestampedBlockUpdate) ProtoMessage 

func (*TimestampedBlockUpdate) ProtoMessage()

func (*TimestampedBlockUpdate) ProtoReflect 

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

func (*TimestampedBlockUpdate) Reset 

func (x *TimestampedBlockUpdate) Reset()

func (*TimestampedBlockUpdate) String 

func (x *TimestampedBlockUpdate) String() string

type TimestampedSlotUpdate 

type TimestampedSlotUpdate struct {

	// Time at which the message was generated
	Ts *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// Slot update
	SlotUpdate *SlotUpdate `protobuf:"bytes,2,opt,name=slot_update,json=slotUpdate,proto3" json:"slot_update,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampedSlotUpdate) Descriptor deprecated 

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

Deprecated: Use TimestampedSlotUpdate.ProtoReflect.Descriptor instead.

func (*TimestampedSlotUpdate) GetSlotUpdate 

func (x *TimestampedSlotUpdate) GetSlotUpdate() *SlotUpdate

func (*TimestampedSlotUpdate) GetTs 

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

func (*TimestampedSlotUpdate) ProtoMessage 

func (*TimestampedSlotUpdate) ProtoMessage()

func (*TimestampedSlotUpdate) ProtoReflect 

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

func (*TimestampedSlotUpdate) Reset 

func (x *TimestampedSlotUpdate) Reset()

func (*TimestampedSlotUpdate) String 

func (x *TimestampedSlotUpdate) String() string

type TimestampedTransactionUpdate 

type TimestampedTransactionUpdate struct {
	Ts          *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Transaction *TransactionUpdate     `protobuf:"bytes,2,opt,name=transaction,proto3" json:"transaction,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampedTransactionUpdate) Descriptor deprecated 

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

Deprecated: Use TimestampedTransactionUpdate.ProtoReflect.Descriptor instead.

func (*TimestampedTransactionUpdate) GetTransaction 

func (x *TimestampedTransactionUpdate) GetTransaction() *TransactionUpdate

func (*TimestampedTransactionUpdate) GetTs 

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

func (*TimestampedTransactionUpdate) ProtoMessage 

func (*TimestampedTransactionUpdate) ProtoMessage()

func (*TimestampedTransactionUpdate) ProtoReflect 

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

func (*TimestampedTransactionUpdate) Reset 

func (x *TimestampedTransactionUpdate) Reset()

func (*TimestampedTransactionUpdate) String 

func (x *TimestampedTransactionUpdate) String() string

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 TokenBalance 

type TokenBalance struct {
	AccountIndex  uint32         `protobuf:"varint,1,opt,name=account_index,json=accountIndex,proto3" json:"account_index,omitempty"`
	Mint          string         `protobuf:"bytes,2,opt,name=mint,proto3" json:"mint,omitempty"`
	UiTokenAmount *UiTokenAmount `protobuf:"bytes,3,opt,name=ui_token_amount,json=uiTokenAmount,proto3" json:"ui_token_amount,omitempty"`
	Owner         string         `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	ProgramId     string         `protobuf:"bytes,5,opt,name=program_id,json=programId,proto3" json:"program_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenBalance) Descriptor deprecated 

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

Deprecated: Use TokenBalance.ProtoReflect.Descriptor instead.

func (*TokenBalance) GetAccountIndex 

func (x *TokenBalance) GetAccountIndex() uint32

func (*TokenBalance) GetMint 

func (x *TokenBalance) GetMint() string

func (*TokenBalance) GetOwner 

func (x *TokenBalance) GetOwner() string

func (*TokenBalance) GetProgramId 

func (x *TokenBalance) GetProgramId() string

func (*TokenBalance) GetUiTokenAmount 

func (x *TokenBalance) GetUiTokenAmount() *UiTokenAmount

func (*TokenBalance) ProtoMessage 

func (*TokenBalance) ProtoMessage()

func (*TokenBalance) ProtoReflect 

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

func (*TokenBalance) Reset 

func (x *TokenBalance) Reset()

func (*TokenBalance) String 

func (x *TokenBalance) 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 Transaction 

type Transaction struct {
	Signatures [][]byte `protobuf:"bytes,1,rep,name=signatures,proto3" json:"signatures,omitempty"`
	Message    *Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Transaction) Descriptor deprecated 

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

Deprecated: Use Transaction.ProtoReflect.Descriptor instead.

func (*Transaction) GetMessage 

func (x *Transaction) GetMessage() *Message

func (*Transaction) GetSignatures 

func (x *Transaction) GetSignatures() [][]byte

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) ProtoReflect 

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

func (*Transaction) Reset 

func (x *Transaction) Reset()

func (*Transaction) String 

func (x *Transaction) String() string

type TransactionByAddr 

type TransactionByAddr struct {
	TxByAddrs []*TransactionByAddrInfo `protobuf:"bytes,1,rep,name=tx_by_addrs,json=txByAddrs,proto3" json:"tx_by_addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionByAddr) Descriptor deprecated 

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

Deprecated: Use TransactionByAddr.ProtoReflect.Descriptor instead.

func (*TransactionByAddr) GetTxByAddrs 

func (x *TransactionByAddr) GetTxByAddrs() []*TransactionByAddrInfo

func (*TransactionByAddr) ProtoMessage 

func (*TransactionByAddr) ProtoMessage()

func (*TransactionByAddr) ProtoReflect 

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

func (*TransactionByAddr) Reset 

func (x *TransactionByAddr) Reset()

func (*TransactionByAddr) String 

func (x *TransactionByAddr) String() string

type TransactionByAddrInfo 

type TransactionByAddrInfo struct {
	Signature []byte            `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Err       *TransactionError `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	Index     uint32            `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Memo      *Memo             `protobuf:"bytes,4,opt,name=memo,proto3" json:"memo,omitempty"`
	BlockTime *UnixTimestamp    `protobuf:"bytes,5,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionByAddrInfo) Descriptor deprecated 

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

Deprecated: Use TransactionByAddrInfo.ProtoReflect.Descriptor instead.

func (*TransactionByAddrInfo) GetBlockTime 

func (x *TransactionByAddrInfo) GetBlockTime() *UnixTimestamp

func (*TransactionByAddrInfo) GetErr 

func (x *TransactionByAddrInfo) GetErr() *TransactionError

func (*TransactionByAddrInfo) GetIndex 

func (x *TransactionByAddrInfo) GetIndex() uint32

func (*TransactionByAddrInfo) GetMemo 

func (x *TransactionByAddrInfo) GetMemo() *Memo

func (*TransactionByAddrInfo) GetSignature 

func (x *TransactionByAddrInfo) GetSignature() []byte

func (*TransactionByAddrInfo) ProtoMessage 

func (*TransactionByAddrInfo) ProtoMessage()

func (*TransactionByAddrInfo) ProtoReflect 

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

func (*TransactionByAddrInfo) Reset 

func (x *TransactionByAddrInfo) Reset()

func (*TransactionByAddrInfo) String 

func (x *TransactionByAddrInfo) String() string

type TransactionDetails 

type TransactionDetails struct {
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionDetails) Descriptor deprecated 

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

Deprecated: Use TransactionDetails.ProtoReflect.Descriptor instead.

func (*TransactionDetails) GetIndex 

func (x *TransactionDetails) GetIndex() uint32

func (*TransactionDetails) ProtoMessage 

func (*TransactionDetails) ProtoMessage()

func (*TransactionDetails) ProtoReflect 

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

func (*TransactionDetails) Reset 

func (x *TransactionDetails) Reset()

func (*TransactionDetails) String 

func (x *TransactionDetails) String() string

type TransactionError 

type TransactionError struct {
	Err []byte `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionError) Descriptor deprecated 

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

Deprecated: Use TransactionError.ProtoReflect.Descriptor instead.

func (*TransactionError) GetErr 

func (x *TransactionError) GetErr() []byte

func (*TransactionError) ProtoMessage 

func (*TransactionError) ProtoMessage()

func (*TransactionError) ProtoReflect 

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

func (*TransactionError) Reset 

func (x *TransactionError) Reset()

func (*TransactionError) String 

func (x *TransactionError) String() string

type TransactionErrorGeyser 

type TransactionErrorGeyser struct {
	TransactionError   TransactionErrorType `` /* 169-byte string literal not displayed */
	InstructionError   *InstructionError    `protobuf:"bytes,2,opt,name=instruction_error,json=instructionError,proto3" json:"instruction_error,omitempty"`
	TransactionDetails *TransactionDetails  `protobuf:"bytes,3,opt,name=transaction_details,json=transactionDetails,proto3" json:"transaction_details,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionErrorGeyser) Descriptor deprecated 

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

Deprecated: Use TransactionError.ProtoReflect.Descriptor instead.

func (*TransactionErrorGeyser) GetInstructionError 

func (x *TransactionErrorGeyser) GetInstructionError() *InstructionError

func (*TransactionErrorGeyser) GetTransactionDetails 

func (x *TransactionErrorGeyser) GetTransactionDetails() *TransactionDetails

func (*TransactionErrorGeyser) GetTransactionError 

func (x *TransactionErrorGeyser) GetTransactionError() TransactionErrorType

func (*TransactionErrorGeyser) ProtoMessage 

func (*TransactionErrorGeyser) ProtoMessage()

func (*TransactionErrorGeyser) ProtoReflect 

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

func (*TransactionErrorGeyser) Reset 

func (x *TransactionErrorGeyser) Reset()

func (*TransactionErrorGeyser) String 

func (x *TransactionErrorGeyser) String() string

type TransactionErrorType 

type TransactionErrorType int32
const (
	TransactionErrorType_ACCOUNT_IN_USE                           TransactionErrorType = 0
	TransactionErrorType_ACCOUNT_LOADED_TWICE                     TransactionErrorType = 1
	TransactionErrorType_ACCOUNT_NOT_FOUND                        TransactionErrorType = 2
	TransactionErrorType_PROGRAM_ACCOUNT_NOT_FOUND                TransactionErrorType = 3
	TransactionErrorType_INSUFFICIENT_FUNDS_FOR_FEE               TransactionErrorType = 4
	TransactionErrorType_INVALID_ACCOUNT_FOR_FEE                  TransactionErrorType = 5
	TransactionErrorType_ALREADY_PROCESSED                        TransactionErrorType = 6
	TransactionErrorType_BLOCKHASH_NOT_FOUND                      TransactionErrorType = 7
	TransactionErrorType_INSTRUCTION_ERROR                        TransactionErrorType = 8
	TransactionErrorType_CALL_CHAIN_TOO_DEEP                      TransactionErrorType = 9
	TransactionErrorType_MISSING_SIGNATURE_FOR_FEE                TransactionErrorType = 10
	TransactionErrorType_INVALID_ACCOUNT_INDEX                    TransactionErrorType = 11
	TransactionErrorType_SIGNATURE_FAILURE                        TransactionErrorType = 12
	TransactionErrorType_INVALID_PROGRAM_FOR_EXECUTION            TransactionErrorType = 13
	TransactionErrorType_SANITIZE_FAILURE                         TransactionErrorType = 14
	TransactionErrorType_CLUSTER_MAINTENANCE                      TransactionErrorType = 15
	TransactionErrorType_ACCOUNT_BORROW_OUTSTANDING_TX            TransactionErrorType = 16
	TransactionErrorType_WOULD_EXCEED_MAX_BLOCK_COST_LIMIT        TransactionErrorType = 17
	TransactionErrorType_UNSUPPORTED_VERSION                      TransactionErrorType = 18
	TransactionErrorType_INVALID_WRITABLE_ACCOUNT                 TransactionErrorType = 19
	TransactionErrorType_WOULD_EXCEED_MAX_ACCOUNT_COST_LIMIT      TransactionErrorType = 20
	TransactionErrorType_WOULD_EXCEED_ACCOUNT_DATA_BLOCK_LIMIT    TransactionErrorType = 21
	TransactionErrorType_TOO_MANY_ACCOUNT_LOCKS                   TransactionErrorType = 22
	TransactionErrorType_ADDRESS_LOOKUP_TABLE_NOT_FOUND           TransactionErrorType = 23
	TransactionErrorType_INVALID_ADDRESS_LOOKUP_TABLE_OWNER       TransactionErrorType = 24
	TransactionErrorType_INVALID_ADDRESS_LOOKUP_TABLE_DATA        TransactionErrorType = 25
	TransactionErrorType_INVALID_ADDRESS_LOOKUP_TABLE_INDEX       TransactionErrorType = 26
	TransactionErrorType_INVALID_RENT_PAYING_ACCOUNT              TransactionErrorType = 27
	TransactionErrorType_WOULD_EXCEED_MAX_VOTE_COST_LIMIT         TransactionErrorType = 28
	TransactionErrorType_WOULD_EXCEED_ACCOUNT_DATA_TOTAL_LIMIT    TransactionErrorType = 29
	TransactionErrorType_DUPLICATE_INSTRUCTION                    TransactionErrorType = 30
	TransactionErrorType_INSUFFICIENT_FUNDS_FOR_RENT              TransactionErrorType = 31
	TransactionErrorType_MAX_LOADED_ACCOUNTS_DATA_SIZE_EXCEEDED   TransactionErrorType = 32
	TransactionErrorType_INVALID_LOADED_ACCOUNTS_DATA_SIZE_LIMIT  TransactionErrorType = 33
	TransactionErrorType_RESANITIZATION_NEEDED                    TransactionErrorType = 34
	TransactionErrorType_PROGRAM_EXECUTION_TEMPORARILY_RESTRICTED TransactionErrorType = 35
	TransactionErrorType_UNBALANCED_TRANSACTION                   TransactionErrorType = 36
)

func (TransactionErrorType) Descriptor 

func (TransactionErrorType) Descriptor() protoreflect.EnumDescriptor

func (TransactionErrorType) Enum 

func (x TransactionErrorType) Enum() *TransactionErrorType

func (TransactionErrorType) EnumDescriptor deprecated 

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

Deprecated: Use TransactionErrorType.Descriptor instead.

func (TransactionErrorType) Number 

func (x TransactionErrorType) Number() protoreflect.EnumNumber

func (TransactionErrorType) String 

func (x TransactionErrorType) String() string

func (TransactionErrorType) Type 

func (TransactionErrorType) Type() protoreflect.EnumType

type TransactionStatusMeta 

type TransactionStatusMeta struct {
	Err                     *TransactionError    `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Fee                     uint64               `protobuf:"varint,2,opt,name=fee,proto3" json:"fee,omitempty"`
	PreBalances             []uint64             `protobuf:"varint,3,rep,packed,name=pre_balances,json=preBalances,proto3" json:"pre_balances,omitempty"`
	PostBalances            []uint64             `protobuf:"varint,4,rep,packed,name=post_balances,json=postBalances,proto3" json:"post_balances,omitempty"`
	InnerInstructions       []*InnerInstructions `protobuf:"bytes,5,rep,name=inner_instructions,json=innerInstructions,proto3" json:"inner_instructions,omitempty"`
	InnerInstructionsNone   bool                 `` /* 128-byte string literal not displayed */
	LogMessages             []string             `protobuf:"bytes,6,rep,name=log_messages,json=logMessages,proto3" json:"log_messages,omitempty"`
	LogMessagesNone         bool                 `protobuf:"varint,11,opt,name=log_messages_none,json=logMessagesNone,proto3" json:"log_messages_none,omitempty"`
	PreTokenBalances        []*TokenBalance      `protobuf:"bytes,7,rep,name=pre_token_balances,json=preTokenBalances,proto3" json:"pre_token_balances,omitempty"`
	PostTokenBalances       []*TokenBalance      `protobuf:"bytes,8,rep,name=post_token_balances,json=postTokenBalances,proto3" json:"post_token_balances,omitempty"`
	Rewards                 []*Reward            `protobuf:"bytes,9,rep,name=rewards,proto3" json:"rewards,omitempty"`
	LoadedWritableAddresses [][]byte             `` /* 133-byte string literal not displayed */
	LoadedReadonlyAddresses [][]byte             `` /* 133-byte string literal not displayed */
	ReturnData              *ReturnData          `protobuf:"bytes,14,opt,name=return_data,json=returnData,proto3" json:"return_data,omitempty"`
	ReturnDataNone          bool                 `protobuf:"varint,15,opt,name=return_data_none,json=returnDataNone,proto3" json:"return_data_none,omitempty"`
	// Sum of compute units consumed by all instructions.
	// Available since Solana v1.10.35 / v1.11.6.
	// Set to `None` for txs executed on earlier versions.
	ComputeUnitsConsumed *uint64 `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TransactionStatusMeta) Descriptor deprecated 

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

Deprecated: Use TransactionStatusMeta.ProtoReflect.Descriptor instead.

func (*TransactionStatusMeta) GetComputeUnitsConsumed 

func (x *TransactionStatusMeta) GetComputeUnitsConsumed() uint64

func (*TransactionStatusMeta) GetErr 

func (x *TransactionStatusMeta) GetErr() *TransactionError

func (*TransactionStatusMeta) GetFee 

func (x *TransactionStatusMeta) GetFee() uint64

func (*TransactionStatusMeta) GetInnerInstructions 

func (x *TransactionStatusMeta) GetInnerInstructions() []*InnerInstructions

func (*TransactionStatusMeta) GetInnerInstructionsNone 

func (x *TransactionStatusMeta) GetInnerInstructionsNone() bool

func (*TransactionStatusMeta) GetLoadedReadonlyAddresses 

func (x *TransactionStatusMeta) GetLoadedReadonlyAddresses() [][]byte

func (*TransactionStatusMeta) GetLoadedWritableAddresses 

func (x *TransactionStatusMeta) GetLoadedWritableAddresses() [][]byte

func (*TransactionStatusMeta) GetLogMessages 

func (x *TransactionStatusMeta) GetLogMessages() []string

func (*TransactionStatusMeta) GetLogMessagesNone 

func (x *TransactionStatusMeta) GetLogMessagesNone() bool

func (*TransactionStatusMeta) GetPostBalances 

func (x *TransactionStatusMeta) GetPostBalances() []uint64

func (*TransactionStatusMeta) GetPostTokenBalances 

func (x *TransactionStatusMeta) GetPostTokenBalances() []*TokenBalance

func (*TransactionStatusMeta) GetPreBalances 

func (x *TransactionStatusMeta) GetPreBalances() []uint64

func (*TransactionStatusMeta) GetPreTokenBalances 

func (x *TransactionStatusMeta) GetPreTokenBalances() []*TokenBalance

func (*TransactionStatusMeta) GetReturnData 

func (x *TransactionStatusMeta) GetReturnData() *ReturnData

func (*TransactionStatusMeta) GetReturnDataNone 

func (x *TransactionStatusMeta) GetReturnDataNone() bool

func (*TransactionStatusMeta) GetRewards 

func (x *TransactionStatusMeta) GetRewards() []*Reward

func (*TransactionStatusMeta) ProtoMessage 

func (*TransactionStatusMeta) ProtoMessage()

func (*TransactionStatusMeta) ProtoReflect 

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

func (*TransactionStatusMeta) Reset 

func (x *TransactionStatusMeta) Reset()

func (*TransactionStatusMeta) String 

func (x *TransactionStatusMeta) String() string

type TransactionUpdate 

type TransactionUpdate struct {
	Slot      uint64                `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Signature string                `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	IsVote    bool                  `protobuf:"varint,3,opt,name=is_vote,json=isVote,proto3" json:"is_vote,omitempty"`
	TxIdx     uint64                `protobuf:"varint,4,opt,name=tx_idx,json=txIdx,proto3" json:"tx_idx,omitempty"`
	Tx        *ConfirmedTransaction `protobuf:"bytes,5,opt,name=tx,proto3" json:"tx,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionUpdate) Descriptor deprecated 

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

Deprecated: Use TransactionUpdate.ProtoReflect.Descriptor instead.

func (*TransactionUpdate) GetIsVote 

func (x *TransactionUpdate) GetIsVote() bool

func (*TransactionUpdate) GetSignature 

func (x *TransactionUpdate) GetSignature() string

func (*TransactionUpdate) GetSlot 

func (x *TransactionUpdate) GetSlot() uint64

func (*TransactionUpdate) GetTx 

func (x *TransactionUpdate) GetTx() *ConfirmedTransaction

func (*TransactionUpdate) GetTxIdx 

func (x *TransactionUpdate) GetTxIdx() uint64

func (*TransactionUpdate) ProtoMessage 

func (*TransactionUpdate) ProtoMessage()

func (*TransactionUpdate) ProtoReflect 

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

func (*TransactionUpdate) Reset 

func (x *TransactionUpdate) Reset()

func (*TransactionUpdate) String 

func (x *TransactionUpdate) String() string

type UiTokenAmount 

type UiTokenAmount struct {
	UiAmount       float64 `protobuf:"fixed64,1,opt,name=ui_amount,json=uiAmount,proto3" json:"ui_amount,omitempty"`
	Decimals       uint32  `protobuf:"varint,2,opt,name=decimals,proto3" json:"decimals,omitempty"`
	Amount         string  `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	UiAmountString string  `protobuf:"bytes,4,opt,name=ui_amount_string,json=uiAmountString,proto3" json:"ui_amount_string,omitempty"`
	// contains filtered or unexported fields
}

func (*UiTokenAmount) Descriptor deprecated 

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

Deprecated: Use UiTokenAmount.ProtoReflect.Descriptor instead.

func (*UiTokenAmount) GetAmount 

func (x *UiTokenAmount) GetAmount() string

func (*UiTokenAmount) GetDecimals 

func (x *UiTokenAmount) GetDecimals() uint32

func (*UiTokenAmount) GetUiAmount 

func (x *UiTokenAmount) GetUiAmount() float64

func (*UiTokenAmount) GetUiAmountString 

func (x *UiTokenAmount) GetUiAmountString() string

func (*UiTokenAmount) ProtoMessage 

func (*UiTokenAmount) ProtoMessage()

func (*UiTokenAmount) ProtoReflect 

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

func (*UiTokenAmount) Reset 

func (x *UiTokenAmount) Reset()

func (*UiTokenAmount) String 

func (x *UiTokenAmount) 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 UnimplementedGeyserServer 

type UnimplementedGeyserServer struct {
}

UnimplementedGeyserServer must be embedded to have forward compatible implementations.

func (UnimplementedGeyserServer) GetHeartbeatInterval 

func (UnimplementedGeyserServer) GetHeartbeatInterval(context.Context, *EmptyRequest) (*GetHeartbeatIntervalResponse, error)

func (UnimplementedGeyserServer) SubscribeAccountUpdates 

func (UnimplementedGeyserServer) SubscribeAccountUpdates(*SubscribeAccountUpdatesRequest, Geyser_SubscribeAccountUpdatesServer) error

func (UnimplementedGeyserServer) SubscribeBlockUpdates 

func (UnimplementedGeyserServer) SubscribeBlockUpdates(*SubscribeBlockUpdatesRequest, Geyser_SubscribeBlockUpdatesServer) error

func (UnimplementedGeyserServer) SubscribePartialAccountUpdates 

func (UnimplementedGeyserServer) SubscribePartialAccountUpdates(*SubscribePartialAccountUpdatesRequest, Geyser_SubscribePartialAccountUpdatesServer) error

func (UnimplementedGeyserServer) SubscribeProgramUpdates 

func (UnimplementedGeyserServer) SubscribeProgramUpdates(*SubscribeProgramsUpdatesRequest, Geyser_SubscribeProgramUpdatesServer) error

func (UnimplementedGeyserServer) SubscribeSlotUpdates 

func (UnimplementedGeyserServer) SubscribeSlotUpdates(*SubscribeSlotUpdateRequest, Geyser_SubscribeSlotUpdatesServer) error

func (UnimplementedGeyserServer) SubscribeTransactionUpdates 

func (UnimplementedGeyserServer) SubscribeTransactionUpdates(*SubscribeTransactionUpdatesRequest, Geyser_SubscribeTransactionUpdatesServer) 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 UnixTimestamp 

type UnixTimestamp struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*UnixTimestamp) Descriptor deprecated 

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

Deprecated: Use UnixTimestamp.ProtoReflect.Descriptor instead.

func (*UnixTimestamp) GetTimestamp 

func (x *UnixTimestamp) GetTimestamp() int64

func (*UnixTimestamp) ProtoMessage 

func (*UnixTimestamp) ProtoMessage()

func (*UnixTimestamp) ProtoReflect 

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

func (*UnixTimestamp) Reset 

func (x *UnixTimestamp) Reset()

func (*UnixTimestamp) String 

func (x *UnixTimestamp) String() string

type UnixTimestampGeyser 

type UnixTimestampGeyser struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*UnixTimestampGeyser) Descriptor deprecated 

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

Deprecated: Use UnixTimestamp.ProtoReflect.Descriptor instead.

func (*UnixTimestampGeyser) GetTimestamp 

func (x *UnixTimestampGeyser) GetTimestamp() int64

func (*UnixTimestampGeyser) ProtoMessage 

func (*UnixTimestampGeyser) ProtoMessage()

func (*UnixTimestampGeyser) ProtoReflect 

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

func (*UnixTimestampGeyser) Reset 

func (x *UnixTimestampGeyser) Reset()

func (*UnixTimestampGeyser) String 

func (x *UnixTimestampGeyser) String() string

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 UnsafeGeyserServer 

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

UnsafeGeyserServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GeyserServer 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.