yellowstone_geyser_pb

package
v0.0.0-...-2f2b176 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Geyser_Subscribe_FullMethodName          = "/geyser.Geyser/Subscribe"
	Geyser_Ping_FullMethodName               = "/geyser.Geyser/Ping"
	Geyser_GetLatestBlockhash_FullMethodName = "/geyser.Geyser/GetLatestBlockhash"
	Geyser_GetBlockHeight_FullMethodName     = "/geyser.Geyser/GetBlockHeight"
	Geyser_GetSlot_FullMethodName            = "/geyser.Geyser/GetSlot"
	Geyser_IsBlockhashValid_FullMethodName   = "/geyser.Geyser/IsBlockhashValid"
	Geyser_GetVersion_FullMethodName         = "/geyser.Geyser/GetVersion"
)
View Source 
const (
	YellowstoneLog_CreateStaticConsumerGroup_FullMethodName = "/yellowstone.log.YellowstoneLog/CreateStaticConsumerGroup"
	YellowstoneLog_Consume_FullMethodName                   = "/yellowstone.log.YellowstoneLog/Consume"
)

Variables

View Source 
var (
	CommitmentLevel_name = map[int32]string{
		0: "PROCESSED",
		1: "CONFIRMED",
		2: "FINALIZED",
		3: "FIRST_SHRED_RECEIVED",
		4: "COMPLETED",
		5: "CREATED_BANK",
		6: "DEAD",
	}
	CommitmentLevel_value = map[string]int32{
		"PROCESSED":            0,
		"CONFIRMED":            1,
		"FINALIZED":            2,
		"FIRST_SHRED_RECEIVED": 3,
		"COMPLETED":            4,
		"CREATED_BANK":         5,
		"DEAD":                 6,
	}
)

Enum value maps for CommitmentLevel.

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 (
	PartitionAssignmentStrategy_name = map[int32]string{
		0: "STATIC",
	}
	PartitionAssignmentStrategy_value = map[string]int32{
		"STATIC": 0,
	}
)

Enum value maps for PartitionAssignmentStrategy.

View Source 
var (
	InitialOffsetPolicy_name = map[int32]string{
		0: "EARLIEST",
		1: "LATEST",
		2: "SLOT",
	}
	InitialOffsetPolicy_value = map[string]int32{
		"EARLIEST": 0,
		"LATEST":   1,
		"SLOT":     2,
	}
)

Enum value maps for InitialOffsetPolicy.

View Source 
var (
	EventSubscriptionPolicy_name = map[int32]string{
		0: "ACCOUNT_UPDATE_ONLY",
		1: "TRANSACTION_ONLY",
		2: "BOTH",
	}
	EventSubscriptionPolicy_value = map[string]int32{
		"ACCOUNT_UPDATE_ONLY": 0,
		"TRANSACTION_ONLY":    1,
		"BOTH":                2,
	}
)

Enum value maps for EventSubscriptionPolicy.

View Source 
var (
	TimelineTranslationPolicy_name = map[int32]string{
		0: "ALLOW_LAG",
		1: "STRICT_SLOT",
	}
	TimelineTranslationPolicy_value = map[string]int32{
		"ALLOW_LAG":   0,
		"STRICT_SLOT": 1,
	}
)

Enum value maps for TimelineTranslationPolicy.

