mutable

package

v1.0.0 Latest Latest Go to latest Published: Feb 23, 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 ¶

type Config
- func NewConfig() *Config
- func (conf *Config) GetShardMutableSizeLimit() int
- func (conf *Config) SetShardMutableSizeLimit(limit int64)
type MemTable
- func GetMemTable(path string) *MemTable
- func NewMemTable(conf *Config, path string) *MemTable
type MemTables
type MsInfo
- func (msi *MsInfo) CreateChunk(sid uint64) (*WriteChunk, bool)
- func (msi *MsInfo) Init(row *influx.Row)
type SortAuxPool
type WriteChunk
- func (chunk *WriteChunk) Init(sid uint64, schema []record.Field)
type WriteRec
- func (writeRec *WriteRec) GetRecord() *record.Record

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

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

func NewConfig ¶

func NewConfig() *Config

func (*Config) GetShardMutableSizeLimit ¶

func (conf *Config) GetShardMutableSizeLimit() int

func (*Config) SetShardMutableSizeLimit ¶

func (conf *Config) SetShardMutableSizeLimit(limit int64)

type MemTable ¶

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

func GetMemTable ¶

func GetMemTable(path string) *MemTable

func NewMemTable ¶

func NewMemTable(conf *Config, path string) *MemTable

func (*MemTable) AddMemSize ¶

func (t *MemTable) AddMemSize(size int64)

nolint

func (*MemTable) ApplyConcurrency ¶

func (t *MemTable) ApplyConcurrency(f func(msName string, sids []uint64))

func (*MemTable) FlushChunks ¶

func (t *MemTable) FlushChunks(dataPath, msName string, lock *string, tbStore immutable.TablesStore, sids []uint64,
	f func(dataPath, msName string, lock *string, totalChunks int, tbStore immutable.TablesStore, chunk *WriteChunk,
		orderMs, unOrderMs *immutable.MsBuilder, finish bool) (*immutable.MsBuilder, *immutable.MsBuilder))

func (*MemTable) GetConf ¶

func (t *MemTable) GetConf() *Config

func (*MemTable) GetMaxTimeBySidNoLock ¶

func (t *MemTable) GetMaxTimeBySidNoLock(msName string, sid uint64) int64

func (*MemTable) GetMemSize ¶

func (t *MemTable) GetMemSize() int64

func (*MemTable) GetSids ¶

func (t *MemTable) GetSids(msName string, sids []uint64) []uint64

func (*MemTable) NeedFlush ¶

func (t *MemTable) NeedFlush() bool

func (*MemTable) PutMemTable ¶

func (t *MemTable) PutMemTable()

func (*MemTable) Ref ¶

func (t *MemTable) Ref()

func (*MemTable) Reset ¶

func (t *MemTable) Reset()

func (*MemTable) SetIdx ¶

func (t *MemTable) SetIdx(idx *ski.ShardKeyIndex)

func (*MemTable) SortAndDedup ¶

func (t *MemTable) SortAndDedup(msName string, sids []uint64)

func (*MemTable) UnRef ¶

func (t *MemTable) UnRef()

func (*MemTable) WriteRows ¶

func (t *MemTable) WriteRows(rowsD *dictpool.Dict, getLastFlushTime func(msName string, sid uint64) (int64, error),
	addRowCountsBySid func(msName string, sid uint64, rowCounts int64)) error

type MemTables ¶ added in v1.0.0

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

func (*MemTables) Init ¶ added in v1.0.0

func (m *MemTables) Init(activeTbl, snapshotTbl *MemTable, readEnable bool)

func (*MemTables) Ref ¶ added in v1.0.0

func (m *MemTables) Ref()

func (*MemTables) UnRef ¶ added in v1.0.0

func (m *MemTables) UnRef()

func (*MemTables) Values ¶ added in v1.0.0

func (m *MemTables) Values(msName string, id uint64, tr record.TimeRange, schema record.Schemas, ascending bool) *record.Record

type MsInfo ¶

type MsInfo struct {
	Name   string // measurement name with version
	Schema record.Schemas

	TimeAsd bool
	// contains filtered or unexported fields
}

func (*MsInfo) CreateChunk ¶ added in v1.0.0

func (msi *MsInfo) CreateChunk(sid uint64) (*WriteChunk, bool)

func (*MsInfo) Init ¶ added in v1.0.0

func (msi *MsInfo) Init(row *influx.Row)

type SortAuxPool ¶

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

type WriteChunk ¶

type WriteChunk struct {
	Mu              sync.Mutex
	Sid             uint64
	LastFlushTime   int64
	OrderWriteRec   WriteRec
	UnOrderWriteRec WriteRec
}

func (*WriteChunk) Init ¶

func (chunk *WriteChunk) Init(sid uint64, schema []record.Field)

type WriteRec ¶

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

func (*WriteRec) GetRecord ¶

func (writeRec *WriteRec) GetRecord() *record.Record

Source Files ¶

View all Source files

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