pb

package
v1.0.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	Fumarole_ListAvailableCommitmentLevels_FullMethodName = "/fumarole.Fumarole/ListAvailableCommitmentLevels"
	Fumarole_GetConsumerGroupInfo_FullMethodName          = "/fumarole.Fumarole/GetConsumerGroupInfo"
	Fumarole_ListConsumerGroups_FullMethodName            = "/fumarole.Fumarole/ListConsumerGroups"
	Fumarole_DeleteConsumerGroup_FullMethodName           = "/fumarole.Fumarole/DeleteConsumerGroup"
	Fumarole_CreateStaticConsumerGroup_FullMethodName     = "/fumarole.Fumarole/CreateStaticConsumerGroup"
	Fumarole_Subscribe_FullMethodName                     = "/fumarole.Fumarole/Subscribe"
	Fumarole_GetSlotLagInfo_FullMethodName                = "/fumarole.Fumarole/GetSlotLagInfo"
	Fumarole_GetOldestSlot_FullMethodName                 = "/fumarole.Fumarole/GetOldestSlot"
)
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"
)

Variables

View Source 
var (
	ConsumerGroupType_name = map[int32]string{
		0: "STATIC",
	}
	ConsumerGroupType_value = map[string]int32{
		"STATIC": 0,
	}
)

Enum value maps for ConsumerGroupType.

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 (
	CommitmentLevel_name = map[int32]string{
		0: "PROCESSED",
		1: "CONFIRMED",
		2: "FINALIZED",
	}
	CommitmentLevel_value = map[string]int32{
		"PROCESSED": 0,
		"CONFIRMED": 1,
		"FINALIZED": 2,
	}
)

Enum value maps for CommitmentLevel.

View Source 
var (
	SlotStatus_name = map[int32]string{
		0: "SLOT_PROCESSED",
		1: "SLOT_CONFIRMED",
		2: "SLOT_FINALIZED",
		3: "SLOT_FIRST_SHRED_RECEIVED",
		4: "SLOT_COMPLETED",
		5: "SLOT_CREATED_BANK",
		6: "SLOT_DEAD",
	}
	SlotStatus_value = map[string]int32{
		"SLOT_PROCESSED":            0,
		"SLOT_CONFIRMED":            1,
		"SLOT_FINALIZED":            2,
		"SLOT_FIRST_SHRED_RECEIVED": 3,
		"SLOT_COMPLETED":            4,
		"SLOT_CREATED_BANK":         5,
		"SLOT_DEAD":                 6,
	}
)

Enum value maps for SlotStatus.

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 File_fumarole_proto protoreflect.FileDescriptor
View Source 
var File_geyser_proto protoreflect.FileDescriptor
View Source 
var File_solana_storage_proto protoreflect.FileDescriptor
View Source 
var Fumarole_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "fumarole.Fumarole",
	HandlerType: (*FumaroleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListAvailableCommitmentLevels",
			Handler:    _Fumarole_ListAvailableCommitmentLevels_Handler,
		},
		{
			MethodName: "GetConsumerGroupInfo",
			Handler:    _Fumarole_GetConsumerGroupInfo_Handler,
		},
		{
			MethodName: "ListConsumerGroups",
			Handler:    _Fumarole_ListConsumerGroups_Handler,
		},
		{
			MethodName: "DeleteConsumerGroup",
			Handler:    _Fumarole_DeleteConsumerGroup_Handler,
		},
		{
			MethodName: "CreateStaticConsumerGroup",
			Handler:    _Fumarole_CreateStaticConsumerGroup_Handler,
		},
		{
			MethodName: "GetSlotLagInfo",
			Handler:    _Fumarole_GetSlotLagInfo_Handler,
		},
		{
			MethodName: "GetOldestSlot",
			Handler:    _Fumarole_GetOldestSlot_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Fumarole_Subscribe_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "fumarole.proto",
}

Fumarole_ServiceDesc is the grpc.ServiceDesc for Fumarole 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 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)

Functions

func RegisterFumaroleServer 

func RegisterFumaroleServer(s grpc.ServiceRegistrar, srv FumaroleServer)

func RegisterGeyserServer 

func RegisterGeyserServer(s grpc.ServiceRegistrar, srv GeyserServer)

Types

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
)

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 ConsumerGroupInfo 

type ConsumerGroupInfo struct {
	Id                      string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ConsumerGroupLabel      string                  `protobuf:"bytes,2,opt,name=consumer_group_label,json=consumerGroupLabel,proto3" json:"consumer_group_label,omitempty"`
	ConsumerGroupType       ConsumerGroupType       `` /* 147-byte string literal not displayed */
	MemberCount             uint32                  `protobuf:"varint,4,opt,name=member_count,json=memberCount,proto3" json:"member_count,omitempty"`
	CommitmentLevel         CommitmentLevel         `` /* 135-byte string literal not displayed */
	EventSubscriptionPolicy EventSubscriptionPolicy `` /* 171-byte string literal not displayed */
	IsStale                 bool                    `protobuf:"varint,7,opt,name=is_stale,json=isStale,proto3" json:"is_stale,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerGroupInfo) Descriptor deprecated 

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

Deprecated: Use ConsumerGroupInfo.ProtoReflect.Descriptor instead.

func (*ConsumerGroupInfo) GetCommitmentLevel 

func (x *ConsumerGroupInfo) GetCommitmentLevel() CommitmentLevel

func (*ConsumerGroupInfo) GetConsumerGroupLabel 

func (x *ConsumerGroupInfo) GetConsumerGroupLabel() string

func (*ConsumerGroupInfo) GetConsumerGroupType 

func (x *ConsumerGroupInfo) GetConsumerGroupType() ConsumerGroupType

func (*ConsumerGroupInfo) GetEventSubscriptionPolicy 

func (x *ConsumerGroupInfo) GetEventSubscriptionPolicy() EventSubscriptionPolicy

func (*ConsumerGroupInfo) GetId 

func (x *ConsumerGroupInfo) GetId() string

func (*ConsumerGroupInfo) GetIsStale 

func (x *ConsumerGroupInfo) GetIsStale() bool

func (*ConsumerGroupInfo) GetMemberCount 

func (x *ConsumerGroupInfo) GetMemberCount() uint32

func (*ConsumerGroupInfo) ProtoMessage 

func (*ConsumerGroupInfo) ProtoMessage()

func (*ConsumerGroupInfo) ProtoReflect 

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

func (*ConsumerGroupInfo) Reset 

func (x *ConsumerGroupInfo) Reset()

func (*ConsumerGroupInfo) String 

func (x *ConsumerGroupInfo) String() string

type ConsumerGroupType 

type ConsumerGroupType int32
const (
	ConsumerGroupType_STATIC ConsumerGroupType = 0
)

func (ConsumerGroupType) Descriptor 

func (ConsumerGroupType) Descriptor() protoreflect.EnumDescriptor

func (ConsumerGroupType) Enum 

func (x ConsumerGroupType) Enum() *ConsumerGroupType

func (ConsumerGroupType) EnumDescriptor deprecated 

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

Deprecated: Use ConsumerGroupType.Descriptor instead.

func (ConsumerGroupType) Number 

func (x ConsumerGroupType) Number() protoreflect.EnumNumber

func (ConsumerGroupType) String 

func (x ConsumerGroupType) String() string

func (ConsumerGroupType) Type 

func (ConsumerGroupType) Type() protoreflect.EnumType

type CreateStaticConsumerGroupRequest 

type CreateStaticConsumerGroupRequest struct {
	ConsumerGroupLabel      string                  `protobuf:"bytes,1,opt,name=consumer_group_label,json=consumerGroupLabel,proto3" json:"consumer_group_label,omitempty"`
	MemberCount             *uint32                 `protobuf:"varint,2,opt,name=member_count,json=memberCount,proto3,oneof" json:"member_count,omitempty"`
	InitialOffsetPolicy     InitialOffsetPolicy     `` /* 155-byte string literal not displayed */
	CommitmentLevel         CommitmentLevel         `` /* 135-byte string literal not displayed */
	EventSubscriptionPolicy EventSubscriptionPolicy `` /* 171-byte string literal not displayed */
	AtSlot                  *int64                  `protobuf:"varint,6,opt,name=at_slot,json=atSlot,proto3,oneof" json:"at_slot,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStaticConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateStaticConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateStaticConsumerGroupRequest) GetAtSlot 

func (x *CreateStaticConsumerGroupRequest) GetAtSlot() int64

func (*CreateStaticConsumerGroupRequest) GetCommitmentLevel 

func (x *CreateStaticConsumerGroupRequest) GetCommitmentLevel() CommitmentLevel

func (*CreateStaticConsumerGroupRequest) GetConsumerGroupLabel 

func (x *CreateStaticConsumerGroupRequest) GetConsumerGroupLabel() string

func (*CreateStaticConsumerGroupRequest) GetEventSubscriptionPolicy 

func (x *CreateStaticConsumerGroupRequest) GetEventSubscriptionPolicy() EventSubscriptionPolicy

func (*CreateStaticConsumerGroupRequest) GetInitialOffsetPolicy 

func (x *CreateStaticConsumerGroupRequest) GetInitialOffsetPolicy() InitialOffsetPolicy

func (*CreateStaticConsumerGroupRequest) GetMemberCount 

func (x *CreateStaticConsumerGroupRequest) GetMemberCount() uint32

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 DeleteConsumerGroupRequest 

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

func (*DeleteConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteConsumerGroupRequest) GetConsumerGroupLabel 

func (x *DeleteConsumerGroupRequest) GetConsumerGroupLabel() string

func (*DeleteConsumerGroupRequest) ProtoMessage 

func (*DeleteConsumerGroupRequest) ProtoMessage()

func (*DeleteConsumerGroupRequest) ProtoReflect 

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

func (*DeleteConsumerGroupRequest) Reset 

func (x *DeleteConsumerGroupRequest) Reset()

func (*DeleteConsumerGroupRequest) String 

func (x *DeleteConsumerGroupRequest) String() string

type DeleteConsumerGroupResponse 

type DeleteConsumerGroupResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConsumerGroupResponse) Descriptor deprecated 

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

