mutable

package
v1.5.3-rc4 Latest Latest
Warning

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

 Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetMsInfo added in v1.2.0 

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

func GetSidsImpl added in v1.1.0 

func GetSidsImpl(size int) []uint64

func GetSortKeys added in v1.3.0 

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

func Init added in v1.3.0 

func Init(cpuNum int)

func InitMutablePool added in v1.1.0 

func InitMutablePool(size int)

func LoadMstRowCount added in v1.1.0 

func LoadMstRowCount(countFile string) (int, error)

LoadMstRowCount is used to load the rowcount value for mst-level pre-aggregation.

func NewTsMemTableImpl added in v1.4.0 

func NewTsMemTableImpl() *tsMemTableImpl

func PutSidsImpl added in v1.1.0 

func PutSidsImpl(sids []uint64)

func SplitRecordByTime added in v1.3.0 

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

func StoreMstRowCount added in v1.1.0 

func StoreMstRowCount(countFile string, rowCount int) error

StoreMstRowCount is used to persist the rowcount value for mst-level pre-aggregation.

func UpdateMstRowCount added in v1.1.1 

func UpdateMstRowCount(msRowCount *util.SyncMap[string, *int64], mstName string, rowCount int64)

Types

type CSMemTableImpl added in v1.5.0 

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

func NewCSMemTableImpl added in v1.5.0 

func NewCSMemTableImpl(db, rp string) *CSMemTableImpl

func (*CSMemTableImpl) FlushChunks added in v1.5.0 

func (c *CSMemTableImpl) FlushChunks(table *MemTable, msName string, tbStore immutable.TablesStore, _ chan []immutable.FileInfoExtend)

func (*CSMemTableImpl) Reset added in v1.5.0 

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

func (*CSMemTableImpl) SetDbRp added in v1.5.0 

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

func (*CSMemTableImpl) WriteCols added in v1.5.0 

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

func (*CSMemTableImpl) WriteRows added in v1.5.0 

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

type MTable added in v1.1.0 

type MTable interface {
	FlushChunks(table *MemTable, msName string, tbStore immutable.TablesStore, fileInfos chan []immutable.FileInfoExtend)
	WriteRows(table *MemTable, rowsD dictmap.DictMap[string, *[]influx.Row], wc WriteRowsCtx) error
	WriteCols(table *MemTable, rec *record.Record, mst string) error
	Reset(table *MemTable)
	// contains filtered or unexported methods
}

type MemTable 

type MemTable struct {
	MTable MTable //public method in MemTable
	// contains filtered or unexported fields
}

func NewMemTable 

func NewMemTable(engineType config.EngineType) *MemTable

func (*MemTable) AddMemSize 

func (t *MemTable) AddMemSize(size int64)

nolint

func (*MemTable) ApplyConcurrency 

func (t *MemTable) ApplyConcurrency(f func(msName string))

func (*MemTable) CreateMsInfo added in v1.1.0 

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

func (*MemTable) GetMemSize 

func (t *MemTable) GetMemSize() int64

func (*MemTable) GetMsInfo added in v1.1.0 

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

func (*MemTable) NeedFlush 

func (t *MemTable) NeedFlush() bool

func (*MemTable) Ref 

func (t *MemTable) Ref()

func (*MemTable) Reset 

func (t *MemTable) Reset()

func (*MemTable) SetDbRp added in v1.5.0 

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

func (*MemTable) SetIdx 

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

func (*MemTable) SetMsInfo added in v1.1.0 

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

func (*MemTable) SetReleaseHook added in v1.1.1 

func (t *MemTable) SetReleaseHook(hook MemTableReleaseHook)

func (*MemTable) UnRef 

func (t *MemTable) UnRef()

type MemTablePool added in v1.1.1 

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

func NewMemTablePool added in v1.1.1 

func NewMemTablePool() *MemTablePool

func (*MemTablePool) Expired added in v1.1.1 

func (p *MemTablePool) Expired() bool

func (*MemTablePool) Get added in v1.1.1 

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

func (*MemTablePool) Put added in v1.1.1 

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

func (*MemTablePool) SetExpire added in v1.1.1 

func (p *MemTablePool) SetExpire(v uint64)

func (*MemTablePool) Size added in v1.1.1 

func (p *MemTablePool) Size() int

type MemTablePoolManager added in v1.1.1 

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

func NewMemTablePoolManager added in v1.1.1 

func NewMemTablePoolManager() *MemTablePoolManager

func (*MemTablePoolManager) Alloc added in v1.1.1 

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

func (*MemTablePoolManager) Close added in v1.1.1 

func (pm *MemTablePoolManager) Close()

func (*MemTablePoolManager) Free added in v1.1.1 

func (pm *MemTablePoolManager) Free()

func (*MemTablePoolManager) Init added in v1.1.1 

func (pm *MemTablePoolManager) Init()

