walv1alpha1

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Mar 23, 2024 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

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) Descriptor() ([]byte, []int)

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

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 (m *Entry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Entry) MarshalToVT 

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

func (*Entry) MarshalVT 

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

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) SizeVT 

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

func (*Entry) String 

func (x *Entry) String() string

func (*Entry) UnmarshalVT 

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetEntry 

func (x *Record) GetEntry() *Entry

func (*Record) MarshalToSizedBufferVT 

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

func (*Record) MarshalToVT 

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

func (*Record) MarshalVT 

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

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) SizeVT 

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

func (*Record) String 

func (x *Record) String() string

func (*Record) UnmarshalVT 

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

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.