View Source 
var File_geyser_proto protoreflect.FileDescriptor
View Source 
var File_solana_storage_proto protoreflect.FileDescriptor
View Source 
var File_yellowstone_log_proto protoreflect.FileDescriptor
View Source 
var Geyser_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "geyser.Geyser",
	HandlerType: (*GeyserServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Geyser_Ping_Handler,
		},
		{
			MethodName: "GetLatestBlockhash",
			Handler:    _Geyser_GetLatestBlockhash_Handler,
		},
		{
			MethodName: "GetBlockHeight",
			Handler:    _Geyser_GetBlockHeight_Handler,
		},
		{
			MethodName: "GetSlot",
			Handler:    _Geyser_GetSlot_Handler,
		},
		{
			MethodName: "IsBlockhashValid",
			Handler:    _Geyser_IsBlockhashValid_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Geyser_GetVersion_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Geyser_Subscribe_Handler,
			ServerStreams: true,
			ClientStreams: 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 YellowstoneLog_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yellowstone.log.YellowstoneLog",
	HandlerType: (*YellowstoneLogServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateStaticConsumerGroup",
			Handler:    _YellowstoneLog_CreateStaticConsumerGroup_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Consume",
			Handler:       _YellowstoneLog_Consume_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "yellowstone-log.proto",
}

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

Functions

func RegisterGeyserServer 

func RegisterGeyserServer(s grpc.ServiceRegistrar, srv GeyserServer)

func RegisterYellowstoneLogServer 

func RegisterYellowstoneLogServer(s grpc.ServiceRegistrar, srv YellowstoneLogServer)

Types

type AccountUpdateEventFilter 

type AccountUpdateEventFilter struct {
	Pubkeys [][]byte `protobuf:"bytes,1,rep,name=pubkeys,proto3" json:"pubkeys,omitempty"`
	Owners  [][]byte `protobuf:"bytes,2,rep,name=owners,proto3" json:"owners,omitempty"`
	// contains filtered or unexported fields
}

/ The AccountUpdateEventFilter message defines filters for account update events. It includes the following fields: / / pubkeys (1) / A repeated field of bytes representing public keys. Events matching any of these public keys will be included in the filtered results. / / owners (2) / A repeated field of bytes representing account owners. Events matching any of these account owners will be included in the filtered results.

func (*AccountUpdateEventFilter) Descriptor deprecated 

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

Deprecated: Use AccountUpdateEventFilter.ProtoReflect.Descriptor instead.

func (*AccountUpdateEventFilter) GetOwners 

func (x *AccountUpdateEventFilter) GetOwners() [][]byte

func (*AccountUpdateEventFilter) GetPubkeys 

func (x *AccountUpdateEventFilter) GetPubkeys() [][]byte

func (*AccountUpdateEventFilter) ProtoMessage 

func (*AccountUpdateEventFilter) ProtoMessage()

func (*AccountUpdateEventFilter) ProtoReflect 

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

func (*AccountUpdateEventFilter) Reset 

func (x *AccountUpdateEventFilter) Reset()

func (*AccountUpdateEventFilter) String 

func (x *AccountUpdateEventFilter) String() string

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 CommitmentLevel 

type CommitmentLevel int32
const (
	CommitmentLevel_PROCESSED            CommitmentLevel = 0
	CommitmentLevel_CONFIRMED            CommitmentLevel = 1
	CommitmentLevel_FINALIZED            CommitmentLevel = 2
	CommitmentLevel_FIRST_SHRED_RECEIVED CommitmentLevel = 3
	CommitmentLevel_COMPLETED            CommitmentLevel = 4
	CommitmentLevel_CREATED_BANK         CommitmentLevel = 5
	CommitmentLevel_DEAD                 CommitmentLevel = 6
)

func (CommitmentLevel) Descriptor 

func (CommitmentLevel) Descriptor() protoreflect.EnumDescriptor

func (CommitmentLevel) Enum 

func (x CommitmentLevel) Enum() *CommitmentLevel

func (CommitmentLevel) EnumDescriptor deprecated 

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

Deprecated: Use CommitmentLevel.Descriptor instead.

func (CommitmentLevel) Number 

func (x CommitmentLevel) Number() protoreflect.EnumNumber

func (CommitmentLevel) String 

func (x CommitmentLevel) String() string

func (CommitmentLevel) Type 

func (CommitmentLevel) Type() protoreflect.EnumType

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 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"`
	NumPartitions     *NumPartitions          `protobuf:"bytes,8,opt,name=num_partitions,json=numPartitions,proto3" json:"num_partitions,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) GetNumPartitions 

func (x *ConfirmedBlock) GetNumPartitions() *NumPartitions

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 ConsumeRequest 

type ConsumeRequest struct {
	ConsumerGroupId          *string                   `protobuf:"bytes,1,opt,name=consumer_group_id,json=consumerGroupId,proto3,oneof" json:"consumer_group_id,omitempty"`
	ConsumerId               *string                   `protobuf:"bytes,2,opt,name=consumer_id,json=consumerId,proto3,oneof" json:"consumer_id,omitempty"`
	InstanceId               *string                   `protobuf:"bytes,3,opt,name=instance_id,json=instanceId,proto3,oneof" json:"instance_id,omitempty"`
	InitialOffsetPolicy      InitialOffsetPolicy       `` /* 162-byte string literal not displayed */
	CommitmentLevel          CommitmentLevel           `` /* 135-byte string literal not displayed */
	EventSubscriptionPolicy  EventSubscriptionPolicy   `` /* 178-byte string literal not displayed */
	AtSlot                   *int64                    `protobuf:"varint,7,opt,name=at_slot,json=atSlot,proto3,oneof" json:"at_slot,omitempty"`
	AccountUpdateEventFilter *AccountUpdateEventFilter `` /* 143-byte string literal not displayed */
	TxEventFilter            *TransactionEventFilter   `protobuf:"bytes,9,opt,name=tx_event_filter,json=txEventFilter,proto3,oneof" json:"tx_event_filter,omitempty"`
	// timelineTranslationPolicy is used when an ingester is out of service and we need to translate a set
	// of consumer to a different ingestion timeline. The policy describe what to do when we need to trigger timeline translation.
	TimelineTranslationPolicy *TimelineTranslationPolicy `` /* 158-byte string literal not displayed */
	TtpMaximumSlotLag         *uint32                    `protobuf:"varint,11,opt,name=ttp_maximum_slot_lag,json=ttpMaximumSlotLag,proto3,oneof" json:"ttp_maximum_slot_lag,omitempty"`
	// contains filtered or unexported fields
}

/ The ConsumeRequest message defines parameters for consuming events or messages from a data stream. It includes the following fields: / / consumer_id (1) / An optional string representing the consumer's unique identifier. / / initial_offset_policy (2) / Specifies the initial offset policy for subscribing to events. It uses values from the InitialOffsetPolicy enum. / / at_slot (3) / An optional int64 indicating the specific slot number from which consumption should start. This is relevant when initial_offset_policy is set to SLOT. / / event_subscription_policy (4) / Defines the event subscription policy using values from the EventSubscriptionPolicy enum. / / account_update_event_filter (5) / An optional AccountUpdateEventFilter message specifying filters for account update events. / / tx_event_filter (6) / An optional TransactionEventFilter message defining filters for transaction events. / / commitment_level (7) / Specifies the commitment level for consuming events. It uses values from the geyser.CommitmentLevel enum. / / timelineTranslationPolicy (8) / An optional TimelineTranslationPolicy describing the policy for triggering timeline translation when an ingester is out of service and consumers need to be translated to a different ingestion timeline. / / ttp_maximum_slot_lag (9) / An optional uint32 indicating the maximum slot lag allowed for timeline translation.

func (*ConsumeRequest) Descriptor deprecated 

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetAccountUpdateEventFilter 

func (x *ConsumeRequest) GetAccountUpdateEventFilter() *AccountUpdateEventFilter

func (*ConsumeRequest) GetAtSlot 

func (x *ConsumeRequest) GetAtSlot() int64

func (*ConsumeRequest) GetCommitmentLevel 

func (x *ConsumeRequest) GetCommitmentLevel() CommitmentLevel

func (*ConsumeRequest) GetConsumerGroupId 

func (x *ConsumeRequest) GetConsumerGroupId() string

func (*ConsumeRequest) GetConsumerId 

func (x *ConsumeRequest) GetConsumerId() string

func (*ConsumeRequest) GetEventSubscriptionPolicy 

func (x *ConsumeRequest) GetEventSubscriptionPolicy() EventSubscriptionPolicy

func (*ConsumeRequest) GetInitialOffsetPolicy 

func (x *ConsumeRequest) GetInitialOffsetPolicy() InitialOffsetPolicy

func (*ConsumeRequest) GetInstanceId 

func (x *ConsumeRequest) GetInstanceId() string

func (*ConsumeRequest) GetTimelineTranslationPolicy 

func (x *ConsumeRequest) GetTimelineTranslationPolicy() TimelineTranslationPolicy

func (*ConsumeRequest) GetTtpMaximumSlotLag 

func (x *ConsumeRequest) GetTtpMaximumSlotLag() uint32

func (*ConsumeRequest) GetTxEventFilter 

func (x *ConsumeRequest) GetTxEventFilter() *TransactionEventFilter

func (*ConsumeRequest) ProtoMessage 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect 

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

func (*ConsumeRequest) Reset 

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) String 

func (x *ConsumeRequest) String() string

type CreateStaticConsumerGroupRequest 

type CreateStaticConsumerGroupRequest struct {
	InstanceIdList           []string `protobuf:"bytes,2,rep,name=instance_id_list,json=instanceIdList,proto3" json:"instance_id_list,omitempty"`
	RedundancyInstanceIdList []string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateStaticConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateStaticConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateStaticConsumerGroupRequest) GetInstanceIdList 

func (x *CreateStaticConsumerGroupRequest) GetInstanceIdList() []string

func (*CreateStaticConsumerGroupRequest) GetRedundancyInstanceIdList 

func (x *CreateStaticConsumerGroupRequest) GetRedundancyInstanceIdList() []string

func (*CreateStaticConsumerGroupRequest) ProtoMessage 

func (*CreateStaticConsumerGroupRequest) ProtoMessage()

func (*CreateStaticConsumerGroupRequest) ProtoReflect 

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

func (*CreateStaticConsumerGroupRequest) Reset 

func (x *CreateStaticConsumerGroupRequest) Reset()

func (*CreateStaticConsumerGroupRequest) String 

func (x *CreateStaticConsumerGroupRequest) String() string

type CreateStaticConsumerGroupResponse 

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

func (*CreateStaticConsumerGroupResponse) Descriptor deprecated 

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

Deprecated: Use CreateStaticConsumerGroupResponse.ProtoReflect.Descriptor instead.

func (*CreateStaticConsumerGroupResponse) GetGroupId 

func (x *CreateStaticConsumerGroupResponse) GetGroupId() string

func (*CreateStaticConsumerGroupResponse) ProtoMessage 

func (*CreateStaticConsumerGroupResponse) ProtoMessage()

func (*CreateStaticConsumerGroupResponse) ProtoReflect 

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

func (*CreateStaticConsumerGroupResponse) Reset 

func (x *CreateStaticConsumerGroupResponse) Reset()

func (*CreateStaticConsumerGroupResponse) String 

func (x *CreateStaticConsumerGroupResponse) String() string

type EventSubscriptionPolicy 

type EventSubscriptionPolicy int32

/ The EventSubscriptionPolicy enum defines the types of events to subscribe to. It offers three options: / / ACCOUNT_UPDATE_ONLY (0) / Subscribes to account update events exclusively. It filters out other types of events, focusing solely on account-related updates. / / TRANSACTION_ONLY (1) / Subscribes to transaction events exclusively. It filters out non-transactional events, ensuring that only transaction-related data is consumed. / / BOTH (2) / This policy subscribes to both account update and transaction events. It enables consumption of a wider range of event types, encompassing both account-related updates and transactions. 

const (
	EventSubscriptionPolicy_ACCOUNT_UPDATE_ONLY EventSubscriptionPolicy = 0
	EventSubscriptionPolicy_TRANSACTION_ONLY    EventSubscriptionPolicy = 1
	EventSubscriptionPolicy_BOTH                EventSubscriptionPolicy = 2
)

func (EventSubscriptionPolicy) Descriptor 

func (EventSubscriptionPolicy) Descriptor() protoreflect.EnumDescriptor

func (EventSubscriptionPolicy) Enum 

func (x EventSubscriptionPolicy) Enum() *EventSubscriptionPolicy

func (EventSubscriptionPolicy) EnumDescriptor deprecated 

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

Deprecated: Use EventSubscriptionPolicy.Descriptor instead.

func (EventSubscriptionPolicy) Number 

func (x EventSubscriptionPolicy) Number() protoreflect.EnumNumber

func (EventSubscriptionPolicy) String 

func (x EventSubscriptionPolicy) String() string

func (EventSubscriptionPolicy) Type 

func (EventSubscriptionPolicy) Type() protoreflect.EnumType

type GetBlockHeightRequest 

type GetBlockHeightRequest struct {
	Commitment *CommitmentLevel `protobuf:"varint,1,opt,name=commitment,proto3,enum=geyser.CommitmentLevel,oneof" json:"commitment,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockHeightRequest) Descriptor deprecated 

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

Deprecated: Use GetBlockHeightRequest.ProtoReflect.Descriptor instead.

func (*GetBlockHeightRequest) GetCommitment 

func (x *GetBlockHeightRequest) GetCommitment() CommitmentLevel

func (*GetBlockHeightRequest) ProtoMessage 

func (*GetBlockHeightRequest) ProtoMessage()

func (*GetBlockHeightRequest) ProtoReflect 

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

func (*GetBlockHeightRequest) Reset 

func (x *GetBlockHeightRequest) Reset()

func (*GetBlockHeightRequest) String 

func (x *GetBlockHeightRequest) String() string

type GetBlockHeightResponse 

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

func (*GetBlockHeightResponse) Descriptor deprecated 

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

Deprecated: Use GetBlockHeightResponse.ProtoReflect.Descriptor instead.

func (*GetBlockHeightResponse) GetBlockHeight 

func (x *GetBlockHeightResponse) GetBlockHeight() uint64

func (*GetBlockHeightResponse) ProtoMessage 

func (*GetBlockHeightResponse) ProtoMessage()

func (*GetBlockHeightResponse) ProtoReflect 

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

func (*GetBlockHeightResponse) Reset 

func (x *GetBlockHeightResponse) Reset()

func (*GetBlockHeightResponse) String 

func (x *GetBlockHeightResponse) String() string

type GetLatestBlockhashRequest 

type GetLatestBlockhashRequest struct {
	Commitment *CommitmentLevel `protobuf:"varint,1,opt,name=commitment,proto3,enum=geyser.CommitmentLevel,oneof" json:"commitment,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLatestBlockhashRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestBlockhashRequest.ProtoReflect.Descriptor instead.

func (*GetLatestBlockhashRequest) GetCommitment 

func (x *GetLatestBlockhashRequest) GetCommitment() CommitmentLevel

func (*GetLatestBlockhashRequest) ProtoMessage 

func (*GetLatestBlockhashRequest) ProtoMessage()

func (*GetLatestBlockhashRequest) ProtoReflect 

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

func (*GetLatestBlockhashRequest) Reset 

func (x *GetLatestBlockhashRequest) Reset()

func (*GetLatestBlockhashRequest) String 

func (x *GetLatestBlockhashRequest) String() string

type GetLatestBlockhashResponse 

type GetLatestBlockhashResponse 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"`
	LastValidBlockHeight uint64 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetLatestBlockhashResponse) Descriptor deprecated 

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

Deprecated: Use GetLatestBlockhashResponse.ProtoReflect.Descriptor instead.

func (*GetLatestBlockhashResponse) GetBlockhash 

func (x *GetLatestBlockhashResponse) GetBlockhash() string

func (*GetLatestBlockhashResponse) GetLastValidBlockHeight 

func (x *GetLatestBlockhashResponse) GetLastValidBlockHeight() uint64

func (*GetLatestBlockhashResponse) GetSlot 

func (x *GetLatestBlockhashResponse) GetSlot() uint64

func (*GetLatestBlockhashResponse) ProtoMessage 

func (*GetLatestBlockhashResponse) ProtoMessage()

func (*GetLatestBlockhashResponse) ProtoReflect 

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

func (*GetLatestBlockhashResponse) Reset 

func (x *GetLatestBlockhashResponse) Reset()

func (*GetLatestBlockhashResponse) String 

func (x *GetLatestBlockhashResponse) String() string

type GetSlotRequest 

type GetSlotRequest struct {
	Commitment *CommitmentLevel `protobuf:"varint,1,opt,name=commitment,proto3,enum=geyser.CommitmentLevel,oneof" json:"commitment,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSlotRequest) Descriptor deprecated 

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

Deprecated: Use GetSlotRequest.ProtoReflect.Descriptor instead.

func (*GetSlotRequest) GetCommitment 

func (x *GetSlotRequest) GetCommitment() CommitmentLevel

func (*GetSlotRequest) ProtoMessage 

func (*GetSlotRequest) ProtoMessage()

func (*GetSlotRequest) ProtoReflect 

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

func (*GetSlotRequest) Reset 

func (x *GetSlotRequest) Reset()

func (*GetSlotRequest) String 

func (x *GetSlotRequest) String() string

type GetSlotResponse 

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

func (*GetSlotResponse) Descriptor deprecated 

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

Deprecated: Use GetSlotResponse.ProtoReflect.Descriptor instead.

func (*GetSlotResponse) GetSlot 

func (x *GetSlotResponse) GetSlot() uint64

func (*GetSlotResponse) ProtoMessage 

func (*GetSlotResponse) ProtoMessage()

func (*GetSlotResponse) ProtoReflect 

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

func (*GetSlotResponse) Reset 

func (x *GetSlotResponse) Reset()

func (*GetSlotResponse) String 

func (x *GetSlotResponse) String() string

type GetVersionRequest 

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

func (*GetVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect 

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

func (*GetVersionRequest) Reset 

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (x *GetVersionRequest) String() string

type GetVersionResponse 

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

func (*GetVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetVersionResponse.ProtoReflect.Descriptor instead.

func (*GetVersionResponse) GetVersion 

func (x *GetVersionResponse) GetVersion() string

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) ProtoReflect 

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

func (*GetVersionResponse) Reset 

func (x *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (x *GetVersionResponse) String() string

type GeyserClient 

type GeyserClient interface {
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeRequest, SubscribeUpdate], error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongResponse, error)
	GetLatestBlockhash(ctx context.Context, in *GetLatestBlockhashRequest, opts ...grpc.CallOption) (*GetLatestBlockhashResponse, error)
	GetBlockHeight(ctx context.Context, in *GetBlockHeightRequest, opts ...grpc.CallOption) (*GetBlockHeightResponse, error)
	GetSlot(ctx context.Context, in *GetSlotRequest, opts ...grpc.CallOption) (*GetSlotResponse, error)
	IsBlockhashValid(ctx context.Context, in *IsBlockhashValidRequest, opts ...grpc.CallOption) (*IsBlockhashValidResponse, error)
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, 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 {
	Subscribe(grpc.BidiStreamingServer[SubscribeRequest, SubscribeUpdate]) error
	Ping(context.Context, *PingRequest) (*PongResponse, error)
	GetLatestBlockhash(context.Context, *GetLatestBlockhashRequest) (*GetLatestBlockhashResponse, error)
	GetBlockHeight(context.Context, *GetBlockHeightRequest) (*GetBlockHeightResponse, error)
	GetSlot(context.Context, *GetSlotRequest) (*GetSlotResponse, error)
	IsBlockhashValid(context.Context, *IsBlockhashValidRequest) (*IsBlockhashValidResponse, error)
	GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
	// contains filtered or unexported methods
}

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

type Geyser_SubscribeClient 

type Geyser_SubscribeClient = grpc.BidiStreamingClient[SubscribeRequest, SubscribeUpdate]

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

type Geyser_SubscribeServer 

type Geyser_SubscribeServer = grpc.BidiStreamingServer[SubscribeRequest, SubscribeUpdate]

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

type InitialOffsetPolicy 

type InitialOffsetPolicy int32

/ The InitialOffsetPolicy enum determines the initial offset used when subscribing to events or messages. It provides three options: / / EARLIEST (0) / This policy subscribes to events or messages starting from the earliest available offset in the data stream. It ensures that all historical data is consumed from the beginning. / / LATEST (1) / Subscribes to events or messages starting from the latest available offset in the data stream. It only consumes new events or messages generated after the subscription is initiated. / / SLOT (2) / This policy subscribes to events or messages starting from a specific slot number in the data stream. It allows for precise control over where consumption begins based on slot numbers. 

const (
	InitialOffsetPolicy_EARLIEST InitialOffsetPolicy = 0
	InitialOffsetPolicy_LATEST   InitialOffsetPolicy = 1
	InitialOffsetPolicy_SLOT     InitialOffsetPolicy = 2
)

func (InitialOffsetPolicy) Descriptor 

func (InitialOffsetPolicy) Descriptor() protoreflect.EnumDescriptor

func (InitialOffsetPolicy) Enum 

func (x InitialOffsetPolicy) Enum() *InitialOffsetPolicy

func (InitialOffsetPolicy) EnumDescriptor deprecated 

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

Deprecated: Use InitialOffsetPolicy.Descriptor instead.

func (InitialOffsetPolicy) Number 

func (x InitialOffsetPolicy) Number() protoreflect.EnumNumber

func (InitialOffsetPolicy) String 

func (x InitialOffsetPolicy) String() string

func (InitialOffsetPolicy) Type 

func (InitialOffsetPolicy) Type() protoreflect.EnumType

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 IsBlockhashValidRequest 

type IsBlockhashValidRequest struct {
	Blockhash  string           `protobuf:"bytes,1,opt,name=blockhash,proto3" json:"blockhash,omitempty"`
	Commitment *CommitmentLevel `protobuf:"varint,2,opt,name=commitment,proto3,enum=geyser.CommitmentLevel,oneof" json:"commitment,omitempty"`
	// contains filtered or unexported fields
}

func (*IsBlockhashValidRequest) Descriptor deprecated 

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

Deprecated: Use IsBlockhashValidRequest.ProtoReflect.Descriptor instead.

func (*IsBlockhashValidRequest) GetBlockhash 

func (x *IsBlockhashValidRequest) GetBlockhash() string

func (*IsBlockhashValidRequest) GetCommitment 

func (x *IsBlockhashValidRequest) GetCommitment() CommitmentLevel

func (*IsBlockhashValidRequest) ProtoMessage 

func (*IsBlockhashValidRequest) ProtoMessage()

func (*IsBlockhashValidRequest) ProtoReflect 

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

func (*IsBlockhashValidRequest) Reset 

func (x *IsBlockhashValidRequest) Reset()

func (*IsBlockhashValidRequest) String 

func (x *IsBlockhashValidRequest) String() string

type IsBlockhashValidResponse 

type IsBlockhashValidResponse struct {
	Slot  uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Valid bool   `protobuf:"varint,2,opt,name=valid,proto3" json:"valid,omitempty"`
	// contains filtered or unexported fields
}

func (*IsBlockhashValidResponse) Descriptor deprecated 

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

Deprecated: Use IsBlockhashValidResponse.ProtoReflect.Descriptor instead.

func (*IsBlockhashValidResponse) GetSlot 

func (x *IsBlockhashValidResponse) GetSlot() uint64

func (*IsBlockhashValidResponse) GetValid 

func (x *IsBlockhashValidResponse) GetValid() bool

func (*IsBlockhashValidResponse) ProtoMessage 

func (*IsBlockhashValidResponse) ProtoMessage()

func (*IsBlockhashValidResponse) ProtoReflect 

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

func (*IsBlockhashValidResponse) Reset 

func (x *IsBlockhashValidResponse) Reset()

func (*IsBlockhashValidResponse) String 

func (x *IsBlockhashValidResponse) String() string

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 NumPartitions 

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

func (*NumPartitions) Descriptor deprecated 

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

Deprecated: Use NumPartitions.ProtoReflect.Descriptor instead.

func (*NumPartitions) GetNumPartitions 

func (x *NumPartitions) GetNumPartitions() uint64

func (*NumPartitions) ProtoMessage 

func (*NumPartitions) ProtoMessage()

func (*NumPartitions) ProtoReflect 

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

func (*NumPartitions) Reset 

func (x *NumPartitions) Reset()

func (*NumPartitions) String 

func (x *NumPartitions) String() string

type PartitionAssignmentStrategy 

type PartitionAssignmentStrategy int32
const (
	PartitionAssignmentStrategy_STATIC PartitionAssignmentStrategy = 0
)

func (PartitionAssignmentStrategy) Descriptor 

func (PartitionAssignmentStrategy) Descriptor() protoreflect.EnumDescriptor

func (PartitionAssignmentStrategy) Enum 

func (x PartitionAssignmentStrategy) Enum() *PartitionAssignmentStrategy

func (PartitionAssignmentStrategy) EnumDescriptor deprecated 

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

Deprecated: Use PartitionAssignmentStrategy.Descriptor instead.

func (PartitionAssignmentStrategy) Number 

func (x PartitionAssignmentStrategy) Number() protoreflect.EnumNumber

func (PartitionAssignmentStrategy) String 

func (x PartitionAssignmentStrategy) String() string

func (PartitionAssignmentStrategy) Type 

func (PartitionAssignmentStrategy) Type() protoreflect.EnumType

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetCount 

func (x *PingRequest) GetCount() int32

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PongResponse 

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

func (*PongResponse) Descriptor deprecated 

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

Deprecated: Use PongResponse.ProtoReflect.Descriptor instead.

func (*PongResponse) GetCount 

func (x *PongResponse) GetCount() int32

func (*PongResponse) ProtoMessage 

func (*PongResponse) ProtoMessage()

func (*PongResponse) ProtoReflect 

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

func (*PongResponse) Reset 

func (x *PongResponse) Reset()

func (*PongResponse) String 

func (x *PongResponse) String() string

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"`
	NumPartitions *NumPartitions `protobuf:"bytes,2,opt,name=num_partitions,json=numPartitions,proto3" json:"num_partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*Rewards) Descriptor deprecated 

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

Deprecated: Use Rewards.ProtoReflect.Descriptor instead.

func (*Rewards) GetNumPartitions 

func (x *Rewards) GetNumPartitions() *NumPartitions

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 SubscribeRequest 

type SubscribeRequest struct {
	Accounts           map[string]*SubscribeRequestFilterAccounts     `` /* 157-byte string literal not displayed */
	Slots              map[string]*SubscribeRequestFilterSlots        `` /* 151-byte string literal not displayed */
	Transactions       map[string]*SubscribeRequestFilterTransactions `` /* 165-byte string literal not displayed */
	TransactionsStatus map[string]*SubscribeRequestFilterTransactions `` /* 204-byte string literal not displayed */
	Blocks             map[string]*SubscribeRequestFilterBlocks       `` /* 153-byte string literal not displayed */
	BlocksMeta         map[string]*SubscribeRequestFilterBlocksMeta   `` /* 179-byte string literal not displayed */
	Entry              map[string]*SubscribeRequestFilterEntry        `` /* 151-byte string literal not displayed */
	Commitment         *CommitmentLevel                               `protobuf:"varint,6,opt,name=commitment,proto3,enum=geyser.CommitmentLevel,oneof" json:"commitment,omitempty"`
	AccountsDataSlice  []*SubscribeRequestAccountsDataSlice           `protobuf:"bytes,7,rep,name=accounts_data_slice,json=accountsDataSlice,proto3" json:"accounts_data_slice,omitempty"`
	Ping               *SubscribeRequestPing                          `protobuf:"bytes,9,opt,name=ping,proto3,oneof" json:"ping,omitempty"`
	FromSlot           *uint64                                        `protobuf:"varint,11,opt,name=from_slot,json=fromSlot,proto3,oneof" json:"from_slot,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetAccounts 

func (x *SubscribeRequest) GetAccounts() map[string]*SubscribeRequestFilterAccounts

func (*SubscribeRequest) GetAccountsDataSlice 

func (x *SubscribeRequest) GetAccountsDataSlice() []*SubscribeRequestAccountsDataSlice

func (*SubscribeRequest) GetBlocks 

func (x *SubscribeRequest) GetBlocks() map[string]*SubscribeRequestFilterBlocks

func (*SubscribeRequest) GetBlocksMeta 

func (x *SubscribeRequest) GetBlocksMeta() map[string]*SubscribeRequestFilterBlocksMeta

func (*SubscribeRequest) GetCommitment 

func (x *SubscribeRequest) GetCommitment() CommitmentLevel

func (*SubscribeRequest) GetEntry 

func (x *SubscribeRequest) GetEntry() map[string]*SubscribeRequestFilterEntry

func (*SubscribeRequest) GetFromSlot 

func (x *SubscribeRequest) GetFromSlot() uint64

func (*SubscribeRequest) GetPing 

func (x *SubscribeRequest) GetPing() *SubscribeRequestPing

func (*SubscribeRequest) GetSlots 

func (x *SubscribeRequest) GetSlots() map[string]*SubscribeRequestFilterSlots

func (*SubscribeRequest) GetTransactions 

func (x *SubscribeRequest) GetTransactions() map[string]*SubscribeRequestFilterTransactions

func (*SubscribeRequest) GetTransactionsStatus 

func (x *SubscribeRequest) GetTransactionsStatus() map[string]*SubscribeRequestFilterTransactions

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeRequestAccountsDataSlice 

type SubscribeRequestAccountsDataSlice struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Length uint64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestAccountsDataSlice) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestAccountsDataSlice.ProtoReflect.Descriptor instead.

func (*SubscribeRequestAccountsDataSlice) GetLength 

func (x *SubscribeRequestAccountsDataSlice) GetLength() uint64

func (*SubscribeRequestAccountsDataSlice) GetOffset 

func (x *SubscribeRequestAccountsDataSlice) GetOffset() uint64

func (*SubscribeRequestAccountsDataSlice) ProtoMessage 

func (*SubscribeRequestAccountsDataSlice) ProtoMessage()

func (*SubscribeRequestAccountsDataSlice) ProtoReflect 

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

func (*SubscribeRequestAccountsDataSlice) Reset 

func (x *SubscribeRequestAccountsDataSlice) Reset()

func (*SubscribeRequestAccountsDataSlice) String 

func (x *SubscribeRequestAccountsDataSlice) String() string

type SubscribeRequestFilterAccounts 

type SubscribeRequestFilterAccounts struct {
	Account              []string                                `protobuf:"bytes,2,rep,name=account,proto3" json:"account,omitempty"`
	Owner                []string                                `protobuf:"bytes,3,rep,name=owner,proto3" json:"owner,omitempty"`
	Filters              []*SubscribeRequestFilterAccountsFilter `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters,omitempty"`
	NonemptyTxnSignature *bool                                   `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterAccounts) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterAccounts.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterAccounts) GetAccount 

func (x *SubscribeRequestFilterAccounts) GetAccount() []string

func (*SubscribeRequestFilterAccounts) GetFilters 

func (x *SubscribeRequestFilterAccounts) GetFilters() []*SubscribeRequestFilterAccountsFilter

func (*SubscribeRequestFilterAccounts) GetNonemptyTxnSignature 

func (x *SubscribeRequestFilterAccounts) GetNonemptyTxnSignature() bool

func (*SubscribeRequestFilterAccounts) GetOwner 

func (x *SubscribeRequestFilterAccounts) GetOwner() []string

func (*SubscribeRequestFilterAccounts) ProtoMessage 

func (*SubscribeRequestFilterAccounts) ProtoMessage()

func (*SubscribeRequestFilterAccounts) ProtoReflect 

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

func (*SubscribeRequestFilterAccounts) Reset 

func (x *SubscribeRequestFilterAccounts) Reset()

func (*SubscribeRequestFilterAccounts) String 

func (x *SubscribeRequestFilterAccounts) String() string

type SubscribeRequestFilterAccountsFilter 

type SubscribeRequestFilterAccountsFilter struct {

	// Types that are assignable to Filter:
	//
	//	*SubscribeRequestFilterAccountsFilter_Memcmp
	//	*SubscribeRequestFilterAccountsFilter_Datasize
	//	*SubscribeRequestFilterAccountsFilter_TokenAccountState
	//	*SubscribeRequestFilterAccountsFilter_Lamports
	Filter isSubscribeRequestFilterAccountsFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterAccountsFilter) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterAccountsFilter.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterAccountsFilter) GetDatasize 

func (x *SubscribeRequestFilterAccountsFilter) GetDatasize() uint64

func (*SubscribeRequestFilterAccountsFilter) GetFilter 

func (m *SubscribeRequestFilterAccountsFilter) GetFilter() isSubscribeRequestFilterAccountsFilter_Filter

func (*SubscribeRequestFilterAccountsFilter) GetLamports 

func (x *SubscribeRequestFilterAccountsFilter) GetLamports() *SubscribeRequestFilterAccountsFilterLamports

func (*SubscribeRequestFilterAccountsFilter) GetMemcmp 

func (x *SubscribeRequestFilterAccountsFilter) GetMemcmp() *SubscribeRequestFilterAccountsFilterMemcmp

func (*SubscribeRequestFilterAccountsFilter) GetTokenAccountState 

func (x *SubscribeRequestFilterAccountsFilter) GetTokenAccountState() bool

func (*SubscribeRequestFilterAccountsFilter) ProtoMessage 

func (*SubscribeRequestFilterAccountsFilter) ProtoMessage()

func (*SubscribeRequestFilterAccountsFilter) ProtoReflect 

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

func (*SubscribeRequestFilterAccountsFilter) Reset 

func (x *SubscribeRequestFilterAccountsFilter) Reset()

func (*SubscribeRequestFilterAccountsFilter) String 

func (x *SubscribeRequestFilterAccountsFilter) String() string

type SubscribeRequestFilterAccountsFilterLamports 

type SubscribeRequestFilterAccountsFilterLamports struct {

	// Types that are assignable to Cmp:
	//
	//	*SubscribeRequestFilterAccountsFilterLamports_Eq
	//	*SubscribeRequestFilterAccountsFilterLamports_Ne
	//	*SubscribeRequestFilterAccountsFilterLamports_Lt
	//	*SubscribeRequestFilterAccountsFilterLamports_Gt
	Cmp isSubscribeRequestFilterAccountsFilterLamports_Cmp `protobuf_oneof:"cmp"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterAccountsFilterLamports) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterAccountsFilterLamports.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterAccountsFilterLamports) GetCmp 

