Documentation ¶
Index ¶
- Variables
- type Entry
- func (*Entry) Descriptor() ([]byte, []int)deprecated
- func (m *Entry) GetEntryType() isEntry_EntryType
- func (x *Entry) GetNewTableBlock() *Entry_NewTableBlock
- func (x *Entry) GetSnapshot() *Entry_Snapshot
- func (x *Entry) GetTableBlockPersisted() *Entry_TableBlockPersisted
- func (x *Entry) GetWrite() *Entry_Write
- func (m *Entry) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Entry) MarshalToVT(dAtA []byte) (int, error)
- func (m *Entry) MarshalVT() (dAtA []byte, err error)
- func (*Entry) ProtoMessage()
- func (x *Entry) ProtoReflect() protoreflect.Message
- func (x *Entry) Reset()
- func (m *Entry) SizeVT() (n int)
- func (x *Entry) String() string
- func (m *Entry) UnmarshalVT(dAtA []byte) error
- type Entry_NewTableBlock
- func (*Entry_NewTableBlock) Descriptor() ([]byte, []int)deprecated
- func (x *Entry_NewTableBlock) GetBlockId() []byte
- func (x *Entry_NewTableBlock) GetConfig() *v1alpha1.TableConfig
- func (x *Entry_NewTableBlock) GetTableName() string
- func (m *Entry_NewTableBlock) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Entry_NewTableBlock) MarshalToVT(dAtA []byte) (int, error)
- func (m *Entry_NewTableBlock) MarshalVT() (dAtA []byte, err error)
- func (*Entry_NewTableBlock) ProtoMessage()
- func (x *Entry_NewTableBlock) ProtoReflect() protoreflect.Message
- func (x *Entry_NewTableBlock) Reset()
- func (m *Entry_NewTableBlock) SizeVT() (n int)
- func (x *Entry_NewTableBlock) String() string
- func (m *Entry_NewTableBlock) UnmarshalVT(dAtA []byte) error
- type Entry_NewTableBlock_
- type Entry_Snapshot
- func (*Entry_Snapshot) Descriptor() ([]byte, []int)deprecated
- func (x *Entry_Snapshot) GetTx() uint64
- func (m *Entry_Snapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Entry_Snapshot) MarshalToVT(dAtA []byte) (int, error)
- func (m *Entry_Snapshot) MarshalVT() (dAtA []byte, err error)
- func (*Entry_Snapshot) ProtoMessage()
- func (x *Entry_Snapshot) ProtoReflect() protoreflect.Message
- func (x *Entry_Snapshot) Reset()
- func (m *Entry_Snapshot) SizeVT() (n int)
- func (x *Entry_Snapshot) String() string
- func (m *Entry_Snapshot) UnmarshalVT(dAtA []byte) error
- type Entry_Snapshot_
- type Entry_TableBlockPersisted
- func (*Entry_TableBlockPersisted) Descriptor() ([]byte, []int)deprecated
- func (x *Entry_TableBlockPersisted) GetBlockId() []byte
- func (x *Entry_TableBlockPersisted) GetTableName() string
- func (m *Entry_TableBlockPersisted) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Entry_TableBlockPersisted) MarshalToVT(dAtA []byte) (int, error)
- func (m *Entry_TableBlockPersisted) MarshalVT() (dAtA []byte, err error)
- func (*Entry_TableBlockPersisted) ProtoMessage()
- func (x *Entry_TableBlockPersisted) ProtoReflect() protoreflect.Message
- func (x *Entry_TableBlockPersisted) Reset()
- func (m *Entry_TableBlockPersisted) SizeVT() (n int)
- func (x *Entry_TableBlockPersisted) String() string
- func (m *Entry_TableBlockPersisted) UnmarshalVT(dAtA []byte) error
- type Entry_TableBlockPersisted_
- type Entry_Write
- func (*Entry_Write) Descriptor() ([]byte, []int)deprecated
- func (x *Entry_Write) GetArrow() bool
- func (x *Entry_Write) GetData() []byte
- func (x *Entry_Write) GetTableName() string
- func (m *Entry_Write) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Entry_Write) MarshalToVT(dAtA []byte) (int, error)
- func (m *Entry_Write) MarshalVT() (dAtA []byte, err error)
- func (*Entry_Write) ProtoMessage()
- func (x *Entry_Write) ProtoReflect() protoreflect.Message
- func (x *Entry_Write) Reset()
- func (m *Entry_Write) SizeVT() (n int)
- func (x *Entry_Write) String() string
- func (m *Entry_Write) UnmarshalVT(dAtA []byte) error
- type Entry_Write_
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetEntry() *Entry
- func (m *Record) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Record) MarshalToVT(dAtA []byte) (int, error)
- func (m *Record) MarshalVT() (dAtA []byte, err error)
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (m *Record) SizeVT() (n int)
- func (x *Record) String() string
- func (m *Record) UnmarshalVT(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
View Source
var File_frostdb_wal_v1alpha1_wal_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Entry ¶
type Entry struct { // The new-table entry. // // Types that are assignable to EntryType: // // *Entry_Write_ // *Entry_NewTableBlock_ // *Entry_TableBlockPersisted_ // *Entry_Snapshot_ EntryType isEntry_EntryType `protobuf_oneof:"entry_type"` // contains filtered or unexported fields }
The data of a WAL Record. This is intentionally separate to allow using the `oneof` feature in a forward-compatible way.
func (*Entry) Descriptor
deprecated
func (*Entry) GetEntryType ¶
func (m *Entry) GetEntryType() isEntry_EntryType
func (*Entry) GetNewTableBlock ¶
func (x *Entry) GetNewTableBlock() *Entry_NewTableBlock
func (*Entry) GetSnapshot ¶
func (x *Entry) GetSnapshot() *Entry_Snapshot
func (*Entry) GetTableBlockPersisted ¶
func (x *Entry) GetTableBlockPersisted() *Entry_TableBlockPersisted
func (*Entry) GetWrite ¶
func (x *Entry) GetWrite() *Entry_Write
func (*Entry) MarshalToSizedBufferVT ¶
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) ProtoReflect ¶
func (x *Entry) ProtoReflect() protoreflect.Message
func (*Entry) UnmarshalVT ¶
type Entry_NewTableBlock ¶
type Entry_NewTableBlock struct { // Table name of the new-table-block. TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Block ID of the new-table-block. BlockId []byte `protobuf:"bytes,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` // Config of the new-table-block. Config *v1alpha1.TableConfig `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
The new-table-block entry.
func (*Entry_NewTableBlock) Descriptor
deprecated
func (*Entry_NewTableBlock) Descriptor() ([]byte, []int)
Deprecated: Use Entry_NewTableBlock.ProtoReflect.Descriptor instead.
func (*Entry_NewTableBlock) GetBlockId ¶
func (x *Entry_NewTableBlock) GetBlockId() []byte
func (*Entry_NewTableBlock) GetConfig ¶
func (x *Entry_NewTableBlock) GetConfig() *v1alpha1.TableConfig
func (*Entry_NewTableBlock) GetTableName ¶
func (x *Entry_NewTableBlock) GetTableName() string
func (*Entry_NewTableBlock) MarshalToSizedBufferVT ¶
func (m *Entry_NewTableBlock) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_NewTableBlock) MarshalToVT ¶
func (m *Entry_NewTableBlock) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_NewTableBlock) MarshalVT ¶
func (m *Entry_NewTableBlock) MarshalVT() (dAtA []byte, err error)
func (*Entry_NewTableBlock) ProtoMessage ¶
func (*Entry_NewTableBlock) ProtoMessage()
func (*Entry_NewTableBlock) ProtoReflect ¶
func (x *Entry_NewTableBlock) ProtoReflect() protoreflect.Message
func (*Entry_NewTableBlock) Reset ¶
func (x *Entry_NewTableBlock) Reset()
func (*Entry_NewTableBlock) SizeVT ¶
func (m *Entry_NewTableBlock) SizeVT() (n int)
func (*Entry_NewTableBlock) String ¶
func (x *Entry_NewTableBlock) String() string
func (*Entry_NewTableBlock) UnmarshalVT ¶
func (m *Entry_NewTableBlock) UnmarshalVT(dAtA []byte) error
type Entry_NewTableBlock_ ¶
type Entry_NewTableBlock_ struct { // NewTableBlock is set if the entry describes a new-table-block. NewTableBlock *Entry_NewTableBlock `protobuf:"bytes,2,opt,name=new_table_block,json=newTableBlock,proto3,oneof"` }
func (*Entry_NewTableBlock_) MarshalToSizedBufferVT ¶
func (m *Entry_NewTableBlock_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_NewTableBlock_) MarshalToVT ¶
func (m *Entry_NewTableBlock_) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_NewTableBlock_) SizeVT ¶
func (m *Entry_NewTableBlock_) SizeVT() (n int)
type Entry_Snapshot ¶
type Entry_Snapshot struct { // The tx the snapshot was taken at. Tx uint64 `protobuf:"varint,1,opt,name=tx,proto3" json:"tx,omitempty"` // contains filtered or unexported fields }
func (*Entry_Snapshot) Descriptor
deprecated
func (*Entry_Snapshot) Descriptor() ([]byte, []int)
Deprecated: Use Entry_Snapshot.ProtoReflect.Descriptor instead.
func (*Entry_Snapshot) GetTx ¶
func (x *Entry_Snapshot) GetTx() uint64
func (*Entry_Snapshot) MarshalToSizedBufferVT ¶
func (m *Entry_Snapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_Snapshot) MarshalToVT ¶
func (m *Entry_Snapshot) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_Snapshot) MarshalVT ¶
func (m *Entry_Snapshot) MarshalVT() (dAtA []byte, err error)
func (*Entry_Snapshot) ProtoMessage ¶
func (*Entry_Snapshot) ProtoMessage()
func (*Entry_Snapshot) ProtoReflect ¶
func (x *Entry_Snapshot) ProtoReflect() protoreflect.Message
func (*Entry_Snapshot) Reset ¶
func (x *Entry_Snapshot) Reset()
func (*Entry_Snapshot) SizeVT ¶
func (m *Entry_Snapshot) SizeVT() (n int)
func (*Entry_Snapshot) String ¶
func (x *Entry_Snapshot) String() string
func (*Entry_Snapshot) UnmarshalVT ¶
func (m *Entry_Snapshot) UnmarshalVT(dAtA []byte) error
type Entry_Snapshot_ ¶
type Entry_Snapshot_ struct { // Snapshot is set if the entry describes a snapshot. Snapshot *Entry_Snapshot `protobuf:"bytes,4,opt,name=snapshot,proto3,oneof"` }
func (*Entry_Snapshot_) MarshalToSizedBufferVT ¶
func (m *Entry_Snapshot_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_Snapshot_) MarshalToVT ¶
func (m *Entry_Snapshot_) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_Snapshot_) SizeVT ¶
func (m *Entry_Snapshot_) SizeVT() (n int)
type Entry_TableBlockPersisted ¶
type Entry_TableBlockPersisted struct { // Table name of the new-table-block. TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Block ID of the new-table-block. BlockId []byte `protobuf:"bytes,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"` // contains filtered or unexported fields }
The table-block persisted entry.
func (*Entry_TableBlockPersisted) Descriptor
deprecated
func (*Entry_TableBlockPersisted) Descriptor() ([]byte, []int)
Deprecated: Use Entry_TableBlockPersisted.ProtoReflect.Descriptor instead.
func (*Entry_TableBlockPersisted) GetBlockId ¶
func (x *Entry_TableBlockPersisted) GetBlockId() []byte
func (*Entry_TableBlockPersisted) GetTableName ¶
func (x *Entry_TableBlockPersisted) GetTableName() string
func (*Entry_TableBlockPersisted) MarshalToSizedBufferVT ¶
func (m *Entry_TableBlockPersisted) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_TableBlockPersisted) MarshalToVT ¶
func (m *Entry_TableBlockPersisted) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_TableBlockPersisted) MarshalVT ¶
func (m *Entry_TableBlockPersisted) MarshalVT() (dAtA []byte, err error)
func (*Entry_TableBlockPersisted) ProtoMessage ¶
func (*Entry_TableBlockPersisted) ProtoMessage()
func (*Entry_TableBlockPersisted) ProtoReflect ¶
func (x *Entry_TableBlockPersisted) ProtoReflect() protoreflect.Message
func (*Entry_TableBlockPersisted) Reset ¶
func (x *Entry_TableBlockPersisted) Reset()
func (*Entry_TableBlockPersisted) SizeVT ¶
func (m *Entry_TableBlockPersisted) SizeVT() (n int)
func (*Entry_TableBlockPersisted) String ¶
func (x *Entry_TableBlockPersisted) String() string
func (*Entry_TableBlockPersisted) UnmarshalVT ¶
func (m *Entry_TableBlockPersisted) UnmarshalVT(dAtA []byte) error
type Entry_TableBlockPersisted_ ¶
type Entry_TableBlockPersisted_ struct { // TableBlockPersisted is set if the entry describes a table-block-persisted. TableBlockPersisted *Entry_TableBlockPersisted `protobuf:"bytes,3,opt,name=table_block_persisted,json=tableBlockPersisted,proto3,oneof"` }
func (*Entry_TableBlockPersisted_) MarshalToSizedBufferVT ¶
func (m *Entry_TableBlockPersisted_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_TableBlockPersisted_) MarshalToVT ¶
func (m *Entry_TableBlockPersisted_) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_TableBlockPersisted_) SizeVT ¶
func (m *Entry_TableBlockPersisted_) SizeVT() (n int)
type Entry_Write ¶
type Entry_Write struct { // Table name of the write. TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Data is the data of the write. Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // Arrow indicates that data is stored in arrow record format. Arrow bool `protobuf:"varint,3,opt,name=arrow,proto3" json:"arrow,omitempty"` // contains filtered or unexported fields }
The write-type entry.
func (*Entry_Write) Descriptor
deprecated
func (*Entry_Write) Descriptor() ([]byte, []int)
Deprecated: Use Entry_Write.ProtoReflect.Descriptor instead.
func (*Entry_Write) GetArrow ¶
func (x *Entry_Write) GetArrow() bool
func (*Entry_Write) GetData ¶
func (x *Entry_Write) GetData() []byte
func (*Entry_Write) GetTableName ¶
func (x *Entry_Write) GetTableName() string
func (*Entry_Write) MarshalToSizedBufferVT ¶
func (m *Entry_Write) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_Write) MarshalToVT ¶
func (m *Entry_Write) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_Write) MarshalVT ¶
func (m *Entry_Write) MarshalVT() (dAtA []byte, err error)
func (*Entry_Write) ProtoMessage ¶
func (*Entry_Write) ProtoMessage()
func (*Entry_Write) ProtoReflect ¶
func (x *Entry_Write) ProtoReflect() protoreflect.Message
func (*Entry_Write) Reset ¶
func (x *Entry_Write) Reset()
func (*Entry_Write) SizeVT ¶
func (m *Entry_Write) SizeVT() (n int)
func (*Entry_Write) String ¶
func (x *Entry_Write) String() string
func (*Entry_Write) UnmarshalVT ¶
func (m *Entry_Write) UnmarshalVT(dAtA []byte) error
type Entry_Write_ ¶
type Entry_Write_ struct { // Write is set if the entry describes a write. Write *Entry_Write `protobuf:"bytes,1,opt,name=write,proto3,oneof"` }
func (*Entry_Write_) MarshalToSizedBufferVT ¶
func (m *Entry_Write_) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Entry_Write_) MarshalToVT ¶
func (m *Entry_Write_) MarshalToVT(dAtA []byte) (int, error)
func (*Entry_Write_) SizeVT ¶
func (m *Entry_Write_) SizeVT() (n int)
type Record ¶
type Record struct { // Data of the record. This is intentionally nested so the only thing in // the entry can be a protobuf `oneof` and have forward compatilibity. Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"` // contains filtered or unexported fields }
Record describes a single entry into the WAL.
func (*Record) Descriptor
deprecated
func (*Record) MarshalToSizedBufferVT ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
func (*Record) UnmarshalVT ¶
Click to show internal directories.
Click to hide internal directories.