Deprecated: Use DeleteConsumerGroupResponse.ProtoReflect.Descriptor instead.

func (*DeleteConsumerGroupResponse) GetSuccess 

func (x *DeleteConsumerGroupResponse) GetSuccess() bool

func (*DeleteConsumerGroupResponse) ProtoMessage 

func (*DeleteConsumerGroupResponse) ProtoMessage()

func (*DeleteConsumerGroupResponse) ProtoReflect 

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

func (*DeleteConsumerGroupResponse) Reset 

func (x *DeleteConsumerGroupResponse) Reset()

func (*DeleteConsumerGroupResponse) String 

func (x *DeleteConsumerGroupResponse) String() string

type EventSubscriptionPolicy 

type EventSubscriptionPolicy int32
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 FumaroleClient 

type FumaroleClient interface {
	ListAvailableCommitmentLevels(ctx context.Context, in *ListAvailableCommitmentLevelsRequest, opts ...grpc.CallOption) (*ListAvailableCommitmentLevelsResponse, error)
	GetConsumerGroupInfo(ctx context.Context, in *GetConsumerGroupInfoRequest, opts ...grpc.CallOption) (*ConsumerGroupInfo, error)
	ListConsumerGroups(ctx context.Context, in *ListConsumerGroupsRequest, opts ...grpc.CallOption) (*ListConsumerGroupsResponse, error)
	DeleteConsumerGroup(ctx context.Context, in *DeleteConsumerGroupRequest, opts ...grpc.CallOption) (*DeleteConsumerGroupResponse, error)
	CreateStaticConsumerGroup(ctx context.Context, in *CreateStaticConsumerGroupRequest, opts ...grpc.CallOption) (*CreateStaticConsumerGroupResponse, error)
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeRequest, SubscribeUpdate], error)
	GetSlotLagInfo(ctx context.Context, in *GetSlotLagInfoRequest, opts ...grpc.CallOption) (*GetSlotLagInfoResponse, error)
	GetOldestSlot(ctx context.Context, in *GetOldestSlotRequest, opts ...grpc.CallOption) (*GetOldestSlotResponse, error)
}

FumaroleClient is the client API for Fumarole 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 NewFumaroleClient 

func NewFumaroleClient(cc grpc.ClientConnInterface) FumaroleClient

type FumaroleServer 

