proto

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
}

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
}

type AccountsOfInterest struct {

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

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

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

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)
}

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
}

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

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
}

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)
}

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
}

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

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

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

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

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

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

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)
}

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
}

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

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

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

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

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

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
}

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
}

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
}

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 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 struct {
	// Reached finalized commitment level.
	Finalized *Finalized `protobuf:"bytes,4,opt,name=finalized,proto3,oneof"`
}

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

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

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
}

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
}

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
}

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
}

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
}

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
}

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

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

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
}

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

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

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

type DroppedReason int32

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

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
}

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

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
}

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

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
}

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
}

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
}

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

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
}

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

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

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

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
}

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)
}

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
}

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

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

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

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

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

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

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

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

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

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

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

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
}

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

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

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
}

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
}

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
}

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
}

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
}

type InstructionErrorType int32