overcast

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: May 11, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SlotStream_StreamSlots_FullMethodName = "/slot_stream.SlotStream/StreamSlots"
)

Variables

View Source 
var File_slot_entry_proto protoreflect.FileDescriptor
View Source 
var File_slot_stream_proto protoreflect.FileDescriptor
View Source 
var SlotStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "slot_stream.SlotStream",
	HandlerType: (*SlotStreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamSlots",
			Handler:       _SlotStream_StreamSlots_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "slot_stream.proto",
}

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

Functions

func RegisterSlotStreamServer 

func RegisterSlotStreamServer(s grpc.ServiceRegistrar, srv SlotStreamServer)

Types

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 Entry 

type Entry struct {
	NumHashes uint64 `protobuf:"varint,1,opt,name=num_hashes,json=numHashes,proto3" json:"num_hashes,omitempty"`
	// fixed size, 32 bytes
	Hash         []byte                  `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Transactions []*VersionedTransaction `protobuf:"bytes,3,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetHash 

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

func (*Entry) GetNumHashes 

func (x *Entry) GetNumHashes() uint64

func (*Entry) GetTransactions 

func (x *Entry) GetTransactions() []*VersionedTransaction

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

type MessageAddressTableLookup 

type MessageAddressTableLookup struct {

	// 32 bytes pubkey
	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 SlotResponse 

type SlotResponse struct {
	Entries    []*Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` // JSON encoded entries
	Slot       uint64   `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"`
	ParentSlot uint64   `protobuf:"varint,3,opt,name=parent_slot,json=parentSlot,proto3" json:"parent_slot,omitempty"`
	// contains filtered or unexported fields
}

func (*SlotResponse) Descriptor deprecated 

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

Deprecated: Use SlotResponse.ProtoReflect.Descriptor instead.

func (*SlotResponse) GetEntries 

func (x *SlotResponse) GetEntries() []*Entry

func (*SlotResponse) GetParentSlot 

func (x *SlotResponse) GetParentSlot() uint64

func (*SlotResponse) GetSlot 

func (x *SlotResponse) GetSlot() uint64

func (*SlotResponse) ProtoMessage 

func (*SlotResponse) ProtoMessage()

func (*SlotResponse) ProtoReflect 

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

func (*SlotResponse) Reset 

func (x *SlotResponse) Reset()

func (*SlotResponse) String 

func (x *SlotResponse) String() string

type SlotStreamClient 

type SlotStreamClient interface {
	StreamSlots(ctx context.Context, in *SlotStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SlotResponse], error)
}

SlotStreamClient is the client API for SlotStream 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 NewSlotStreamClient 

func NewSlotStreamClient(cc grpc.ClientConnInterface) SlotStreamClient

type SlotStreamRequest 

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

func (*SlotStreamRequest) Descriptor deprecated 

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

Deprecated: Use SlotStreamRequest.ProtoReflect.Descriptor instead.

func (*SlotStreamRequest) ProtoMessage 

func (*SlotStreamRequest) ProtoMessage()

func (*SlotStreamRequest) ProtoReflect 

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

func (*SlotStreamRequest) Reset 

func (x *SlotStreamRequest) Reset()

func (*SlotStreamRequest) String 

func (x *SlotStreamRequest) String() string

type SlotStreamServer 

type SlotStreamServer interface {
	StreamSlots(*SlotStreamRequest, grpc.ServerStreamingServer[SlotResponse]) error
	// contains filtered or unexported methods
}

SlotStreamServer is the server API for SlotStream service. All implementations must embed UnimplementedSlotStreamServer for forward compatibility.

type SlotStream_StreamSlotsClient 

type SlotStream_StreamSlotsClient = grpc.ServerStreamingClient[SlotResponse]

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

type SlotStream_StreamSlotsServer 

type SlotStream_StreamSlotsServer = grpc.ServerStreamingServer[SlotResponse]

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

type UnimplementedSlotStreamServer 

type UnimplementedSlotStreamServer struct{}

UnimplementedSlotStreamServer 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 (UnimplementedSlotStreamServer) StreamSlots 

func (UnimplementedSlotStreamServer) StreamSlots(*SlotStreamRequest, grpc.ServerStreamingServer[SlotResponse]) error

type UnsafeSlotStreamServer 

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

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

type VersionedMessageLegacy 

type VersionedMessageLegacy struct {
	Header *MessageHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Each key is a 32 bytes pubkey
	AccountKeys [][]byte `protobuf:"bytes,2,rep,name=account_keys,json=accountKeys,proto3" json:"account_keys,omitempty"`
	// 32 byte hash
	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"`
	// contains filtered or unexported fields
}

func (*VersionedMessageLegacy) Descriptor deprecated 

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

Deprecated: Use VersionedMessageLegacy.ProtoReflect.Descriptor instead.

func (*VersionedMessageLegacy) GetAccountKeys 

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

func (*VersionedMessageLegacy) GetHeader 

func (x *VersionedMessageLegacy) GetHeader() *MessageHeader

func (*VersionedMessageLegacy) GetInstructions 

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

func (*VersionedMessageLegacy) GetRecentBlockhash 

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

func (*VersionedMessageLegacy) ProtoMessage 

func (*VersionedMessageLegacy) ProtoMessage()

func (*VersionedMessageLegacy) ProtoReflect 

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

func (*VersionedMessageLegacy) Reset 

func (x *VersionedMessageLegacy) Reset()

func (*VersionedMessageLegacy) String 

func (x *VersionedMessageLegacy) String() string

type VersionedMessageV0 

type VersionedMessageV0 struct {
	Header *MessageHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Each key is a 32 bytes pubkey
	AccountKeys [][]byte `protobuf:"bytes,2,rep,name=account_keys,json=accountKeys,proto3" json:"account_keys,omitempty"`
	// 32 byte hash
	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"`
	AddressTableLookups []*MessageAddressTableLookup `protobuf:"bytes,5,rep,name=address_table_lookups,json=addressTableLookups,proto3" json:"address_table_lookups,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedMessageV0) Descriptor deprecated 

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

Deprecated: Use VersionedMessageV0.ProtoReflect.Descriptor instead.

func (*VersionedMessageV0) GetAccountKeys 

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

func (*VersionedMessageV0) GetAddressTableLookups 

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

func (*VersionedMessageV0) GetHeader 

func (x *VersionedMessageV0) GetHeader() *MessageHeader

func (*VersionedMessageV0) GetInstructions 

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

func (*VersionedMessageV0) GetRecentBlockhash 

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

func (*VersionedMessageV0) ProtoMessage 

func (*VersionedMessageV0) ProtoMessage()

func (*VersionedMessageV0) ProtoReflect 

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

func (*VersionedMessageV0) Reset 

func (x *VersionedMessageV0) Reset()

func (*VersionedMessageV0) String 

func (x *VersionedMessageV0) String() string

type VersionedTransaction 

type VersionedTransaction struct {

	// Each signature is 64 bytes
	Signatures [][]byte `protobuf:"bytes,1,rep,name=signatures,proto3" json:"signatures,omitempty"`
	// Types that are valid to be assigned to Message:
	//
	//	*VersionedTransaction_MessageLegacy
	//	*VersionedTransaction_MessageV0
	Message isVersionedTransaction_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*VersionedTransaction) Descriptor deprecated 

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

Deprecated: Use VersionedTransaction.ProtoReflect.Descriptor instead.

func (*VersionedTransaction) GetMessage 

func (x *VersionedTransaction) GetMessage() isVersionedTransaction_Message

func (*VersionedTransaction) GetMessageLegacy 

func (x *VersionedTransaction) GetMessageLegacy() *VersionedMessageLegacy

func (*VersionedTransaction) GetMessageV0 

func (x *VersionedTransaction) GetMessageV0() *VersionedMessageV0

func (*VersionedTransaction) GetSignatures 

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

func (*VersionedTransaction) ProtoMessage 

func (*VersionedTransaction) ProtoMessage()

func (*VersionedTransaction) ProtoReflect 

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

func (*VersionedTransaction) Reset 

func (x *VersionedTransaction) Reset()

func (*VersionedTransaction) String 

func (x *VersionedTransaction) String() string

type VersionedTransaction_MessageLegacy 

type VersionedTransaction_MessageLegacy struct {
	MessageLegacy *VersionedMessageLegacy `protobuf:"bytes,2,opt,name=message_legacy,json=messageLegacy,proto3,oneof"`
}

type VersionedTransaction_MessageV0 

type VersionedTransaction_MessageV0 struct {
	MessageV0 *VersionedMessageV0 `protobuf:"bytes,3,opt,name=message_v0,json=messageV0,proto3,oneof"`
}

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.