type FumaroleServer interface {
	ListAvailableCommitmentLevels(context.Context, *ListAvailableCommitmentLevelsRequest) (*ListAvailableCommitmentLevelsResponse, error)
	GetConsumerGroupInfo(context.Context, *GetConsumerGroupInfoRequest) (*ConsumerGroupInfo, error)
	ListConsumerGroups(context.Context, *ListConsumerGroupsRequest) (*ListConsumerGroupsResponse, error)
	DeleteConsumerGroup(context.Context, *DeleteConsumerGroupRequest) (*DeleteConsumerGroupResponse, error)
	CreateStaticConsumerGroup(context.Context, *CreateStaticConsumerGroupRequest) (*CreateStaticConsumerGroupResponse, error)
	Subscribe(grpc.BidiStreamingServer[SubscribeRequest, SubscribeUpdate]) error
	GetSlotLagInfo(context.Context, *GetSlotLagInfoRequest) (*GetSlotLagInfoResponse, error)
	GetOldestSlot(context.Context, *GetOldestSlotRequest) (*GetOldestSlotResponse, error)
	// contains filtered or unexported methods
}

FumaroleServer is the server API for Fumarole service. All implementations must embed UnimplementedFumaroleServer for forward compatibility.

type Fumarole_SubscribeClient 

type Fumarole_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 Fumarole_SubscribeServer 

type Fumarole_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 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 GetConsumerGroupInfoRequest 

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