func (m *SubscribeRequestFilterAccountsFilterLamports) GetCmp() isSubscribeRequestFilterAccountsFilterLamports_Cmp

func (*SubscribeRequestFilterAccountsFilterLamports) GetEq 

func (x *SubscribeRequestFilterAccountsFilterLamports) GetEq() uint64

func (*SubscribeRequestFilterAccountsFilterLamports) GetGt 

func (x *SubscribeRequestFilterAccountsFilterLamports) GetGt() uint64

func (*SubscribeRequestFilterAccountsFilterLamports) GetLt 

func (x *SubscribeRequestFilterAccountsFilterLamports) GetLt() uint64

func (*SubscribeRequestFilterAccountsFilterLamports) GetNe 

func (x *SubscribeRequestFilterAccountsFilterLamports) GetNe() uint64

func (*SubscribeRequestFilterAccountsFilterLamports) ProtoMessage 

func (*SubscribeRequestFilterAccountsFilterLamports) ProtoMessage()

func (*SubscribeRequestFilterAccountsFilterLamports) ProtoReflect 

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

func (*SubscribeRequestFilterAccountsFilterLamports) Reset 

func (x *SubscribeRequestFilterAccountsFilterLamports) Reset()

func (*SubscribeRequestFilterAccountsFilterLamports) String 

