mutable

Nov 27, 2025

Changes in this version

+ type CSMemTableImpl struct

+ func NewCSMemTableImpl(db, rp string) *CSMemTableImpl

+ func (c *CSMemTableImpl) FlushChunks(table *MemTable, dataPath, msName, db, rp string, lock *string, ...)

+ func (c *CSMemTableImpl) FlushChunksDetached(table *MemTable, dataPath string, ident colstore.MeasurementIdent, ...)

+ func (c *CSMemTableImpl) Reset(t *MemTable)

+ func (c *CSMemTableImpl) SetDbRp(db, rp string)

+ func (c *CSMemTableImpl) SetFlushManagerInfo(manager map[string]FlushManager, accumulateMetaIndex *sync.Map)

+ func (c *CSMemTableImpl) WriteCols(table *MemTable, rec *record.Record, mst string) error

+ func (c *CSMemTableImpl) WriteRows(table *MemTable, rowsD dictmap.DictMap[string, *[]influx.Row], ...) error

type MemTable

+ func (t *MemTable) SetDbRp(db, rp string)

+ type RecordFlusher struct

+ func NewRecordFlusher(tbStore immutable.TablesStore, mst string, ...) *RecordFlusher

+ func (rf *RecordFlusher) Flush() ([]immutable.TSSPFile, []immutable.TSSPFile, error)

+ func (rf *RecordFlusher) FlushRecord(sid uint64, rec *record.Record) error

+ func (rf *RecordFlusher) Free()

+ type SeriesRowCountFunc func(msName string, sid uint64, rowCounts int64)

+ type WriteAttached struct

+ func NewWriteAttached(mst *colstore.Measurement) *WriteAttached

+ func (w *WriteAttached) FlushRecord(tbStore immutable.TablesStore, rec *record.Record)

+ func (w *WriteAttached) SetDBInfo(db string, rp string)

+ func (w *WriteAttached) WriteRecordForFlush(rec *record.Record, msb *immutable.MsBuilder, tbStore immutable.TablesStore, ...) *immutable.MsBuilder

type WriteChunkForColumnStore

+ func NewWriteChunkForColumnStore() *WriteChunkForColumnStore

type WriteRowsCtx

+ func (ctx *WriteRowsCtx) SetMsRowCount(v *util.SyncMap[string, *int64])

+ func (ctx *WriteRowsCtx) SetSeriesRowCountFunc(fn SeriesRowCountFunc)

Apr 12, 2025

Changes in this version

+ func NewTsMemTableImpl() *tsMemTableImpl

+ func SetShelfMemRecordReader(r MemRecordReader)

type FlushManager

+ SetDBInfo func(db string, rp string)

type MTable

+ GetClient func() metaclient.MetaClient

+ type MemRecordReader func(shardID uint64, mst string, sid uint64, tr *util.TimeRange, ...) *record.Record

type MemTables

+ func NewMemTables(shardID uint64, readEnable bool) *MemTables

+ type RecordIterator interface

+ Next func(dst *record.Record) (uint64, error)

Nov 12, 2024

Changes in this version

+ func GetSortKeys(schema []record.Field, primaryKeys []string) []record.PrimaryKey

+ func Init(cpuNum int)

+ func SplitRecordByTime(rec *record.Record, pool []record.Record, time int64) (*record.Record, *record.Record)

type MTable

+ SetClient func(client metaclient.MetaClient)

type WriteChunk

+ WriteRec WriteRec

Feb 29, 2024

Changes in this version

+ func GetMsInfo(name string, mstsInfo *sync.Map) (*meta.MeasurementInfo, bool)

+ type FlushManager interface

type MTable

+ SetFlushManagerInfo func(manager map[string]FlushManager, accumulateMetaIndex *sync.Map)

type MsInfo

+ func (msi *MsInfo) GetFlushed() *bool

type WriteChunkForColumnStore

+ func (chunk *WriteChunkForColumnStore) TimeSorted() bool

Nov 7, 2023

Changes in this version

+ func MergeSchema(table *MemTable, msName string)

+ func UpdateMstRowCount(msRowCount *sync.Map, mstName string, rowCount int64)

type MemTable

+ func (t *MemTable) SetReleaseHook(hook MemTableReleaseHook)

+ type MemTablePool struct

+ func NewMemTablePool() *MemTablePool

+ func (p *MemTablePool) Expired() bool

+ func (p *MemTablePool) Get(engineType config.EngineType) *MemTable

+ func (p *MemTablePool) Put(tb *MemTable)

+ func (p *MemTablePool) SetExpire(v uint64)

+ func (p *MemTablePool) Size() int

+ type MemTablePoolManager struct

+ func NewMemTablePoolManager() *MemTablePoolManager

+ func (pm *MemTablePoolManager) Alloc(key string) *MemTablePool

+ func (pm *MemTablePoolManager) Close()

+ func (pm *MemTablePoolManager) Free()

+ func (pm *MemTablePoolManager) Init()