func (*GetConsumerGroupInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetConsumerGroupInfoRequest.ProtoReflect.Descriptor instead.

func (*GetConsumerGroupInfoRequest) GetConsumerGroupLabel 

func (x *GetConsumerGroupInfoRequest) GetConsumerGroupLabel() string

func (*GetConsumerGroupInfoRequest) ProtoMessage 

func (*GetConsumerGroupInfoRequest) ProtoMessage()

func (*GetConsumerGroupInfoRequest) ProtoReflect 

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

func (*GetConsumerGroupInfoRequest) Reset 

func (x *GetConsumerGroupInfoRequest) Reset()

func (*GetConsumerGroupInfoRequest) String 

func (x *GetConsumerGroupInfoRequest) 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 GetOldestSlotRequest 

type GetOldestSlotRequest struct {
	CommitmentLevel CommitmentLevel `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetOldestSlotRequest) Descriptor deprecated 

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

Deprecated: Use GetOldestSlotRequest.ProtoReflect.Descriptor instead.

func (*GetOldestSlotRequest) GetCommitmentLevel 

func (x *GetOldestSlotRequest) GetCommitmentLevel() CommitmentLevel

func (*GetOldestSlotRequest) ProtoMessage 

func (*GetOldestSlotRequest) ProtoMessage()

func (*GetOldestSlotRequest) ProtoReflect 

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

func (*GetOldestSlotRequest) Reset 

func (x *GetOldestSlotRequest) Reset()

func (*GetOldestSlotRequest) String 

func (x *GetOldestSlotRequest) String() string

type GetOldestSlotResponse 

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

func (*GetOldestSlotResponse) Descriptor deprecated 

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

Deprecated: Use GetOldestSlotResponse.ProtoReflect.Descriptor instead.

func (*GetOldestSlotResponse) GetSlot 

func (x *GetOldestSlotResponse) GetSlot() uint64

func (*GetOldestSlotResponse) ProtoMessage 

func (*GetOldestSlotResponse) ProtoMessage()

func (*GetOldestSlotResponse) ProtoReflect 

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

func (*GetOldestSlotResponse) Reset 

func (x *GetOldestSlotResponse) Reset()

func (*GetOldestSlotResponse) String 

func (x *GetOldestSlotResponse) String() string

type GetSlotLagInfoRequest 

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

func (*GetSlotLagInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetSlotLagInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSlotLagInfoRequest) GetConsumerGroupLabel 

func (x *GetSlotLagInfoRequest) GetConsumerGroupLabel() string

func (*GetSlotLagInfoRequest) ProtoMessage 

func (*GetSlotLagInfoRequest) ProtoMessage()

func (*GetSlotLagInfoRequest) ProtoReflect 

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

func (*GetSlotLagInfoRequest) Reset 

func (x *GetSlotLagInfoRequest) Reset()

func (*GetSlotLagInfoRequest) String 

func (x *GetSlotLagInfoRequest) String() string

type GetSlotLagInfoResponse 

type GetSlotLagInfoResponse struct {
	MaxSlotSeen   uint64 `protobuf:"varint,1,opt,name=max_slot_seen,json=maxSlotSeen,proto3" json:"max_slot_seen,omitempty"`
	GlobalMaxSlot uint64 `protobuf:"varint,2,opt,name=global_max_slot,json=globalMaxSlot,proto3" json:"global_max_slot,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSlotLagInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetSlotLagInfoResponse.ProtoReflect.Descriptor instead.

func (*GetSlotLagInfoResponse) GetGlobalMaxSlot 

func (x *GetSlotLagInfoResponse) GetGlobalMaxSlot() uint64

func (*GetSlotLagInfoResponse) GetMaxSlotSeen 

func (x *GetSlotLagInfoResponse) GetMaxSlotSeen() uint64

func (*GetSlotLagInfoResponse) ProtoMessage 

func (*GetSlotLagInfoResponse) ProtoMessage()

func (*GetSlotLagInfoResponse) ProtoReflect 

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

func (*GetSlotLagInfoResponse) Reset 

func (x *GetSlotLagInfoResponse) Reset()

func (*GetSlotLagInfoResponse) String 

func (x *GetSlotLagInfoResponse) 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
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 ListAvailableCommitmentLevelsRequest 

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

func (*ListAvailableCommitmentLevelsRequest) Descriptor deprecated 

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

Deprecated: Use ListAvailableCommitmentLevelsRequest.ProtoReflect.Descriptor instead.

func (*ListAvailableCommitmentLevelsRequest) ProtoMessage 

func (*ListAvailableCommitmentLevelsRequest) ProtoMessage()

func (*ListAvailableCommitmentLevelsRequest) ProtoReflect 

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

func (*ListAvailableCommitmentLevelsRequest) Reset 

func (x *ListAvailableCommitmentLevelsRequest) Reset()

func (*ListAvailableCommitmentLevelsRequest) String 

func (x *ListAvailableCommitmentLevelsRequest) String() string

type ListAvailableCommitmentLevelsResponse 

type ListAvailableCommitmentLevelsResponse struct {
	CommitmentLevels []CommitmentLevel `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListAvailableCommitmentLevelsResponse) Descriptor deprecated 

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

Deprecated: Use ListAvailableCommitmentLevelsResponse.ProtoReflect.Descriptor instead.

func (*ListAvailableCommitmentLevelsResponse) GetCommitmentLevels 

func (x *ListAvailableCommitmentLevelsResponse) GetCommitmentLevels() []CommitmentLevel

func (*ListAvailableCommitmentLevelsResponse) ProtoMessage 

func (*ListAvailableCommitmentLevelsResponse) ProtoMessage()

func (*ListAvailableCommitmentLevelsResponse) ProtoReflect 

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

func (*ListAvailableCommitmentLevelsResponse) Reset 

func (x *ListAvailableCommitmentLevelsResponse) Reset()

func (*ListAvailableCommitmentLevelsResponse) String 

func (x *ListAvailableCommitmentLevelsResponse) String() string

type ListConsumerGroupsRequest 

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

func (*ListConsumerGroupsRequest) Descriptor deprecated 

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

Deprecated: Use ListConsumerGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListConsumerGroupsRequest) ProtoMessage 

func (*ListConsumerGroupsRequest) ProtoMessage()

func (*ListConsumerGroupsRequest) ProtoReflect 

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

func (*ListConsumerGroupsRequest) Reset 

func (x *ListConsumerGroupsRequest) Reset()

func (*ListConsumerGroupsRequest) String 

func (x *ListConsumerGroupsRequest) String() string

type ListConsumerGroupsResponse 

type ListConsumerGroupsResponse struct {
	ConsumerGroups []*ConsumerGroupInfo `protobuf:"bytes,1,rep,name=consumer_groups,json=consumerGroups,proto3" json:"consumer_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConsumerGroupsResponse) Descriptor deprecated 

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

Deprecated: Use ListConsumerGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListConsumerGroupsResponse) GetConsumerGroups 

func (x *ListConsumerGroupsResponse) GetConsumerGroups() []*ConsumerGroupInfo

func (*ListConsumerGroupsResponse) ProtoMessage 

func (*ListConsumerGroupsResponse) ProtoMessage()

func (*ListConsumerGroupsResponse) ProtoReflect 

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

func (*ListConsumerGroupsResponse) Reset 

func (x *ListConsumerGroupsResponse) Reset()

func (*ListConsumerGroupsResponse) String 

func (x *ListConsumerGroupsResponse) 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 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 `` /* 147-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 SlotStatus 

type SlotStatus int32
const (
	SlotStatus_SLOT_PROCESSED            SlotStatus = 0
	SlotStatus_SLOT_CONFIRMED            SlotStatus = 1
	SlotStatus_SLOT_FINALIZED            SlotStatus = 2
	SlotStatus_SLOT_FIRST_SHRED_RECEIVED SlotStatus = 3
	SlotStatus_SLOT_COMPLETED            SlotStatus = 4
	SlotStatus_SLOT_CREATED_BANK         SlotStatus = 5
	SlotStatus_SLOT_DEAD                 SlotStatus = 6
)

func (SlotStatus) Descriptor 

func (SlotStatus) Descriptor() protoreflect.EnumDescriptor

func (SlotStatus) Enum 

func (x SlotStatus) Enum() *SlotStatus

func (SlotStatus) EnumDescriptor deprecated 

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

Deprecated: Use SlotStatus.Descriptor instead.

func (SlotStatus) Number 

func (x SlotStatus) Number() protoreflect.EnumNumber

func (SlotStatus) String 

func (x SlotStatus) String() string

func (SlotStatus) Type 

func (SlotStatus) Type() protoreflect.EnumType

type SubscribeRequest 

type SubscribeRequest struct {
	ConsumerGroupLabel string                                         `protobuf:"bytes,1,opt,name=consumer_group_label,json=consumerGroupLabel,proto3" json:"consumer_group_label,omitempty"`
	ConsumerId         *uint32                                        `protobuf:"varint,2,opt,name=consumer_id,json=consumerId,proto3,oneof" json:"consumer_id,omitempty"`
	Accounts           map[string]*SubscribeRequestFilterAccounts     `` /* 157-byte string literal not displayed */
	Transactions       map[string]*SubscribeRequestFilterTransactions `` /* 165-byte string literal not displayed */
	// 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) GetConsumerGroupLabel 

func (x *SubscribeRequest) GetConsumerGroupLabel() string

func (*SubscribeRequest) GetConsumerId 

func (x *SubscribeRequest) GetConsumerId() uint32

func (*SubscribeRequest) GetTransactions 

func (x *SubscribeRequest) GetTransactions() 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    SlotStatus `protobuf:"varint,3,opt,name=status,proto3,enum=geyser.SlotStatus" 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() SlotStatus

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

type UnimplementedFumaroleServer struct{}

UnimplementedFumaroleServer 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 (UnimplementedFumaroleServer) CreateStaticConsumerGroup 

func (UnimplementedFumaroleServer) CreateStaticConsumerGroup(context.Context, *CreateStaticConsumerGroupRequest) (*CreateStaticConsumerGroupResponse, error)

func (UnimplementedFumaroleServer) DeleteConsumerGroup 

func (UnimplementedFumaroleServer) DeleteConsumerGroup(context.Context, *DeleteConsumerGroupRequest) (*DeleteConsumerGroupResponse, error)

func (UnimplementedFumaroleServer) GetConsumerGroupInfo 

func (UnimplementedFumaroleServer) GetConsumerGroupInfo(context.Context, *GetConsumerGroupInfoRequest) (*ConsumerGroupInfo, error)

func (UnimplementedFumaroleServer) GetOldestSlot 

func (UnimplementedFumaroleServer) GetOldestSlot(context.Context, *GetOldestSlotRequest) (*GetOldestSlotResponse, error)

func (UnimplementedFumaroleServer) GetSlotLagInfo 

func (UnimplementedFumaroleServer) GetSlotLagInfo(context.Context, *GetSlotLagInfoRequest) (*GetSlotLagInfoResponse, error)

func (UnimplementedFumaroleServer) ListAvailableCommitmentLevels 

func (UnimplementedFumaroleServer) ListAvailableCommitmentLevels(context.Context, *ListAvailableCommitmentLevelsRequest) (*ListAvailableCommitmentLevelsResponse, error)

func (UnimplementedFumaroleServer) ListConsumerGroups 

func (UnimplementedFumaroleServer) ListConsumerGroups(context.Context, *ListConsumerGroupsRequest) (*ListConsumerGroupsResponse, error)

func (UnimplementedFumaroleServer) Subscribe 

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

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

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

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

type UnsafeGeyserServer 

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

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

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.