func (x *SubscribeRequestFilterAccountsFilterLamports) String() string

type SubscribeRequestFilterAccountsFilterLamports_Eq 

type SubscribeRequestFilterAccountsFilterLamports_Eq struct {
	Eq uint64 `protobuf:"varint,1,opt,name=eq,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilterLamports_Gt 

type SubscribeRequestFilterAccountsFilterLamports_Gt struct {
	Gt uint64 `protobuf:"varint,4,opt,name=gt,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilterLamports_Lt 

type SubscribeRequestFilterAccountsFilterLamports_Lt struct {
	Lt uint64 `protobuf:"varint,3,opt,name=lt,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilterLamports_Ne 

type SubscribeRequestFilterAccountsFilterLamports_Ne struct {
	Ne uint64 `protobuf:"varint,2,opt,name=ne,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilterMemcmp 

type SubscribeRequestFilterAccountsFilterMemcmp struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// Types that are assignable to Data:
	//
	//	*SubscribeRequestFilterAccountsFilterMemcmp_Bytes
	//	*SubscribeRequestFilterAccountsFilterMemcmp_Base58
	//	*SubscribeRequestFilterAccountsFilterMemcmp_Base64
	Data isSubscribeRequestFilterAccountsFilterMemcmp_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterAccountsFilterMemcmp) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterAccountsFilterMemcmp.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterAccountsFilterMemcmp) GetBase58 

func (x *SubscribeRequestFilterAccountsFilterMemcmp) GetBase58() string

func (*SubscribeRequestFilterAccountsFilterMemcmp) GetBase64 

func (x *SubscribeRequestFilterAccountsFilterMemcmp) GetBase64() string

func (*SubscribeRequestFilterAccountsFilterMemcmp) GetBytes 

func (x *SubscribeRequestFilterAccountsFilterMemcmp) GetBytes() []byte

func (*SubscribeRequestFilterAccountsFilterMemcmp) GetData 

func (m *SubscribeRequestFilterAccountsFilterMemcmp) GetData() isSubscribeRequestFilterAccountsFilterMemcmp_Data

func (*SubscribeRequestFilterAccountsFilterMemcmp) GetOffset 

func (x *SubscribeRequestFilterAccountsFilterMemcmp) GetOffset() uint64

func (*SubscribeRequestFilterAccountsFilterMemcmp) ProtoMessage 

func (*SubscribeRequestFilterAccountsFilterMemcmp) ProtoMessage()

func (*SubscribeRequestFilterAccountsFilterMemcmp) ProtoReflect 

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

func (*SubscribeRequestFilterAccountsFilterMemcmp) Reset 

func (x *SubscribeRequestFilterAccountsFilterMemcmp) Reset()

func (*SubscribeRequestFilterAccountsFilterMemcmp) String 

func (x *SubscribeRequestFilterAccountsFilterMemcmp) String() string

type SubscribeRequestFilterAccountsFilterMemcmp_Base58 

