pboutputcache

package

v1.17.4 Latest Latest Go to latest Published: Nov 21, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/substreams

Links

Documentation ¶

Index ¶

Variables
type Array
type Item
type Map

Constants ¶

This section is empty.

Variables ¶

View Source

var File_output_proto protoreflect.FileDescriptor

Functions ¶

This section is empty.

Types ¶

type Array ¶

type Array struct {
	Items   []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Ordered bool    `protobuf:"varint,2,opt,name=ordered,proto3" json:"ordered,omitempty"` // this will forcibly be written at the beginning if we are ordered, so the items can be unmarshalled sequentially
	// contains filtered or unexported fields
}

func (*Array) Descriptor deprecated

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

Deprecated: Use Array.ProtoReflect.Descriptor instead.

func (*Array) GetItems ¶

func (x *Array) GetItems() []*Item

func (*Array) GetOrdered ¶ added in v1.15.8

func (x *Array) GetOrdered() bool

func (*Array) MarshalToSizedBufferVT ¶

func (m *Array) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Array) MarshalToVT ¶

func (m *Array) MarshalToVT(dAtA []byte) (int, error)

func (*Array) MarshalVT ¶

func (m *Array) MarshalVT() (dAtA []byte, err error)

func (*Array) ProtoMessage ¶

func (*Array) ProtoMessage()

func (*Array) ProtoReflect ¶

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

func (*Array) Reset ¶

func (x *Array) Reset()

func (*Array) SizeVT ¶

func (m *Array) SizeVT() (n int)

func (*Array) String ¶

func (x *Array) String() string

func (*Array) UnmarshalVT ¶

func (m *Array) UnmarshalVT(dAtA []byte) error

func (*Array) UnmarshalVTUnsafe ¶ added in v1.15.8

func (m *Array) UnmarshalVTUnsafe(dAtA []byte) error

type Item ¶

type Item struct {
	BlockNum  uint64                 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	BlockId   string                 `protobuf:"bytes,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Payload   []byte                 `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Cursor    string                 `protobuf:"bytes,5,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*Item) Descriptor deprecated

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetBlockId ¶

func (x *Item) GetBlockId() string

func (*Item) GetBlockNum ¶

func (x *Item) GetBlockNum() uint64

func (*Item) GetCursor ¶

func (x *Item) GetCursor() string

func (*Item) GetPayload ¶

func (x *Item) GetPayload() []byte

func (*Item) GetTimestamp ¶

func (x *Item) GetTimestamp() *timestamppb.Timestamp

func (*Item) MarshalToSizedBufferVT ¶

func (m *Item) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Item) MarshalToVT ¶

func (m *Item) MarshalToVT(dAtA []byte) (int, error)

func (*Item) MarshalVT ¶

func (m *Item) MarshalVT() (dAtA []byte, err error)

func (*Item) ProtoMessage ¶

func (*Item) ProtoMessage()

func (*Item) ProtoReflect ¶

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

func (*Item) Reset ¶

func (x *Item) Reset()

func (*Item) SizeVT ¶

func (m *Item) SizeVT() (n int)

func (*Item) String ¶

func (x *Item) String() string

func (*Item) UnmarshalVT ¶

func (m *Item) UnmarshalVT(dAtA []byte) error

func (*Item) UnmarshalVTUnsafe ¶ added in v1.15.8

func (m *Item) UnmarshalVTUnsafe(dAtA []byte) error

type Map ¶

type Map struct {
	Kv map[string]*Item `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Map) Descriptor deprecated

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

Deprecated: Use Map.ProtoReflect.Descriptor instead.

func (*Map) GetKv ¶

func (x *Map) GetKv() map[string]*Item

func (*Map) MarshalFast ¶

func (m *Map) MarshalFast() (dAtA []byte, err error)

Faster marshalling through conversion to Array

func (*Map) MarshalToSizedBufferVT ¶

func (m *Map) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Map) MarshalToVT ¶

func (m *Map) MarshalToVT(dAtA []byte) (int, error)

func (*Map) MarshalVT ¶

func (m *Map) MarshalVT() (dAtA []byte, err error)

func (*Map) ProtoMessage ¶

func (*Map) ProtoMessage()

func (*Map) ProtoReflect ¶

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

func (*Map) Reset ¶

func (x *Map) Reset()

func (*Map) SizeVT ¶

func (m *Map) SizeVT() (n int)

func (*Map) String ¶

func (x *Map) String() string

func (*Map) UnmarshalFast ¶

func (m *Map) UnmarshalFast(dAtA []byte) error

Faster unmarshalling when it was converted to array first

func (*Map) UnmarshalVT ¶

func (m *Map) UnmarshalVT(dAtA []byte) error

func (*Map) UnmarshalVTUnsafe ¶ added in v1.15.8

func (m *Map) UnmarshalVTUnsafe(dAtA []byte) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL