Versions in this module Expand all Collapse all v0 v0.0.1 Mar 23, 2024 Changes in this version + var ErrIntOverflow = fmt.Errorf("proto: integer overflow") + var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") + var File_frostdb_wal_v1alpha1_wal_proto protoreflect.FileDescriptor + type Entry struct + EntryType isEntry_EntryType + func (*Entry) Descriptor() ([]byte, []int) + func (*Entry) ProtoMessage() + func (m *Entry) GetEntryType() isEntry_EntryType + 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 (m *Entry) SizeVT() (n int) + func (m *Entry) UnmarshalVT(dAtA []byte) error + 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 (x *Entry) ProtoReflect() protoreflect.Message + func (x *Entry) Reset() + func (x *Entry) String() string + type Entry_NewTableBlock struct + BlockId []byte + Config *v1alpha1.TableConfig + TableName string + func (*Entry_NewTableBlock) Descriptor() ([]byte, []int) + func (*Entry_NewTableBlock) ProtoMessage() + 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 (m *Entry_NewTableBlock) SizeVT() (n int) + func (m *Entry_NewTableBlock) UnmarshalVT(dAtA []byte) error + func (x *Entry_NewTableBlock) GetBlockId() []byte + func (x *Entry_NewTableBlock) GetConfig() *v1alpha1.TableConfig + func (x *Entry_NewTableBlock) GetTableName() string + func (x *Entry_NewTableBlock) ProtoReflect() protoreflect.Message + func (x *Entry_NewTableBlock) Reset() + func (x *Entry_NewTableBlock) String() string + type Entry_NewTableBlock_ struct + NewTableBlock *Entry_NewTableBlock + func (m *Entry_NewTableBlock_) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Entry_NewTableBlock_) MarshalToVT(dAtA []byte) (int, error) + func (m *Entry_NewTableBlock_) SizeVT() (n int) + type Entry_Snapshot struct + Tx uint64 + func (*Entry_Snapshot) Descriptor() ([]byte, []int) + func (*Entry_Snapshot) ProtoMessage() + 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 (m *Entry_Snapshot) SizeVT() (n int) + func (m *Entry_Snapshot) UnmarshalVT(dAtA []byte) error + func (x *Entry_Snapshot) GetTx() uint64 + func (x *Entry_Snapshot) ProtoReflect() protoreflect.Message + func (x *Entry_Snapshot) Reset() + func (x *Entry_Snapshot) String() string + type Entry_Snapshot_ struct + Snapshot *Entry_Snapshot + func (m *Entry_Snapshot_) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Entry_Snapshot_) MarshalToVT(dAtA []byte) (int, error) + func (m *Entry_Snapshot_) SizeVT() (n int) + type Entry_TableBlockPersisted struct + BlockId []byte + TableName string + func (*Entry_TableBlockPersisted) Descriptor() ([]byte, []int) + func (*Entry_TableBlockPersisted) ProtoMessage() + 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 (m *Entry_TableBlockPersisted) SizeVT() (n int) + func (m *Entry_TableBlockPersisted) UnmarshalVT(dAtA []byte) error + func (x *Entry_TableBlockPersisted) GetBlockId() []byte + func (x *Entry_TableBlockPersisted) GetTableName() string + func (x *Entry_TableBlockPersisted) ProtoReflect() protoreflect.Message + func (x *Entry_TableBlockPersisted) Reset() + func (x *Entry_TableBlockPersisted) String() string + type Entry_TableBlockPersisted_ struct + TableBlockPersisted *Entry_TableBlockPersisted + func (m *Entry_TableBlockPersisted_) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Entry_TableBlockPersisted_) MarshalToVT(dAtA []byte) (int, error) + func (m *Entry_TableBlockPersisted_) SizeVT() (n int) + type Entry_Write struct + Arrow bool + Data []byte + TableName string + func (*Entry_Write) Descriptor() ([]byte, []int) + func (*Entry_Write) ProtoMessage() + 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 (m *Entry_Write) SizeVT() (n int) + func (m *Entry_Write) UnmarshalVT(dAtA []byte) error + func (x *Entry_Write) GetArrow() bool + func (x *Entry_Write) GetData() []byte + func (x *Entry_Write) GetTableName() string + func (x *Entry_Write) ProtoReflect() protoreflect.Message + func (x *Entry_Write) Reset() + func (x *Entry_Write) String() string + type Entry_Write_ struct + Write *Entry_Write + func (m *Entry_Write_) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Entry_Write_) MarshalToVT(dAtA []byte) (int, error) + func (m *Entry_Write_) SizeVT() (n int) + type Record struct + Entry *Entry + func (*Record) Descriptor() ([]byte, []int) + func (*Record) ProtoMessage() + 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 (m *Record) SizeVT() (n int) + func (m *Record) UnmarshalVT(dAtA []byte) error + func (x *Record) GetEntry() *Entry + func (x *Record) ProtoReflect() protoreflect.Message + func (x *Record) Reset() + func (x *Record) String() string