+ func (pm *MemTablePoolManager) Size() int

+ type MemTableReleaseHook func(t *MemTable)

Sep 28, 2023

Changes in this version

+ func GetPrimaryKeys(schema []record.Field, primaryKeys []string) []record.PrimaryKey

+ func GetSidsImpl(size int) []uint64

+ func GetSizeLimit() int64

+ func InitConcurLimiter(limit int)

+ func InitMutablePool(size int)

+ func InitWriteRecPool(size int)

+ func JoinWriteRec(table *MemTable, msName string)

+ func LoadMstRowCount(countFile string) (int, error)

+ func PutSidsImpl(sids []uint64)

+ func SetSizeLimit(limit int64)

+ func SetWriteChunk(msi *MsInfo, rec *record.Record)

+ func SortAndDedup(table *MemTable, msName string)

+ func StoreMstRowCount(countFile string, rowCount int) error

+ func WriteIntoFile(msb *immutable.MsBuilder, tmp bool, withPKIndex bool) error

+ func WriteRecordForFlush(rec *record.Record, msb *immutable.MsBuilder, tbStore immutable.TablesStore, ...) *immutable.MsBuilder

+ type MTable interface

+ ApplyConcurrency func(table *MemTable, f func(msName string))

+ FlushChunks func(table *MemTable, dataPath, msName string, lock *string, ...)

+ Reset func(table *MemTable)

+ WriteCols func(table *MemTable, rec *record.Record, mstsInfo map[string]*meta.MeasurementInfo, ...) error

+ WriteRows func(table *MemTable, rowsD *dictpool.Dict, wc WriteRowsCtx) error

type MemTable

+ MTable MTable

+ func (t *MemTable) CreateMsInfo(name string, row *influx.Row, rec *record.Record) *MsInfo

+ func (t *MemTable) GetMsInfo(name string) (*MsInfo, error)

+ func (t *MemTable) SetMsInfo(name string, msInfo *MsInfo)

type MsInfo

+ func (msi *MsInfo) CreateWriteChunkForColumnStore(sortKeys []string)

+ func (msi *MsInfo) GetAllSid() []uint64

+ func (msi *MsInfo) GetRowChunks() *rowChunks

+ func (msi *MsInfo) GetWriteChunk() *WriteChunkForColumnStore

+ func (msi *MsInfo) SetWriteChunk(writeChunk *WriteChunkForColumnStore)

+ type SidsPool struct

type WriteChunk

+ func (chunk *WriteChunk) SortRecord(hlp *record.SortHelper)

+ func (chunk *WriteChunk) SortRecordNoLock(hlp *record.SortHelper)

+ type WriteChunkForColumnStore struct

+ Mu sync.Mutex

+ WriteRec WriteRec

+ func (chunk *WriteChunkForColumnStore) SortRecord()

type WriteRec

+ func (writeRec *WriteRec) SetLastAppendTime(v int64)

+ func (writeRec *WriteRec) SetWriteRec(rec *record.Record)

+ func (writeRec *WriteRec) SortRecord(hlp *record.SortHelper)

+ type WriteRowsCtx struct

+ AddRowCountsBySid func(msName string, sid uint64, rowCounts int64)

+ GetLastFlushTime func(msName string, sid uint64) int64

+ MsRowCount *sync.Map

+ MstsInfo map[string]*meta.MeasurementInfo

Feb 23, 2023

Changes in this version

+ type MemTables struct

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

+ func (m *MemTables) Ref()

+ func (m *MemTables) UnRef()

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

type MsInfo

+ Name string

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

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

Sep 27, 2022

Changes in this version

+ type Config struct

+ func NewConfig() *Config

+ func (conf *Config) GetShardMutableSizeLimit() int

+ func (conf *Config) SetShardMutableSizeLimit(limit int64)

+ type MemTable struct

+ func GetMemTable(path string) *MemTable

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

+ func (t *MemTable) AddMemSize(size int64)

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

+ func (t *MemTable) Close() error

+ func (t *MemTable) FlushChunks(dataPath, msName string, tbStore immutable.TablesStore, sids []uint64, ...)

+ func (t *MemTable) GetConf() *Config

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

+ func (t *MemTable) GetMemSize() int64

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

+ func (t *MemTable) NeedFlush() bool

+ func (t *MemTable) PutMemTable()

+ func (t *MemTable) Ref()

+ func (t *MemTable) Reset()

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

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

+ func (t *MemTable) UnRef()

+ func (t *MemTable) Values(msName string, id uint64, tr record.TimeRange, schema record.Schemas, ...) *record.Record

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

+ type MsInfo struct

+ Schema record.Schemas

+ TimeAsd bool

+ type SortAuxPool struct

+ type WriteChunk struct

+ LastFlushTime int64

+ Mu sync.Mutex

+ OrderWriteRec WriteRec

+ Sid uint64

+ UnOrderWriteRec WriteRec

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

+ type WriteRec struct

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