overcast

package
v0.1.0-alpha.1 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

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

Variables

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CompiledInstruction) Descriptor 

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

func (*CompiledInstruction) GetAccounts 

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

func (*CompiledInstruction) GetData 

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

func (*CompiledInstruction) GetProgramIdIndex 

func (m *CompiledInstruction) GetProgramIdIndex() uint32

func (*CompiledInstruction) ProtoMessage 

func (*CompiledInstruction) ProtoMessage()

func (*CompiledInstruction) Reset 

func (m *CompiledInstruction) Reset()

func (*CompiledInstruction) String 

func (m *CompiledInstruction) String() string

func (*CompiledInstruction) XXX_DiscardUnknown 

func (m *CompiledInstruction) XXX_DiscardUnknown()

func (*CompiledInstruction) XXX_Marshal 

func (m *CompiledInstruction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompiledInstruction) XXX_Merge 

func (m *CompiledInstruction) XXX_Merge(src proto.Message)

func (*CompiledInstruction) XXX_Size 

func (m *CompiledInstruction) XXX_Size() int

func (*CompiledInstruction) XXX_Unmarshal 

func (m *CompiledInstruction) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Entry) Descriptor 

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

func (*Entry) GetHash 

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

func (*Entry) GetNumHashes 

func (m *Entry) GetNumHashes() uint64

func (*Entry) GetTransactions 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entry) XXX_Merge 

func (m *Entry) XXX_Merge(src proto.Message)

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

func (m *Entry) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageAddressTableLookup) Descriptor 

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

func (*MessageAddressTableLookup) GetAccountKey 

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

func (*MessageAddressTableLookup) GetReadonlyIndexes 

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

func (*MessageAddressTableLookup) GetWritableIndexes 

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

func (*MessageAddressTableLookup) ProtoMessage 

func (*MessageAddressTableLookup) ProtoMessage()

func (*MessageAddressTableLookup) Reset 

func (m *MessageAddressTableLookup) Reset()

func (*MessageAddressTableLookup) String 

func (m *MessageAddressTableLookup) String() string

func (*MessageAddressTableLookup) XXX_DiscardUnknown 

func (m *MessageAddressTableLookup) XXX_DiscardUnknown()

func (*MessageAddressTableLookup) XXX_Marshal 

func (m *MessageAddressTableLookup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageAddressTableLookup) XXX_Merge 

func (m *MessageAddressTableLookup) XXX_Merge(src proto.Message)

func (*MessageAddressTableLookup) XXX_Size 

func (m *MessageAddressTableLookup) XXX_Size() int

func (*MessageAddressTableLookup) XXX_Unmarshal 

func (m *MessageAddressTableLookup) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
	XXX_unrecognized            []byte   `json:"-"`
	XXX_sizecache               int32    `json:"-"`
}

func (*MessageHeader) Descriptor 

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

func (*MessageHeader) GetNumReadonlySignedAccounts 

func (m *MessageHeader) GetNumReadonlySignedAccounts() uint32

func (*MessageHeader) GetNumReadonlyUnsignedAccounts 

func (m *MessageHeader) GetNumReadonlyUnsignedAccounts() uint32

func (*MessageHeader) GetNumRequiredSignatures 

func (m *MessageHeader) GetNumRequiredSignatures() uint32

func (*MessageHeader) ProtoMessage 

func (*MessageHeader) ProtoMessage()

func (*MessageHeader) Reset 

func (m *MessageHeader) Reset()

func (*MessageHeader) String 

func (m *MessageHeader) String() string

func (*MessageHeader) XXX_DiscardUnknown 

func (m *MessageHeader) XXX_DiscardUnknown()

func (*MessageHeader) XXX_Marshal 

func (m *MessageHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageHeader) XXX_Merge 

func (m *MessageHeader) XXX_Merge(src proto.Message)

func (*MessageHeader) XXX_Size 

func (m *MessageHeader) XXX_Size() int

func (*MessageHeader) XXX_Unmarshal 

func (m *MessageHeader) XXX_Unmarshal(b []byte) error

type SlotResponse 