func (*MemTablePoolManager) Size added in v1.1.1 

func (pm *MemTablePoolManager) Size() int

type MemTableReleaseHook added in v1.1.1 

type MemTableReleaseHook func(t *MemTable)

type MemTables added in v1.0.0 

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

func NewMemTables added in v1.4.0 

func NewMemTables(readEnable bool) *MemTables

func (*MemTables) Init added in v1.0.0 

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

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 util.TimeRange, schema record.Schemas, ascending bool) *record.Record

type MsInfo 

type MsInfo struct {
	Name   string // measurement name with version
	Schema record.Schemas
	// contains filtered or unexported fields
}

func (*MsInfo) CreateChunk added in v1.0.0 

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

func (*MsInfo) CreateWriteChunkForColumnStore added in v1.1.0 

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

func (*MsInfo) GetAllSid added in v1.1.0 

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

func (*MsInfo) GetFlushed added in v1.2.0 

func (msi *MsInfo) GetFlushed() *bool

func (*MsInfo) GetWriteChunk added in v1.1.0 

func (msi *MsInfo) GetWriteChunk() *WriteChunkForColumnStore

func (*MsInfo) Init added in v1.0.0 

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

func (*MsInfo) SetWriteChunk added in v1.1.0 

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

type RecordFlusher added in v1.5.0 

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

func NewRecordFlusher added in v1.5.0 

func NewRecordFlusher(tbStore immutable.TablesStore, mst string, fileInfos chan []immutable.FileInfoExtend) *RecordFlusher

func (*RecordFlusher) Flush added in v1.5.0 

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

func (*RecordFlusher) FlushRecord added in v1.5.0 

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

func (*RecordFlusher) Free added in v1.5.0 

func (rf *RecordFlusher) Free()

type RecordIterator added in v1.4.0 

type RecordIterator interface {
	Next(dst *record.Record) (uint64, error)
}

type SeriesRowCountFunc added in v1.5.0 

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

type SidsPool added in v1.1.0 

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

type WriteAttached added in v1.5.0 

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

func NewWriteAttached added in v1.5.0 

func NewWriteAttached(mst *colstore.Measurement) *WriteAttached

func (*WriteAttached) FlushRecord added in v1.5.0 

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

func (*WriteAttached) SetDBInfo added in v1.5.0 

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

func (*WriteAttached) WriteRecordForFlush added in v1.5.0 

func (w *WriteAttached) WriteRecordForFlush(rec *record.Record, msb *immutable.MsBuilder, tbStore immutable.TablesStore, id uint64, order bool,
	lastFlushTime int64, schema record.Schemas, skipIndexRelation *influxql.IndexRelation) *immutable.MsBuilder

type WriteChunk 

type WriteChunk struct {
	Mu       sync.Mutex
	Sid      uint64
	WriteRec WriteRec
}

func (*WriteChunk) Init 

func (chunk *WriteChunk) Init(sid uint64)

func (*WriteChunk) SortRecord added in v1.1.0 

func (chunk *WriteChunk) SortRecord(hlp *record.ColumnSortHelper)

func (*WriteChunk) SortRecordNoLock added in v1.1.0 

func (chunk *WriteChunk) SortRecordNoLock(hlp *record.ColumnSortHelper)

type WriteChunkForColumnStore added in v1.1.0 

type WriteChunkForColumnStore struct {
	Mu       sync.Mutex
	WriteRec WriteRec
	// contains filtered or unexported fields
}

func NewWriteChunkForColumnStore added in v1.5.0 

func NewWriteChunkForColumnStore() *WriteChunkForColumnStore

func (*WriteChunkForColumnStore) SortRecord added in v1.1.0 

func (chunk *WriteChunkForColumnStore) SortRecord(tcDuration time.Duration)

func (*WriteChunkForColumnStore) TimeSorted added in v1.2.0 

func (chunk *WriteChunkForColumnStore) TimeSorted() bool

type WriteRec 

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

func (*WriteRec) GetRecord 

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

func (*WriteRec) SetLastAppendTime added in v1.1.0 

func (writeRec *WriteRec) SetLastAppendTime(v int64)

func (*WriteRec) SetWriteRec added in v1.1.0 

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

func (*WriteRec) SortRecord added in v1.1.0 

func (writeRec *WriteRec) SortRecord(hlp *record.ColumnSortHelper)

type WriteRowsCtx added in v1.1.0 

type WriteRowsCtx struct {
	AddRowCountsBySid SeriesRowCountFunc
	MsRowCount        *util.SyncMap[string, *int64]
}

func (*WriteRowsCtx) SetMsRowCount added in v1.5.0 

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

func (*WriteRowsCtx) SetSeriesRowCountFunc added in v1.5.0 

func (ctx *WriteRowsCtx) SetSeriesRowCountFunc(fn SeriesRowCountFunc)

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.