type SubscribeRequestFilterAccountsFilterMemcmp_Base58 struct {
	Base58 string `protobuf:"bytes,3,opt,name=base58,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilterMemcmp_Base64 

type SubscribeRequestFilterAccountsFilterMemcmp_Base64 struct {
	Base64 string `protobuf:"bytes,4,opt,name=base64,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilterMemcmp_Bytes 

type SubscribeRequestFilterAccountsFilterMemcmp_Bytes struct {
	Bytes []byte `protobuf:"bytes,2,opt,name=bytes,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilter_Datasize 

type SubscribeRequestFilterAccountsFilter_Datasize struct {
	Datasize uint64 `protobuf:"varint,2,opt,name=datasize,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilter_Lamports 

type SubscribeRequestFilterAccountsFilter_Lamports struct {
	Lamports *SubscribeRequestFilterAccountsFilterLamports `protobuf:"bytes,4,opt,name=lamports,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilter_Memcmp 

type SubscribeRequestFilterAccountsFilter_Memcmp struct {
	Memcmp *SubscribeRequestFilterAccountsFilterMemcmp `protobuf:"bytes,1,opt,name=memcmp,proto3,oneof"`
}

type SubscribeRequestFilterAccountsFilter_TokenAccountState 

type SubscribeRequestFilterAccountsFilter_TokenAccountState struct {
	TokenAccountState bool `protobuf:"varint,3,opt,name=token_account_state,json=tokenAccountState,proto3,oneof"`
}

type SubscribeRequestFilterBlocks 

type SubscribeRequestFilterBlocks struct {
	AccountInclude      []string `protobuf:"bytes,1,rep,name=account_include,json=accountInclude,proto3" json:"account_include,omitempty"`
	IncludeTransactions *bool    `protobuf:"varint,2,opt,name=include_transactions,json=includeTransactions,proto3,oneof" json:"include_transactions,omitempty"`
	IncludeAccounts     *bool    `protobuf:"varint,3,opt,name=include_accounts,json=includeAccounts,proto3,oneof" json:"include_accounts,omitempty"`
	IncludeEntries      *bool    `protobuf:"varint,4,opt,name=include_entries,json=includeEntries,proto3,oneof" json:"include_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterBlocks) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterBlocks.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterBlocks) GetAccountInclude 

func (x *SubscribeRequestFilterBlocks) GetAccountInclude() []string

func (*SubscribeRequestFilterBlocks) GetIncludeAccounts 

func (x *SubscribeRequestFilterBlocks) GetIncludeAccounts() bool

func (*SubscribeRequestFilterBlocks) GetIncludeEntries 

func (x *SubscribeRequestFilterBlocks) GetIncludeEntries() bool

func (*SubscribeRequestFilterBlocks) GetIncludeTransactions 

func (x *SubscribeRequestFilterBlocks) GetIncludeTransactions() bool

func (*SubscribeRequestFilterBlocks) ProtoMessage 

func (*SubscribeRequestFilterBlocks) ProtoMessage()

func (*SubscribeRequestFilterBlocks) ProtoReflect 

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

func (*SubscribeRequestFilterBlocks) Reset 

func (x *SubscribeRequestFilterBlocks) Reset()

func (*SubscribeRequestFilterBlocks) String 

func (x *SubscribeRequestFilterBlocks) String() string

type SubscribeRequestFilterBlocksMeta 

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

func (*SubscribeRequestFilterBlocksMeta) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterBlocksMeta.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterBlocksMeta) ProtoMessage 

func (*SubscribeRequestFilterBlocksMeta) ProtoMessage()

func (*SubscribeRequestFilterBlocksMeta) ProtoReflect 

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

func (*SubscribeRequestFilterBlocksMeta) Reset 

func (x *SubscribeRequestFilterBlocksMeta) Reset()

func (*SubscribeRequestFilterBlocksMeta) String 

func (x *SubscribeRequestFilterBlocksMeta) String() string

type SubscribeRequestFilterEntry 

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

func (*SubscribeRequestFilterEntry) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterEntry.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterEntry) ProtoMessage 

func (*SubscribeRequestFilterEntry) ProtoMessage()

func (*SubscribeRequestFilterEntry) ProtoReflect 

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

func (*SubscribeRequestFilterEntry) Reset 

func (x *SubscribeRequestFilterEntry) Reset()

func (*SubscribeRequestFilterEntry) String 

func (x *SubscribeRequestFilterEntry) String() string

type SubscribeRequestFilterSlots 

type SubscribeRequestFilterSlots struct {
	FilterByCommitment *bool `protobuf:"varint,1,opt,name=filter_by_commitment,json=filterByCommitment,proto3,oneof" json:"filter_by_commitment,omitempty"`
	InterslotUpdates   *bool `protobuf:"varint,2,opt,name=interslot_updates,json=interslotUpdates,proto3,oneof" json:"interslot_updates,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterSlots) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterSlots.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterSlots) GetFilterByCommitment 

func (x *SubscribeRequestFilterSlots) GetFilterByCommitment() bool

func (*SubscribeRequestFilterSlots) GetInterslotUpdates 

func (x *SubscribeRequestFilterSlots) GetInterslotUpdates() bool

func (*SubscribeRequestFilterSlots) ProtoMessage 

func (*SubscribeRequestFilterSlots) ProtoMessage()

func (*SubscribeRequestFilterSlots) ProtoReflect 

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

func (*SubscribeRequestFilterSlots) Reset 

func (x *SubscribeRequestFilterSlots) Reset()

func (*SubscribeRequestFilterSlots) String 

func (x *SubscribeRequestFilterSlots) String() string

type SubscribeRequestFilterTransactions 

type SubscribeRequestFilterTransactions struct {
	Vote            *bool    `protobuf:"varint,1,opt,name=vote,proto3,oneof" json:"vote,omitempty"`
	Failed          *bool    `protobuf:"varint,2,opt,name=failed,proto3,oneof" json:"failed,omitempty"`
	Signature       *string  `protobuf:"bytes,5,opt,name=signature,proto3,oneof" json:"signature,omitempty"`
	AccountInclude  []string `protobuf:"bytes,3,rep,name=account_include,json=accountInclude,proto3" json:"account_include,omitempty"`
	AccountExclude  []string `protobuf:"bytes,4,rep,name=account_exclude,json=accountExclude,proto3" json:"account_exclude,omitempty"`
	AccountRequired []string `protobuf:"bytes,6,rep,name=account_required,json=accountRequired,proto3" json:"account_required,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestFilterTransactions) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestFilterTransactions.ProtoReflect.Descriptor instead.

func (*SubscribeRequestFilterTransactions) GetAccountExclude 

func (x *SubscribeRequestFilterTransactions) GetAccountExclude() []string

func (*SubscribeRequestFilterTransactions) GetAccountInclude 

func (x *SubscribeRequestFilterTransactions) GetAccountInclude() []string

func (*SubscribeRequestFilterTransactions) GetAccountRequired 

func (x *SubscribeRequestFilterTransactions) GetAccountRequired() []string

func (*SubscribeRequestFilterTransactions) GetFailed 

func (x *SubscribeRequestFilterTransactions) GetFailed() bool

func (*SubscribeRequestFilterTransactions) GetSignature 

func (x *SubscribeRequestFilterTransactions) GetSignature() string

func (*SubscribeRequestFilterTransactions) GetVote 

func (x *SubscribeRequestFilterTransactions) GetVote() bool

func (*SubscribeRequestFilterTransactions) ProtoMessage 

func (*SubscribeRequestFilterTransactions) ProtoMessage()

func (*SubscribeRequestFilterTransactions) ProtoReflect 

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

func (*SubscribeRequestFilterTransactions) Reset 

func (x *SubscribeRequestFilterTransactions) Reset()

func (*SubscribeRequestFilterTransactions) String 

func (x *SubscribeRequestFilterTransactions) String() string

type SubscribeRequestPing 

type SubscribeRequestPing struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequestPing) Descriptor deprecated 

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

Deprecated: Use SubscribeRequestPing.ProtoReflect.Descriptor instead.

func (*SubscribeRequestPing) GetId 

func (x *SubscribeRequestPing) GetId() int32

func (*SubscribeRequestPing) ProtoMessage 

func (*SubscribeRequestPing) ProtoMessage()

func (*SubscribeRequestPing) ProtoReflect 

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

func (*SubscribeRequestPing) Reset 

func (x *SubscribeRequestPing) Reset()

func (*SubscribeRequestPing) String 

func (x *SubscribeRequestPing) String() string

type SubscribeUpdate 

type SubscribeUpdate struct {
	Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// Types that are assignable to UpdateOneof:
	//
	//	*SubscribeUpdate_Account
	//	*SubscribeUpdate_Slot
	//	*SubscribeUpdate_Transaction
	//	*SubscribeUpdate_TransactionStatus
	//	*SubscribeUpdate_Block
	//	*SubscribeUpdate_Ping
	//	*SubscribeUpdate_Pong
	//	*SubscribeUpdate_BlockMeta
	//	*SubscribeUpdate_Entry
	UpdateOneof isSubscribeUpdate_UpdateOneof `protobuf_oneof:"update_oneof"`
	CreatedAt   *timestamppb.Timestamp        `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdate) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdate.ProtoReflect.Descriptor instead.

func (*SubscribeUpdate) GetAccount 

func (x *SubscribeUpdate) GetAccount() *SubscribeUpdateAccount

func (*SubscribeUpdate) GetBlock 

func (x *SubscribeUpdate) GetBlock() *SubscribeUpdateBlock

func (*SubscribeUpdate) GetBlockMeta 

func (x *SubscribeUpdate) GetBlockMeta() *SubscribeUpdateBlockMeta

func (*SubscribeUpdate) GetCreatedAt 

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

func (*SubscribeUpdate) GetEntry 

func (x *SubscribeUpdate) GetEntry() *SubscribeUpdateEntry

func (*SubscribeUpdate) GetFilters 

func (x *SubscribeUpdate) GetFilters() []string

func (*SubscribeUpdate) GetPing 

func (x *SubscribeUpdate) GetPing() *SubscribeUpdatePing

func (*SubscribeUpdate) GetPong 

func (x *SubscribeUpdate) GetPong() *SubscribeUpdatePong

func (*SubscribeUpdate) GetSlot 

func (x *SubscribeUpdate) GetSlot() *SubscribeUpdateSlot

func (*SubscribeUpdate) GetTransaction 

func (x *SubscribeUpdate) GetTransaction() *SubscribeUpdateTransaction

func (*SubscribeUpdate) GetTransactionStatus 

func (x *SubscribeUpdate) GetTransactionStatus() *SubscribeUpdateTransactionStatus

func (*SubscribeUpdate) GetUpdateOneof 

func (m *SubscribeUpdate) GetUpdateOneof() isSubscribeUpdate_UpdateOneof

func (*SubscribeUpdate) ProtoMessage 

func (*SubscribeUpdate) ProtoMessage()

func (*SubscribeUpdate) ProtoReflect 

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

func (*SubscribeUpdate) Reset 

func (x *SubscribeUpdate) Reset()

func (*SubscribeUpdate) String 

func (x *SubscribeUpdate) String() string

type SubscribeUpdateAccount 

type SubscribeUpdateAccount struct {
	Account   *SubscribeUpdateAccountInfo `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
	Slot      uint64                      `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"`
	IsStartup bool                        `protobuf:"varint,3,opt,name=is_startup,json=isStartup,proto3" json:"is_startup,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateAccount) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateAccount.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateAccount) GetAccount 

func (x *SubscribeUpdateAccount) GetAccount() *SubscribeUpdateAccountInfo

func (*SubscribeUpdateAccount) GetIsStartup 

func (x *SubscribeUpdateAccount) GetIsStartup() bool

func (*SubscribeUpdateAccount) GetSlot 

func (x *SubscribeUpdateAccount) GetSlot() uint64

func (*SubscribeUpdateAccount) ProtoMessage 

func (*SubscribeUpdateAccount) ProtoMessage()

func (*SubscribeUpdateAccount) ProtoReflect 

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

func (*SubscribeUpdateAccount) Reset 

func (x *SubscribeUpdateAccount) Reset()

func (*SubscribeUpdateAccount) String 

func (x *SubscribeUpdateAccount) String() string

type SubscribeUpdateAccountInfo 

type SubscribeUpdateAccountInfo struct {
	Pubkey       []byte `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	Lamports     uint64 `protobuf:"varint,2,opt,name=lamports,proto3" json:"lamports,omitempty"`
	Owner        []byte `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	Executable   bool   `protobuf:"varint,4,opt,name=executable,proto3" json:"executable,omitempty"`
	RentEpoch    uint64 `protobuf:"varint,5,opt,name=rent_epoch,json=rentEpoch,proto3" json:"rent_epoch,omitempty"`
	Data         []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	WriteVersion uint64 `protobuf:"varint,7,opt,name=write_version,json=writeVersion,proto3" json:"write_version,omitempty"`
	TxnSignature []byte `protobuf:"bytes,8,opt,name=txn_signature,json=txnSignature,proto3,oneof" json:"txn_signature,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateAccountInfo) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateAccountInfo.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateAccountInfo) GetData 

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

func (*SubscribeUpdateAccountInfo) GetExecutable 

func (x *SubscribeUpdateAccountInfo) GetExecutable() bool

func (*SubscribeUpdateAccountInfo) GetLamports 

func (x *SubscribeUpdateAccountInfo) GetLamports() uint64

func (*SubscribeUpdateAccountInfo) GetOwner 

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

func (*SubscribeUpdateAccountInfo) GetPubkey 

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

func (*SubscribeUpdateAccountInfo) GetRentEpoch 

func (x *SubscribeUpdateAccountInfo) GetRentEpoch() uint64

func (*SubscribeUpdateAccountInfo) GetTxnSignature 

func (x *SubscribeUpdateAccountInfo) GetTxnSignature() []byte

func (*SubscribeUpdateAccountInfo) GetWriteVersion 

func (x *SubscribeUpdateAccountInfo) GetWriteVersion() uint64

func (*SubscribeUpdateAccountInfo) ProtoMessage 

func (*SubscribeUpdateAccountInfo) ProtoMessage()

func (*SubscribeUpdateAccountInfo) ProtoReflect 

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

func (*SubscribeUpdateAccountInfo) Reset 

func (x *SubscribeUpdateAccountInfo) Reset()

func (*SubscribeUpdateAccountInfo) String 

func (x *SubscribeUpdateAccountInfo) String() string

type SubscribeUpdateBlock 

type SubscribeUpdateBlock 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                  *Rewards                          `protobuf:"bytes,3,opt,name=rewards,proto3" json:"rewards,omitempty"`
	BlockTime                *UnixTimestamp                    `protobuf:"bytes,4,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	BlockHeight              *BlockHeight                      `protobuf:"bytes,5,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	ParentSlot               uint64                            `protobuf:"varint,7,opt,name=parent_slot,json=parentSlot,proto3" json:"parent_slot,omitempty"`
	ParentBlockhash          string                            `protobuf:"bytes,8,opt,name=parent_blockhash,json=parentBlockhash,proto3" json:"parent_blockhash,omitempty"`
	ExecutedTransactionCount uint64                            `` /* 136-byte string literal not displayed */
	Transactions             []*SubscribeUpdateTransactionInfo `protobuf:"bytes,6,rep,name=transactions,proto3" json:"transactions,omitempty"`
	UpdatedAccountCount      uint64                            `protobuf:"varint,10,opt,name=updated_account_count,json=updatedAccountCount,proto3" json:"updated_account_count,omitempty"`
	Accounts                 []*SubscribeUpdateAccountInfo     `protobuf:"bytes,11,rep,name=accounts,proto3" json:"accounts,omitempty"`
	EntriesCount             uint64                            `protobuf:"varint,12,opt,name=entries_count,json=entriesCount,proto3" json:"entries_count,omitempty"`
	Entries                  []*SubscribeUpdateEntry           `protobuf:"bytes,13,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateBlock) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateBlock.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateBlock) GetAccounts 

func (x *SubscribeUpdateBlock) GetAccounts() []*SubscribeUpdateAccountInfo

func (*SubscribeUpdateBlock) GetBlockHeight 

func (x *SubscribeUpdateBlock) GetBlockHeight() *BlockHeight

func (*SubscribeUpdateBlock) GetBlockTime 

func (x *SubscribeUpdateBlock) GetBlockTime() *UnixTimestamp

func (*SubscribeUpdateBlock) GetBlockhash 

func (x *SubscribeUpdateBlock) GetBlockhash() string

func (*SubscribeUpdateBlock) GetEntries 

func (x *SubscribeUpdateBlock) GetEntries() []*SubscribeUpdateEntry

func (*SubscribeUpdateBlock) GetEntriesCount 

func (x *SubscribeUpdateBlock) GetEntriesCount() uint64

func (*SubscribeUpdateBlock) GetExecutedTransactionCount 

func (x *SubscribeUpdateBlock) GetExecutedTransactionCount() uint64

func (*SubscribeUpdateBlock) GetParentBlockhash 

func (x *SubscribeUpdateBlock) GetParentBlockhash() string

func (*SubscribeUpdateBlock) GetParentSlot 

func (x *SubscribeUpdateBlock) GetParentSlot() uint64

func (*SubscribeUpdateBlock) GetRewards 

func (x *SubscribeUpdateBlock) GetRewards() *Rewards

func (*SubscribeUpdateBlock) GetSlot 

func (x *SubscribeUpdateBlock) GetSlot() uint64

func (*SubscribeUpdateBlock) GetTransactions 

func (x *SubscribeUpdateBlock) GetTransactions() []*SubscribeUpdateTransactionInfo

func (*SubscribeUpdateBlock) GetUpdatedAccountCount 

func (x *SubscribeUpdateBlock) GetUpdatedAccountCount() uint64

func (*SubscribeUpdateBlock) ProtoMessage 

func (*SubscribeUpdateBlock) ProtoMessage()

func (*SubscribeUpdateBlock) ProtoReflect 

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

func (*SubscribeUpdateBlock) Reset 

func (x *SubscribeUpdateBlock) Reset()

func (*SubscribeUpdateBlock) String 

func (x *SubscribeUpdateBlock) String() string

type SubscribeUpdateBlockMeta 

type SubscribeUpdateBlockMeta 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                  *Rewards       `protobuf:"bytes,3,opt,name=rewards,proto3" json:"rewards,omitempty"`
	BlockTime                *UnixTimestamp `protobuf:"bytes,4,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	BlockHeight              *BlockHeight   `protobuf:"bytes,5,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	ParentSlot               uint64         `protobuf:"varint,6,opt,name=parent_slot,json=parentSlot,proto3" json:"parent_slot,omitempty"`
	ParentBlockhash          string         `protobuf:"bytes,7,opt,name=parent_blockhash,json=parentBlockhash,proto3" json:"parent_blockhash,omitempty"`
	ExecutedTransactionCount uint64         `` /* 136-byte string literal not displayed */
	EntriesCount             uint64         `protobuf:"varint,9,opt,name=entries_count,json=entriesCount,proto3" json:"entries_count,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateBlockMeta) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateBlockMeta.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateBlockMeta) GetBlockHeight 

func (x *SubscribeUpdateBlockMeta) GetBlockHeight() *BlockHeight

func (*SubscribeUpdateBlockMeta) GetBlockTime 

func (x *SubscribeUpdateBlockMeta) GetBlockTime() *UnixTimestamp

func (*SubscribeUpdateBlockMeta) GetBlockhash 

func (x *SubscribeUpdateBlockMeta) GetBlockhash() string

func (*SubscribeUpdateBlockMeta) GetEntriesCount 

func (x *SubscribeUpdateBlockMeta) GetEntriesCount() uint64

func (*SubscribeUpdateBlockMeta) GetExecutedTransactionCount 

func (x *SubscribeUpdateBlockMeta) GetExecutedTransactionCount() uint64

func (*SubscribeUpdateBlockMeta) GetParentBlockhash 

func (x *SubscribeUpdateBlockMeta) GetParentBlockhash() string

func (*SubscribeUpdateBlockMeta) GetParentSlot 

func (x *SubscribeUpdateBlockMeta) GetParentSlot() uint64

func (*SubscribeUpdateBlockMeta) GetRewards 

func (x *SubscribeUpdateBlockMeta) GetRewards() *Rewards

func (*SubscribeUpdateBlockMeta) GetSlot 

func (x *SubscribeUpdateBlockMeta) GetSlot() uint64

func (*SubscribeUpdateBlockMeta) ProtoMessage 

func (*SubscribeUpdateBlockMeta) ProtoMessage()

func (*SubscribeUpdateBlockMeta) ProtoReflect 

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

func (*SubscribeUpdateBlockMeta) Reset 

func (x *SubscribeUpdateBlockMeta) Reset()

func (*SubscribeUpdateBlockMeta) String 

func (x *SubscribeUpdateBlockMeta) String() string

type SubscribeUpdateEntry 

type SubscribeUpdateEntry struct {
	Slot                     uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Index                    uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	NumHashes                uint64 `protobuf:"varint,3,opt,name=num_hashes,json=numHashes,proto3" json:"num_hashes,omitempty"`
	Hash                     []byte `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	ExecutedTransactionCount uint64 `` /* 136-byte string literal not displayed */
	StartingTransactionIndex uint64 `` // added in v1.18, for solana 1.17 value is always 0
	/* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SubscribeUpdateEntry) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateEntry.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateEntry) GetExecutedTransactionCount 

func (x *SubscribeUpdateEntry) GetExecutedTransactionCount() uint64

func (*SubscribeUpdateEntry) GetHash 

func (x *SubscribeUpdateEntry) GetHash() []byte

func (*SubscribeUpdateEntry) GetIndex 

func (x *SubscribeUpdateEntry) GetIndex() uint64

func (*SubscribeUpdateEntry) GetNumHashes 

func (x *SubscribeUpdateEntry) GetNumHashes() uint64

func (*SubscribeUpdateEntry) GetSlot 

func (x *SubscribeUpdateEntry) GetSlot() uint64

func (*SubscribeUpdateEntry) GetStartingTransactionIndex 

func (x *SubscribeUpdateEntry) GetStartingTransactionIndex() uint64

func (*SubscribeUpdateEntry) ProtoMessage 

func (*SubscribeUpdateEntry) ProtoMessage()

func (*SubscribeUpdateEntry) ProtoReflect 

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

func (*SubscribeUpdateEntry) Reset 

func (x *SubscribeUpdateEntry) Reset()

func (*SubscribeUpdateEntry) String 

func (x *SubscribeUpdateEntry) String() string

type SubscribeUpdatePing 

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

func (*SubscribeUpdatePing) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdatePing.ProtoReflect.Descriptor instead.

func (*SubscribeUpdatePing) ProtoMessage 

func (*SubscribeUpdatePing) ProtoMessage()

func (*SubscribeUpdatePing) ProtoReflect 

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

func (*SubscribeUpdatePing) Reset 

func (x *SubscribeUpdatePing) Reset()

func (*SubscribeUpdatePing) String 

func (x *SubscribeUpdatePing) String() string

type SubscribeUpdatePong 

type SubscribeUpdatePong struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdatePong) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdatePong.ProtoReflect.Descriptor instead.

func (*SubscribeUpdatePong) GetId 

func (x *SubscribeUpdatePong) GetId() int32

func (*SubscribeUpdatePong) ProtoMessage 

func (*SubscribeUpdatePong) ProtoMessage()

func (*SubscribeUpdatePong) ProtoReflect 

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

func (*SubscribeUpdatePong) Reset 

func (x *SubscribeUpdatePong) Reset()

func (*SubscribeUpdatePong) String 

func (x *SubscribeUpdatePong) String() string

type SubscribeUpdateSlot 

type SubscribeUpdateSlot struct {
	Slot      uint64          `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Parent    *uint64         `protobuf:"varint,2,opt,name=parent,proto3,oneof" json:"parent,omitempty"`
	Status    CommitmentLevel `protobuf:"varint,3,opt,name=status,proto3,enum=geyser.CommitmentLevel" json:"status,omitempty"`
	DeadError *string         `protobuf:"bytes,4,opt,name=dead_error,json=deadError,proto3,oneof" json:"dead_error,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateSlot) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateSlot.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateSlot) GetDeadError 

func (x *SubscribeUpdateSlot) GetDeadError() string

func (*SubscribeUpdateSlot) GetParent 

func (x *SubscribeUpdateSlot) GetParent() uint64

func (*SubscribeUpdateSlot) GetSlot 

func (x *SubscribeUpdateSlot) GetSlot() uint64

func (*SubscribeUpdateSlot) GetStatus 

func (x *SubscribeUpdateSlot) GetStatus() CommitmentLevel

func (*SubscribeUpdateSlot) ProtoMessage 

func (*SubscribeUpdateSlot) ProtoMessage()

func (*SubscribeUpdateSlot) ProtoReflect 

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

func (*SubscribeUpdateSlot) Reset 

func (x *SubscribeUpdateSlot) Reset()

func (*SubscribeUpdateSlot) String 

func (x *SubscribeUpdateSlot) String() string

type SubscribeUpdateTransaction 

type SubscribeUpdateTransaction struct {
	Transaction *SubscribeUpdateTransactionInfo `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Slot        uint64                          `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateTransaction) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateTransaction.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateTransaction) GetSlot 

func (x *SubscribeUpdateTransaction) GetSlot() uint64

func (*SubscribeUpdateTransaction) GetTransaction 

func (x *SubscribeUpdateTransaction) GetTransaction() *SubscribeUpdateTransactionInfo

func (*SubscribeUpdateTransaction) ProtoMessage 

func (*SubscribeUpdateTransaction) ProtoMessage()

func (*SubscribeUpdateTransaction) ProtoReflect 

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

func (*SubscribeUpdateTransaction) Reset 

func (x *SubscribeUpdateTransaction) Reset()

func (*SubscribeUpdateTransaction) String 

func (x *SubscribeUpdateTransaction) String() string

type SubscribeUpdateTransactionInfo 

type SubscribeUpdateTransactionInfo struct {
	Signature   []byte                 `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	IsVote      bool                   `protobuf:"varint,2,opt,name=is_vote,json=isVote,proto3" json:"is_vote,omitempty"`
	Transaction *Transaction           `protobuf:"bytes,3,opt,name=transaction,proto3" json:"transaction,omitempty"`
	Meta        *TransactionStatusMeta `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	Index       uint64                 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateTransactionInfo) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateTransactionInfo.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateTransactionInfo) GetIndex 

func (x *SubscribeUpdateTransactionInfo) GetIndex() uint64

func (*SubscribeUpdateTransactionInfo) GetIsVote 

func (x *SubscribeUpdateTransactionInfo) GetIsVote() bool

func (*SubscribeUpdateTransactionInfo) GetMeta 

func (x *SubscribeUpdateTransactionInfo) GetMeta() *TransactionStatusMeta

func (*SubscribeUpdateTransactionInfo) GetSignature 

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

func (*SubscribeUpdateTransactionInfo) GetTransaction 

func (x *SubscribeUpdateTransactionInfo) GetTransaction() *Transaction

func (*SubscribeUpdateTransactionInfo) ProtoMessage 

func (*SubscribeUpdateTransactionInfo) ProtoMessage()

func (*SubscribeUpdateTransactionInfo) ProtoReflect 

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

func (*SubscribeUpdateTransactionInfo) Reset 

func (x *SubscribeUpdateTransactionInfo) Reset()

func (*SubscribeUpdateTransactionInfo) String 

func (x *SubscribeUpdateTransactionInfo) String() string

type SubscribeUpdateTransactionStatus 

type SubscribeUpdateTransactionStatus struct {
	Slot      uint64            `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	Signature []byte            `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"`
	Index     uint64            `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
	Err       *TransactionError `protobuf:"bytes,5,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeUpdateTransactionStatus) Descriptor deprecated 

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

Deprecated: Use SubscribeUpdateTransactionStatus.ProtoReflect.Descriptor instead.

func (*SubscribeUpdateTransactionStatus) GetErr 

func (x *SubscribeUpdateTransactionStatus) GetErr() *TransactionError

func (*SubscribeUpdateTransactionStatus) GetIndex 

func (x *SubscribeUpdateTransactionStatus) GetIndex() uint64

func (*SubscribeUpdateTransactionStatus) GetIsVote 

func (x *SubscribeUpdateTransactionStatus) GetIsVote() bool

func (*SubscribeUpdateTransactionStatus) GetSignature 

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

func (*SubscribeUpdateTransactionStatus) GetSlot 

func (x *SubscribeUpdateTransactionStatus) GetSlot() uint64

func (*SubscribeUpdateTransactionStatus) ProtoMessage 

func (*SubscribeUpdateTransactionStatus) ProtoMessage()

func (*SubscribeUpdateTransactionStatus) ProtoReflect 

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

func (*SubscribeUpdateTransactionStatus) Reset 

func (x *SubscribeUpdateTransactionStatus) Reset()

func (*SubscribeUpdateTransactionStatus) String 

func (x *SubscribeUpdateTransactionStatus) String() string

type SubscribeUpdate_Account 

type SubscribeUpdate_Account struct {
	Account *SubscribeUpdateAccount `protobuf:"bytes,2,opt,name=account,proto3,oneof"`
}

type SubscribeUpdate_Block 

type SubscribeUpdate_Block struct {
	Block *SubscribeUpdateBlock `protobuf:"bytes,5,opt,name=block,proto3,oneof"`
}

type SubscribeUpdate_BlockMeta 

type SubscribeUpdate_BlockMeta struct {
	BlockMeta *SubscribeUpdateBlockMeta `protobuf:"bytes,7,opt,name=block_meta,json=blockMeta,proto3,oneof"`
}

type SubscribeUpdate_Entry 

type SubscribeUpdate_Entry struct {
	Entry *SubscribeUpdateEntry `protobuf:"bytes,8,opt,name=entry,proto3,oneof"`
}

type SubscribeUpdate_Ping 

type SubscribeUpdate_Ping struct {
	Ping *SubscribeUpdatePing `protobuf:"bytes,6,opt,name=ping,proto3,oneof"`
}

type SubscribeUpdate_Pong 

type SubscribeUpdate_Pong struct {
	Pong *SubscribeUpdatePong `protobuf:"bytes,9,opt,name=pong,proto3,oneof"`
}

type SubscribeUpdate_Slot 

type SubscribeUpdate_Slot struct {
	Slot *SubscribeUpdateSlot `protobuf:"bytes,3,opt,name=slot,proto3,oneof"`
}

type SubscribeUpdate_Transaction 

type SubscribeUpdate_Transaction struct {
	Transaction *SubscribeUpdateTransaction `protobuf:"bytes,4,opt,name=transaction,proto3,oneof"`
}

type SubscribeUpdate_TransactionStatus 

type SubscribeUpdate_TransactionStatus struct {
	TransactionStatus *SubscribeUpdateTransactionStatus `protobuf:"bytes,10,opt,name=transaction_status,json=transactionStatus,proto3,oneof"`
}

type TimelineTranslationPolicy 

type TimelineTranslationPolicy int32

/ Timeline Translation Policy / The TimelineTranslationPolicy enum defines different strategies for translating users to timelines based on their last seen slot number or a specified lag. This is particularly useful for managing data consumption in conjunction with the ConsumeRequest.ttp_maximum_slot_lag parameter. / / ALLOW_LAG / This policy allows users to be translated to a timeline that contains the last seen slot number or up to a certain lag. It extends the allowable lag for eligible timelines. / / Example: / / Suppose we have three timelines with the latest available slot numbers: / / timeline1 : 10 / timeline2 : 5 / timeline3 : 8 / If a consumer is assigned to timeline1 with ttp_maximum_slot_lag set to 2, then the only eligible destination timeline would be timeline3. / / STRICT_SLOT / Under this policy, eligible destination timelines must contain the last seen slot number in the current consumer timeline; otherwise, the translation fails. This ensures strict adherence to slot numbers when translating users to timelines. 

const (
	TimelineTranslationPolicy_ALLOW_LAG   TimelineTranslationPolicy = 0
	TimelineTranslationPolicy_STRICT_SLOT TimelineTranslationPolicy = 1
)

func (TimelineTranslationPolicy) Descriptor 

func (TimelineTranslationPolicy) Descriptor() protoreflect.EnumDescriptor

func (TimelineTranslationPolicy) Enum 

func (x TimelineTranslationPolicy) Enum() *TimelineTranslationPolicy

func (TimelineTranslationPolicy) EnumDescriptor deprecated 

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

Deprecated: Use TimelineTranslationPolicy.Descriptor instead.

func (TimelineTranslationPolicy) Number 

func (x TimelineTranslationPolicy) Number() protoreflect.EnumNumber

func (TimelineTranslationPolicy) String 

func (x TimelineTranslationPolicy) String() string

func (TimelineTranslationPolicy) Type 

func (TimelineTranslationPolicy) Type() protoreflect.EnumType

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 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 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 TransactionEventFilter 

type TransactionEventFilter struct {
	AccountKeys [][]byte `protobuf:"bytes,1,rep,name=account_keys,json=accountKeys,proto3" json:"account_keys,omitempty"`
	// contains filtered or unexported fields
}

/ account_keys (1) / A repeated field of bytes representing account keys. Events associated with any of these account keys will be included in the filtered results.

func (*TransactionEventFilter) Descriptor deprecated 

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

Deprecated: Use TransactionEventFilter.ProtoReflect.Descriptor instead.

func (*TransactionEventFilter) GetAccountKeys 

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

func (*TransactionEventFilter) ProtoMessage 

func (*TransactionEventFilter) ProtoMessage()

func (*TransactionEventFilter) ProtoReflect 

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

func (*TransactionEventFilter) Reset 

func (x *TransactionEventFilter) Reset()

func (*TransactionEventFilter) String 

func (x *TransactionEventFilter) String() string

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 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 UnimplementedGeyserServer 

type UnimplementedGeyserServer struct{}

UnimplementedGeyserServer must be embedded to have forward compatible implementations.

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

func (UnimplementedGeyserServer) GetBlockHeight 

func (UnimplementedGeyserServer) GetBlockHeight(context.Context, *GetBlockHeightRequest) (*GetBlockHeightResponse, error)

func (UnimplementedGeyserServer) GetLatestBlockhash 

func (UnimplementedGeyserServer) GetLatestBlockhash(context.Context, *GetLatestBlockhashRequest) (*GetLatestBlockhashResponse, error)

func (UnimplementedGeyserServer) GetSlot 

func (UnimplementedGeyserServer) GetSlot(context.Context, *GetSlotRequest) (*GetSlotResponse, error)

func (UnimplementedGeyserServer) GetVersion 

func (UnimplementedGeyserServer) GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)

func (UnimplementedGeyserServer) IsBlockhashValid 

func (UnimplementedGeyserServer) IsBlockhashValid(context.Context, *IsBlockhashValidRequest) (*IsBlockhashValidResponse, error)

func (UnimplementedGeyserServer) Ping 

func (UnimplementedGeyserServer) Ping(context.Context, *PingRequest) (*PongResponse, error)

func (UnimplementedGeyserServer) Subscribe 

func (UnimplementedGeyserServer) Subscribe(grpc.BidiStreamingServer[SubscribeRequest, SubscribeUpdate]) error

type UnimplementedYellowstoneLogServer 

type UnimplementedYellowstoneLogServer struct {
}

UnimplementedYellowstoneLogServer must be embedded to have forward compatible implementations.

func (UnimplementedYellowstoneLogServer) Consume 

func (UnimplementedYellowstoneLogServer) Consume(*ConsumeRequest, YellowstoneLog_ConsumeServer) error

func (UnimplementedYellowstoneLogServer) CreateStaticConsumerGroup 

func (UnimplementedYellowstoneLogServer) CreateStaticConsumerGroup(context.Context, *CreateStaticConsumerGroupRequest) (*CreateStaticConsumerGroupResponse, 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 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 UnsafeYellowstoneLogServer 

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

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

type YellowstoneLogClient 

type YellowstoneLogClient interface {
	CreateStaticConsumerGroup(ctx context.Context, in *CreateStaticConsumerGroupRequest, opts ...grpc.CallOption) (*CreateStaticConsumerGroupResponse, error)
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (YellowstoneLog_ConsumeClient, error)
}

YellowstoneLogClient is the client API for YellowstoneLog 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 NewYellowstoneLogClient 

func NewYellowstoneLogClient(cc grpc.ClientConnInterface) YellowstoneLogClient

type YellowstoneLogServer 

type YellowstoneLogServer interface {
	CreateStaticConsumerGroup(context.Context, *CreateStaticConsumerGroupRequest) (*CreateStaticConsumerGroupResponse, error)
	Consume(*ConsumeRequest, YellowstoneLog_ConsumeServer) error
	// contains filtered or unexported methods
}

YellowstoneLogServer is the server API for YellowstoneLog service. All implementations must embed UnimplementedYellowstoneLogServer for forward compatibility

type YellowstoneLog_ConsumeClient 

type YellowstoneLog_ConsumeClient interface {
	Recv() (*SubscribeUpdate, error)
	grpc.ClientStream
}

type YellowstoneLog_ConsumeServer 

type YellowstoneLog_ConsumeServer interface {
	Send(*SubscribeUpdate) error
	grpc.ServerStream
}

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.