Documentation ¶
Index ¶
- Variables
- type BloomFilter
- func (*BloomFilter) Descriptor() ([]byte, []int)deprecated
- func (x *BloomFilter) GetCrc32() uint32
- func (x *BloomFilter) GetData() []byte
- func (x *BloomFilter) GetNumBytes() int32
- func (x *BloomFilter) GetNumHashes() int32
- func (*BloomFilter) ProtoMessage()
- func (x *BloomFilter) ProtoReflect() protoreflect.Message
- func (x *BloomFilter) Reset()
- func (x *BloomFilter) String() string
- type DataEntry
- type IndexEntry
- type MemtableInfo
- func (*MemtableInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MemtableInfo) GetId() int64
- func (x *MemtableInfo) GetWalFile() string
- func (*MemtableInfo) ProtoMessage()
- func (x *MemtableInfo) ProtoReflect() protoreflect.Message
- func (x *MemtableInfo) Reset()
- func (x *MemtableInfo) String() string
- type SSTableInfo
- func (*SSTableInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SSTableInfo) GetBloomFile() string
- func (x *SSTableInfo) GetDataFile() string
- func (x *SSTableInfo) GetId() int64
- func (x *SSTableInfo) GetIndexFile() string
- func (x *SSTableInfo) GetLevel() int32
- func (x *SSTableInfo) GetMetaFile() string
- func (x *SSTableInfo) GetNumRecords() int64
- func (x *SSTableInfo) GetSize() int64
- func (*SSTableInfo) ProtoMessage()
- func (x *SSTableInfo) ProtoReflect() protoreflect.Message
- func (x *SSTableInfo) Reset()
- func (x *SSTableInfo) String() string
- type SegmentCreated
- type SegmentFlushed
- func (*SegmentFlushed) Descriptor() ([]byte, []int)deprecated
- func (x *SegmentFlushed) GetMemtableId() int64
- func (x *SegmentFlushed) GetSstable() *SSTableInfo
- func (*SegmentFlushed) ProtoMessage()
- func (x *SegmentFlushed) ProtoReflect() protoreflect.Message
- func (x *SegmentFlushed) Reset()
- func (x *SegmentFlushed) String() string
- type SegmentsMerged
- func (*SegmentsMerged) Descriptor() ([]byte, []int)deprecated
- func (x *SegmentsMerged) GetNewSstable() *SSTableInfo
- func (x *SegmentsMerged) GetOldSstableIds() []int64
- func (*SegmentsMerged) ProtoMessage()
- func (x *SegmentsMerged) ProtoReflect() protoreflect.Message
- func (x *SegmentsMerged) Reset()
- func (x *SegmentsMerged) String() string
- type StateChangeType
- func (StateChangeType) Descriptor() protoreflect.EnumDescriptor
- func (x StateChangeType) Enum() *StateChangeType
- func (StateChangeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x StateChangeType) Number() protoreflect.EnumNumber
- func (x StateChangeType) String() string
- func (StateChangeType) Type() protoreflect.EnumType
- type StateLogEntry
- func (*StateLogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *StateLogEntry) GetChangeType() StateChangeType
- func (x *StateLogEntry) GetSegmentCreated() *SegmentCreated
- func (x *StateLogEntry) GetSegmentFlushed() *SegmentFlushed
- func (x *StateLogEntry) GetSegmentsMerged() *SegmentsMerged
- func (x *StateLogEntry) GetTimestamp() int64
- func (*StateLogEntry) ProtoMessage()
- func (x *StateLogEntry) ProtoReflect() protoreflect.Message
- func (x *StateLogEntry) Reset()
- func (x *StateLogEntry) String() string
- type TableMeta
- type Value
Constants ¶
This section is empty.
Variables ¶
View Source
var ( StateChangeType_name = map[int32]string{ 0: "SEGMENT_CREATED", 1: "SEGMENT_FLUSHED", 2: "SEGMENTS_MERGED", } StateChangeType_value = map[string]int32{ "SEGMENT_CREATED": 0, "SEGMENT_FLUSHED": 1, "SEGMENTS_MERGED": 2, } )
Enum value maps for StateChangeType.
View Source
var File_storage_lsmtree_proto_lsm_proto protoreflect.FileDescriptor
View Source
var File_storage_lsmtree_proto_state_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BloomFilter ¶
type BloomFilter struct { NumBytes int32 `protobuf:"varint,1,opt,name=num_bytes,json=numBytes,proto3" json:"num_bytes,omitempty"` NumHashes int32 `protobuf:"varint,2,opt,name=num_hashes,json=numHashes,proto3" json:"num_hashes,omitempty"` Crc32 uint32 `protobuf:"varint,3,opt,name=crc32,proto3" json:"crc32,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*BloomFilter) Descriptor
deprecated
func (*BloomFilter) Descriptor() ([]byte, []int)
Deprecated: Use BloomFilter.ProtoReflect.Descriptor instead.
func (*BloomFilter) GetCrc32 ¶
func (x *BloomFilter) GetCrc32() uint32
func (*BloomFilter) GetData ¶
func (x *BloomFilter) GetData() []byte
func (*BloomFilter) GetNumBytes ¶
func (x *BloomFilter) GetNumBytes() int32
func (*BloomFilter) GetNumHashes ¶
func (x *BloomFilter) GetNumHashes() int32
func (*BloomFilter) ProtoMessage ¶
func (*BloomFilter) ProtoMessage()
func (*BloomFilter) ProtoReflect ¶
func (x *BloomFilter) ProtoReflect() protoreflect.Message
func (*BloomFilter) Reset ¶
func (x *BloomFilter) Reset()
func (*BloomFilter) String ¶
func (x *BloomFilter) String() string
type DataEntry ¶
type DataEntry struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Values []*Value `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*DataEntry) Descriptor
deprecated
func (*DataEntry) ProtoMessage ¶
func (*DataEntry) ProtoMessage()
func (*DataEntry) ProtoReflect ¶
func (x *DataEntry) ProtoReflect() protoreflect.Message
type IndexEntry ¶
type IndexEntry struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` DataOffset int64 `protobuf:"varint,2,opt,name=data_offset,json=dataOffset,proto3" json:"data_offset,omitempty"` // contains filtered or unexported fields }
func (*IndexEntry) Descriptor
deprecated
func (*IndexEntry) Descriptor() ([]byte, []int)
Deprecated: Use IndexEntry.ProtoReflect.Descriptor instead.
func (*IndexEntry) GetDataOffset ¶
func (x *IndexEntry) GetDataOffset() int64
func (*IndexEntry) GetKey ¶
func (x *IndexEntry) GetKey() string
func (*IndexEntry) ProtoMessage ¶
func (*IndexEntry) ProtoMessage()
func (*IndexEntry) ProtoReflect ¶
func (x *IndexEntry) ProtoReflect() protoreflect.Message
func (*IndexEntry) Reset ¶
func (x *IndexEntry) Reset()
func (*IndexEntry) String ¶
func (x *IndexEntry) String() string
type MemtableInfo ¶
type MemtableInfo struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` WalFile string `protobuf:"bytes,2,opt,name=wal_file,json=walFile,proto3" json:"wal_file,omitempty"` // contains filtered or unexported fields }
func (*MemtableInfo) Descriptor
deprecated
func (*MemtableInfo) Descriptor() ([]byte, []int)
Deprecated: Use MemtableInfo.ProtoReflect.Descriptor instead.
func (*MemtableInfo) GetId ¶
func (x *MemtableInfo) GetId() int64
func (*MemtableInfo) GetWalFile ¶
func (x *MemtableInfo) GetWalFile() string
func (*MemtableInfo) ProtoMessage ¶
func (*MemtableInfo) ProtoMessage()
func (*MemtableInfo) ProtoReflect ¶
func (x *MemtableInfo) ProtoReflect() protoreflect.Message
func (*MemtableInfo) Reset ¶
func (x *MemtableInfo) Reset()
func (*MemtableInfo) String ¶
func (x *MemtableInfo) String() string
type SSTableInfo ¶
type SSTableInfo struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Level int32 `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"` Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` NumRecords int64 `protobuf:"varint,4,opt,name=num_records,json=numRecords,proto3" json:"num_records,omitempty"` IndexFile string `protobuf:"bytes,5,opt,name=index_file,json=indexFile,proto3" json:"index_file,omitempty"` DataFile string `protobuf:"bytes,6,opt,name=data_file,json=dataFile,proto3" json:"data_file,omitempty"` BloomFile string `protobuf:"bytes,7,opt,name=bloom_file,json=bloomFile,proto3" json:"bloom_file,omitempty"` MetaFile string `protobuf:"bytes,8,opt,name=meta_file,json=metaFile,proto3" json:"meta_file,omitempty"` // contains filtered or unexported fields }
func (*SSTableInfo) Descriptor
deprecated
func (*SSTableInfo) Descriptor() ([]byte, []int)
Deprecated: Use SSTableInfo.ProtoReflect.Descriptor instead.
func (*SSTableInfo) GetBloomFile ¶
func (x *SSTableInfo) GetBloomFile() string
func (*SSTableInfo) GetDataFile ¶
func (x *SSTableInfo) GetDataFile() string
func (*SSTableInfo) GetId ¶
func (x *SSTableInfo) GetId() int64
func (*SSTableInfo) GetIndexFile ¶
func (x *SSTableInfo) GetIndexFile() string
func (*SSTableInfo) GetLevel ¶
func (x *SSTableInfo) GetLevel() int32
func (*SSTableInfo) GetMetaFile ¶
func (x *SSTableInfo) GetMetaFile() string
func (*SSTableInfo) GetNumRecords ¶
func (x *SSTableInfo) GetNumRecords() int64
func (*SSTableInfo) GetSize ¶
func (x *SSTableInfo) GetSize() int64
func (*SSTableInfo) ProtoMessage ¶
func (*SSTableInfo) ProtoMessage()
func (*SSTableInfo) ProtoReflect ¶
func (x *SSTableInfo) ProtoReflect() protoreflect.Message
func (*SSTableInfo) Reset ¶
func (x *SSTableInfo) Reset()
func (*SSTableInfo) String ¶
func (x *SSTableInfo) String() string
type SegmentCreated ¶
type SegmentCreated struct { Memtable *MemtableInfo `protobuf:"bytes,1,opt,name=memtable,proto3" json:"memtable,omitempty"` // contains filtered or unexported fields }
func (*SegmentCreated) Descriptor
deprecated
func (*SegmentCreated) Descriptor() ([]byte, []int)
Deprecated: Use SegmentCreated.ProtoReflect.Descriptor instead.
func (*SegmentCreated) GetMemtable ¶
func (x *SegmentCreated) GetMemtable() *MemtableInfo
func (*SegmentCreated) ProtoMessage ¶
func (*SegmentCreated) ProtoMessage()
func (*SegmentCreated) ProtoReflect ¶
func (x *SegmentCreated) ProtoReflect() protoreflect.Message
func (*SegmentCreated) Reset ¶
func (x *SegmentCreated) Reset()
func (*SegmentCreated) String ¶
func (x *SegmentCreated) String() string
type SegmentFlushed ¶
type SegmentFlushed struct { MemtableId int64 `protobuf:"varint,1,opt,name=memtable_id,json=memtableId,proto3" json:"memtable_id,omitempty"` Sstable *SSTableInfo `protobuf:"bytes,2,opt,name=sstable,proto3" json:"sstable,omitempty"` // contains filtered or unexported fields }
func (*SegmentFlushed) Descriptor
deprecated
func (*SegmentFlushed) Descriptor() ([]byte, []int)
Deprecated: Use SegmentFlushed.ProtoReflect.Descriptor instead.
func (*SegmentFlushed) GetMemtableId ¶
func (x *SegmentFlushed) GetMemtableId() int64
func (*SegmentFlushed) GetSstable ¶
func (x *SegmentFlushed) GetSstable() *SSTableInfo
func (*SegmentFlushed) ProtoMessage ¶
func (*SegmentFlushed) ProtoMessage()
func (*SegmentFlushed) ProtoReflect ¶
func (x *SegmentFlushed) ProtoReflect() protoreflect.Message
func (*SegmentFlushed) Reset ¶
func (x *SegmentFlushed) Reset()
func (*SegmentFlushed) String ¶
func (x *SegmentFlushed) String() string
type SegmentsMerged ¶
type SegmentsMerged struct { OldSstableIds []int64 `protobuf:"varint,1,rep,packed,name=old_sstable_ids,json=oldSstableIds,proto3" json:"old_sstable_ids,omitempty"` NewSstable *SSTableInfo `protobuf:"bytes,2,opt,name=new_sstable,json=newSstable,proto3" json:"new_sstable,omitempty"` // contains filtered or unexported fields }
func (*SegmentsMerged) Descriptor
deprecated
func (*SegmentsMerged) Descriptor() ([]byte, []int)
Deprecated: Use SegmentsMerged.ProtoReflect.Descriptor instead.
func (*SegmentsMerged) GetNewSstable ¶
func (x *SegmentsMerged) GetNewSstable() *SSTableInfo
func (*SegmentsMerged) GetOldSstableIds ¶
func (x *SegmentsMerged) GetOldSstableIds() []int64
func (*SegmentsMerged) ProtoMessage ¶
func (*SegmentsMerged) ProtoMessage()
func (*SegmentsMerged) ProtoReflect ¶
func (x *SegmentsMerged) ProtoReflect() protoreflect.Message
func (*SegmentsMerged) Reset ¶
func (x *SegmentsMerged) Reset()
func (*SegmentsMerged) String ¶
func (x *SegmentsMerged) String() string
type StateChangeType ¶
type StateChangeType int32
const ( StateChangeType_SEGMENT_CREATED StateChangeType = 0 StateChangeType_SEGMENT_FLUSHED StateChangeType = 1 StateChangeType_SEGMENTS_MERGED StateChangeType = 2 )
func (StateChangeType) Descriptor ¶
func (StateChangeType) Descriptor() protoreflect.EnumDescriptor
func (StateChangeType) Enum ¶
func (x StateChangeType) Enum() *StateChangeType
func (StateChangeType) EnumDescriptor
deprecated
func (StateChangeType) EnumDescriptor() ([]byte, []int)
Deprecated: Use StateChangeType.Descriptor instead.
func (StateChangeType) Number ¶
func (x StateChangeType) Number() protoreflect.EnumNumber
func (StateChangeType) String ¶
func (x StateChangeType) String() string
func (StateChangeType) Type ¶
func (StateChangeType) Type() protoreflect.EnumType
type StateLogEntry ¶
type StateLogEntry struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ChangeType StateChangeType `protobuf:"varint,2,opt,name=change_type,json=changeType,proto3,enum=lsm.StateChangeType" json:"change_type,omitempty"` SegmentCreated *SegmentCreated `protobuf:"bytes,3,opt,name=segment_created,json=segmentCreated,proto3" json:"segment_created,omitempty"` SegmentFlushed *SegmentFlushed `protobuf:"bytes,4,opt,name=segment_flushed,json=segmentFlushed,proto3" json:"segment_flushed,omitempty"` SegmentsMerged *SegmentsMerged `protobuf:"bytes,5,opt,name=segments_merged,json=segmentsMerged,proto3" json:"segments_merged,omitempty"` // contains filtered or unexported fields }
func (*StateLogEntry) Descriptor
deprecated
func (*StateLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use StateLogEntry.ProtoReflect.Descriptor instead.
func (*StateLogEntry) GetChangeType ¶
func (x *StateLogEntry) GetChangeType() StateChangeType
func (*StateLogEntry) GetSegmentCreated ¶
func (x *StateLogEntry) GetSegmentCreated() *SegmentCreated
func (*StateLogEntry) GetSegmentFlushed ¶
func (x *StateLogEntry) GetSegmentFlushed() *SegmentFlushed
func (*StateLogEntry) GetSegmentsMerged ¶
func (x *StateLogEntry) GetSegmentsMerged() *SegmentsMerged
func (*StateLogEntry) GetTimestamp ¶
func (x *StateLogEntry) GetTimestamp() int64
func (*StateLogEntry) ProtoMessage ¶
func (*StateLogEntry) ProtoMessage()
func (*StateLogEntry) ProtoReflect ¶
func (x *StateLogEntry) ProtoReflect() protoreflect.Message
func (*StateLogEntry) Reset ¶
func (x *StateLogEntry) Reset()
func (*StateLogEntry) String ¶
func (x *StateLogEntry) String() string
type TableMeta ¶
type TableMeta struct { NumEntries int64 `protobuf:"varint,1,opt,name=num_entries,json=numEntries,proto3" json:"num_entries,omitempty"` Level int32 `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"` // contains filtered or unexported fields }
func (*TableMeta) Descriptor
deprecated
func (*TableMeta) GetNumEntries ¶
func (*TableMeta) ProtoMessage ¶
func (*TableMeta) ProtoMessage()
func (*TableMeta) ProtoReflect ¶
func (x *TableMeta) ProtoReflect() protoreflect.Message
type Value ¶
type Value struct { Tombstone bool `protobuf:"varint,1,opt,name=tombstone,proto3" json:"tombstone,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Value) Descriptor
deprecated
func (*Value) GetTombstone ¶
func (*Value) GetVersion ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.