colstore

package

v1.1.0 Latest Latest Go to latest Published: Sep 28, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Details

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

Repository

github.com/openGemini/openGemini

Links

Documentation ¶

Index ¶

Constants
func AppendIndexSuffix(dataPath string) string
func InitDecFunctions()
type ChunkBuilder
- func NewChunkBuilder() *ChunkBuilder
- func (b *ChunkBuilder) EncodeChunk(rec *record.Record, dst []byte, offset []byte, offsetStart uint32) ([]byte, error)
type ColumnBuilder
- func NewColumnBuilder() *ColumnBuilder
- func (b *ColumnBuilder) EncodeColumn(ref *record.Field, col *record.ColVal) ([]byte, error)
type IndexBuilder
- func NewIndexBuilder(lockPath *string, filePath string) *IndexBuilder
- func (b *IndexBuilder) Reset()
- func (b *IndexBuilder) WriteData(rec *record.Record) error
type PKFiles
- func NewPKFiles() *PKFiles
- func (f *PKFiles) DelPKInfo(file string)
- func (f *PKFiles) GetPKInfo(file string) (*PKInfo, bool)
- func (f *PKFiles) GetPKInfos() PKInfos
- func (f *PKFiles) SetPKInfo(file string, rec *record.Record, mark fragment.IndexFragment)
type PKInfo
- func (p *PKInfo) GetMark() fragment.IndexFragment
- func (p *PKInfo) GetRec() *record.Record
type PKInfos
type PrimaryKeyReader
- func NewPrimaryKeyReader(name string, lockPath *string) (*PrimaryKeyReader, error)
- func (r *PrimaryKeyReader) Close() error
- func (r *PrimaryKeyReader) FileSize() int64
- func (r *PrimaryKeyReader) Open() error
- func (r *PrimaryKeyReader) Read(offset int64, size uint32, dst *[]byte) ([]byte, error)
- func (r *PrimaryKeyReader) ReadData() (*record.Record, error)
- func (r *PrimaryKeyReader) Version() uint32

Constants ¶

View Source

const (
	RowsNumPerFragment  int    = 8192
	CoarseIndexFragment int    = 8
	MinRowsForSeek      int    = 0
	IndexFileSuffix     string = ".idx"
)

Variables ¶

This section is empty.

Functions ¶

func AppendIndexSuffix ¶

func AppendIndexSuffix(dataPath string) string

func InitDecFunctions ¶

func InitDecFunctions()

Types ¶

type ChunkBuilder ¶

type ChunkBuilder struct {
	// contains filtered or unexported fields
}

func NewChunkBuilder ¶

func NewChunkBuilder() *ChunkBuilder

func (*ChunkBuilder) EncodeChunk ¶

func (b *ChunkBuilder) EncodeChunk(rec *record.Record, dst []byte, offset []byte, offsetStart uint32) ([]byte, error)

type ColumnBuilder ¶

type ColumnBuilder struct {
	// contains filtered or unexported fields
}

func NewColumnBuilder ¶

func NewColumnBuilder() *ColumnBuilder

func (*ColumnBuilder) EncodeColumn ¶

func (b *ColumnBuilder) EncodeColumn(ref *record.Field, col *record.ColVal) ([]byte, error)

type IndexBuilder ¶

type IndexBuilder struct {
	// contains filtered or unexported fields
}

func NewIndexBuilder ¶

func NewIndexBuilder(lockPath *string, filePath string) *IndexBuilder

func (*IndexBuilder) Reset ¶

func (b *IndexBuilder) Reset()

func (*IndexBuilder) WriteData ¶

func (b *IndexBuilder) WriteData(rec *record.Record) error

type PKFiles ¶

type PKFiles struct {
	// contains filtered or unexported fields
}

func NewPKFiles ¶

func NewPKFiles() *PKFiles

func (*PKFiles) DelPKInfo ¶

func (f *PKFiles) DelPKInfo(file string)

func (*PKFiles) GetPKInfo ¶

func (f *PKFiles) GetPKInfo(file string) (*PKInfo, bool)

func (*PKFiles) GetPKInfos ¶

func (f *PKFiles) GetPKInfos() PKInfos

func (*PKFiles) SetPKInfo ¶

func (f *PKFiles) SetPKInfo(file string, rec *record.Record, mark fragment.IndexFragment)

type PKInfo ¶

type PKInfo struct {
	// contains filtered or unexported fields
}

func (*PKInfo) GetMark ¶

func (p *PKInfo) GetMark() fragment.IndexFragment

func (*PKInfo) GetRec ¶

func (p *PKInfo) GetRec() *record.Record

type PKInfos ¶

type PKInfos map[string]*PKInfo

type PrimaryKeyReader ¶

type PrimaryKeyReader struct {
	// contains filtered or unexported fields
}

func NewPrimaryKeyReader ¶

func NewPrimaryKeyReader(name string, lockPath *string) (*PrimaryKeyReader, error)

func (*PrimaryKeyReader) Close ¶

func (r *PrimaryKeyReader) Close() error

func (*PrimaryKeyReader) FileSize ¶

func (r *PrimaryKeyReader) FileSize() int64

func (*PrimaryKeyReader) Open ¶

func (r *PrimaryKeyReader) Open() error

func (*PrimaryKeyReader) Read ¶

func (r *PrimaryKeyReader) Read(offset int64, size uint32, dst *[]byte) ([]byte, error)

func (*PrimaryKeyReader) ReadData ¶

func (r *PrimaryKeyReader) ReadData() (*record.Record, error)

func (*PrimaryKeyReader) Version ¶

func (r *PrimaryKeyReader) Version() uint32

Source Files ¶

View all Source files

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