type SlotResponse struct {
	Entries              []*Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	Slot                 uint64   `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SlotResponse) Descriptor 

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

func (*SlotResponse) GetEntries 

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

func (*SlotResponse) GetSlot 

func (m *SlotResponse) GetSlot() uint64

func (*SlotResponse) ProtoMessage 

func (*SlotResponse) ProtoMessage()

func (*SlotResponse) Reset 

func (m *SlotResponse) Reset()

func (*SlotResponse) String 

func (m *SlotResponse) String() string

func (*SlotResponse) XXX_DiscardUnknown 

func (m *SlotResponse) XXX_DiscardUnknown()

func (*SlotResponse) XXX_Marshal 

func (m *SlotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlotResponse) XXX_Merge 

func (m *SlotResponse) XXX_Merge(src proto.Message)

func (*SlotResponse) XXX_Size 

func (m *SlotResponse) XXX_Size() int

func (*SlotResponse) XXX_Unmarshal 

func (m *SlotResponse) XXX_Unmarshal(b []byte) error

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SlotStreamRequest) Descriptor 

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

func (*SlotStreamRequest) ProtoMessage 

func (*SlotStreamRequest) ProtoMessage()

func (*SlotStreamRequest) Reset 

func (m *SlotStreamRequest) Reset()

func (*SlotStreamRequest) String 

func (m *SlotStreamRequest) String() string

func (*SlotStreamRequest) XXX_DiscardUnknown 

func (m *SlotStreamRequest) XXX_DiscardUnknown()

func (*SlotStreamRequest) XXX_Marshal 

func (m *SlotStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlotStreamRequest) XXX_Merge 

func (m *SlotStreamRequest) XXX_Merge(src proto.Message)

func (*SlotStreamRequest) XXX_Size 

func (m *SlotStreamRequest) XXX_Size() int

func (*SlotStreamRequest) XXX_Unmarshal 

func (m *SlotStreamRequest) XXX_Unmarshal(b []byte) error

type SlotStreamServer 

type SlotStreamServer interface {
	StreamSlots(*SlotStreamRequest, grpc.ServerStreamingServer[SlotResponse]) error
}

SlotStreamServer is the server API for SlotStream service. All implementations should 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 should 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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*VersionedMessageLegacy) Descriptor 

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

func (*VersionedMessageLegacy) GetAccountKeys 

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

func (*VersionedMessageLegacy) GetHeader 

func (m *VersionedMessageLegacy) GetHeader() *MessageHeader

func (*VersionedMessageLegacy) GetInstructions 

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

func (*VersionedMessageLegacy) GetRecentBlockhash 

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

func (*VersionedMessageLegacy) ProtoMessage 

func (*VersionedMessageLegacy) ProtoMessage()

func (*VersionedMessageLegacy) Reset 

func (m *VersionedMessageLegacy) Reset()

func (*VersionedMessageLegacy) String 

func (m *VersionedMessageLegacy) String() string

func (*VersionedMessageLegacy) XXX_DiscardUnknown 

func (m *VersionedMessageLegacy) XXX_DiscardUnknown()

func (*VersionedMessageLegacy) XXX_Marshal 

func (m *VersionedMessageLegacy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionedMessageLegacy) XXX_Merge 

func (m *VersionedMessageLegacy) XXX_Merge(src proto.Message)

func (*VersionedMessageLegacy) XXX_Size 

func (m *VersionedMessageLegacy) XXX_Size() int

func (*VersionedMessageLegacy) XXX_Unmarshal 

func (m *VersionedMessageLegacy) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*VersionedMessageV0) Descriptor 

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

func (*VersionedMessageV0) GetAccountKeys 

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

func (*VersionedMessageV0) GetAddressTableLookups 

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

func (*VersionedMessageV0) GetHeader 

func (m *VersionedMessageV0) GetHeader() *MessageHeader

func (*VersionedMessageV0) GetInstructions 

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

func (*VersionedMessageV0) GetRecentBlockhash 

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

func (*VersionedMessageV0) ProtoMessage 

func (*VersionedMessageV0) ProtoMessage()

func (*VersionedMessageV0) Reset 

func (m *VersionedMessageV0) Reset()

func (*VersionedMessageV0) String 

func (m *VersionedMessageV0) String() string

func (*VersionedMessageV0) XXX_DiscardUnknown 

func (m *VersionedMessageV0) XXX_DiscardUnknown()

func (*VersionedMessageV0) XXX_Marshal 

func (m *VersionedMessageV0) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionedMessageV0) XXX_Merge 

func (m *VersionedMessageV0) XXX_Merge(src proto.Message)

func (*VersionedMessageV0) XXX_Size 

func (m *VersionedMessageV0) XXX_Size() int

func (*VersionedMessageV0) XXX_Unmarshal 

func (m *VersionedMessageV0) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*VersionedTransaction) Descriptor 

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

func (*VersionedTransaction) GetMessage 

func (m *VersionedTransaction) GetMessage() isVersionedTransaction_Message

func (*VersionedTransaction) GetMessageLegacy 

func (m *VersionedTransaction) GetMessageLegacy() *VersionedMessageLegacy

func (*VersionedTransaction) GetMessageV0 

func (m *VersionedTransaction) GetMessageV0() *VersionedMessageV0

func (*VersionedTransaction) GetSignatures 

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

func (*VersionedTransaction) ProtoMessage 

func (*VersionedTransaction) ProtoMessage()

func (*VersionedTransaction) Reset 

func (m *VersionedTransaction) Reset()

func (*VersionedTransaction) String 

func (m *VersionedTransaction) String() string

func (*VersionedTransaction) XXX_DiscardUnknown 

func (m *VersionedTransaction) XXX_DiscardUnknown()

func (*VersionedTransaction) XXX_Marshal 

func (m *VersionedTransaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionedTransaction) XXX_Merge 

func (m *VersionedTransaction) XXX_Merge(src proto.Message)

func (*VersionedTransaction) XXX_OneofWrappers 

func (*VersionedTransaction) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*VersionedTransaction) XXX_Size 

func (m *VersionedTransaction) XXX_Size() int

func (*VersionedTransaction) XXX_Unmarshal 

func (m *VersionedTransaction) XXX_Unmarshal(b []byte) error

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.