tsdb

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 17, 2023

Changes in this version

type Buffer

+ func NewBufferWithWal(log *logger.Logger, position common.Position, ...) (*Buffer, error)

+ func (b *Buffer) Register(id string, onFlushFn onFlush)

+ func (b *Buffer) Unregister(id string)

+ type BufferSupplier struct

+ func NewBufferSupplier(l *logger.Logger, p common.Position, writeConcurrency, numShards int, ...) *BufferSupplier

+ func (b *BufferSupplier) Borrow(bufferName, name string, bufferSize int, onFlushFn onFlush) (buffer *Buffer, err error)

+ func (b *BufferSupplier) Close() error

+ func (b *BufferSupplier) Return(bufferName, name string)

+ func (b *BufferSupplier) Volume() int

type DatabaseOpts

+ EnableWAL bool

v0.4.0

Jun 28, 2023

Changes in this version

+ var ErrUnknownShard = errors.New("unknown shard")

+ var OptionsKey = contextOptionsKey

+ type BlockExpiryTracker struct

+ func (bl *BlockExpiryTracker) BlockExpiryDuration() time.Duration

+ func (bl *BlockExpiryTracker) EndTime() time.Time

+ func (bl *BlockExpiryTracker) IsActive() bool

+ type Buffer struct

+ func NewBuffer(log *logger.Logger, position common.Position, ...) (*Buffer, error)

+ func (b *Buffer) Close() error

+ func (b *Buffer) Read(key []byte, ts time.Time) ([]byte, bool)

+ func (b *Buffer) Write(key, value []byte, timestamp time.Time)

type Database

+ CreateShardsAndGetByID func(id common.ShardID) (Shard, error)

type DatabaseOpts

+ IndexGranularity IndexGranularity

+ TSTableFactory TSTableFactory

+ type IndexGranularity int

+ const IndexGranularityBlock

+ const IndexGranularitySeries

type IndexWriter

+ func NewSeriesIndexWriter(seriesID common.SeriesID, seriesDB SeriesDatabase) IndexWriter

+ type OrderBy struct

+ Index *databasev1.IndexRule

+ Sort modelv1.Sort

type SeriesDatabase

+ Search func(ctx context.Context, path Path, filter index.Filter, order *OrderBy) (SeriesList, error)

+ SizeOnDisk func() int64

+ type TSTable interface

+ CollectStats func() *badger.Statistics

+ Get func(key []byte, ts time.Time) ([]byte, error)

+ Put func(key, val []byte, ts time.Time) error

+ SizeOnDisk func() int64

+ type TSTableFactory interface

+ NewTSTable func(bufferLifecycle BlockExpiryTracker, root string, position common.Position, ...) (TSTable, error)

v0.3.1

Feb 21, 2023

v0.3.0

Feb 6, 2023

Changes in this version

+ func MarshalEntityValues(evs EntityValues) ([]byte, error)

+ type CompressionMethod struct

+ ChunkSizeInBytes int

+ Type CompressionType

+ type CompressionType int

+ const CompressionTypeNone

+ const CompressionTypeZSTD

type DatabaseOpts

+ BlockInvertedIndex InvertedIndexOpts

+ CompressionMethod CompressionMethod

type EncodingMethod

+ ChunkSizeInBytes int

+ type EntityValue *modelv1.TagValue

+ func Int64Value(v int64) EntityValue

+ func StrValue(v string) EntityValue

+ type EntityValues []EntityValue

+ func DecodeEntityValues(tvv []*modelv1.TagValue) (result EntityValues)

+ func UnmarshalEntityValues(evs []byte) (result EntityValues, err error)

+ func (evs EntityValues) Encode() (result []*modelv1.TagValue)

+ func (evs EntityValues) Prepend(scope EntityValue) EntityValues

+ func (evs EntityValues) String() string

+ func (evs EntityValues) ToEntity() (result Entity, err error)

type Entry

+ func EntityValueToEntry(ev EntityValue) (Entry, error)

+ type InvertedIndexOpts struct

+ BatchWaitSec int64

+ type SectionID uint32

type Series

+ String func() string

type Shard

+ TriggerSchedule func(task string) bool

v0.2.0

Nov 5, 2022

Changes in this version

+ var ErrBlockClosingInterrupted = errors.New("interrupt to close the block")

+ type BlockDelegate interface

+ String func() string

type BlockID

+ func (b BlockID) String() string

type DatabaseOpts

+ BlockInterval IntervalRule

+ BlockMemSize int64

+ EnableGlobalIndex bool

+ GlobalIndexMemSize int64

+ SegmentInterval IntervalRule

+ SeriesMemSize int64

+ TTL IntervalRule

type Entity

+ func NewEntity(len int) Entity

+ func (e Entity) Copy() Entity

type IntervalRule

+ func (ir IntervalRule) PreviousTime(current time.Time) time.Time

type Path

+ func (p Path) Prepend(entry Entry) Path

type Series

+ Create func(ctx context.Context, t time.Time) (SeriesSpan, error)

type SeriesList

+ func (a SeriesList) Merge(other SeriesList) SeriesList

type ShardState

+ StrategyManagers []string

v0.1.0

Jun 2, 2022

Changes in this version

+ var AnyEntry = Entry(nil)

+ var ErrBlockAbsent = errors.New("block is absent")

+ var ErrDuplicatedFamily = errors.New("duplicated family")

+ var ErrEmptySeriesSpan = errors.New("there is no data in such time range")

+ var ErrEndOfSegment = errors.New("reached the end of the segment")

+ var ErrInvalidShardID = errors.New("invalid shard id")

+ var ErrItemIDMalformed = errors.New("serialized item id is malformed")

+ var ErrNoTime = errors.New("no time specified")

+ var ErrNoVal = errors.New("no value specified")

+ var ErrOpenDatabase = errors.New("fails to open the database")

+ var ErrUnsupportedIndexRule = errors.New("the index rule is not supported")

+ func GenerateInternalID(unit IntervalUnit, suffix int) uint16

+ func GlobalSeriesID(scope Entry) common.SeriesID

+ func Hash(entry []byte) []byte

+ func HashEntity(entity Entity) []byte

+ func SeriesID(entity Entity) common.SeriesID

+ func WalkDir(root, prefix string, walkFn WalkFn) error

+ type BlockID struct

+ BlockID uint16

+ SegID uint16

+ type BlockState struct

+ Closed bool

+ ID BlockID

+ TimeRange timestamp.TimeRange

+ type Condition map[string][]index.ConditionValue

+ type Database interface

+ Shard func(id common.ShardID) (Shard, error)

+ Shards func() []Shard

+ func OpenDatabase(ctx context.Context, opts DatabaseOpts) (Database, error)

+ type DatabaseOpts struct

+ BlockSize IntervalRule

+ EncodingMethod EncodingMethod

+ Location string

+ SegmentSize IntervalRule

+ ShardNum uint32

+ type EncodingMethod struct

+ DecoderPool encoding.SeriesDecoderPool

+ EncoderPool encoding.SeriesEncoderPool

+ type Entity []Entry

+ func (e Entity) Marshal() []byte

+ func (e Entity) Prepend(entry Entry) Entity

+ type Entry []byte

+ type GlobalItemID struct

+ ID common.ItemID

+ SeriesID common.SeriesID

+ ShardID common.ShardID

+ func (i *GlobalItemID) Marshal() []byte

+ func (i *GlobalItemID) UnMarshal(data []byte) error

+ type IndexDatabase interface

+ Seek func(field index.Field) ([]GlobalItemID, error)

+ WriterBuilder func() IndexWriterBuilder

+ type IndexSeekBuilder interface

+ type IndexWriter interface

+ WriteInvertedIndex func(field index.Field) error

+ WriteLSMIndex func(field index.Field) error

+ type IndexWriterBuilder interface

+ Build func() (IndexWriter, error)

+ GlobalItemID func(itemID GlobalItemID) IndexWriterBuilder

+ Scope func(scope Entry) IndexWriterBuilder

+ Time func(ts time.Time) IndexWriterBuilder

+ type IntervalRule struct

+ Num int

+ Unit IntervalUnit

+ func (ir IntervalRule) EstimatedDuration() time.Duration

+ func (ir IntervalRule) NextTime(current time.Time) time.Time

+ type IntervalUnit int

+ const DAY

+ const HOUR

+ func (iu IntervalUnit) String() string

+ type Item interface

+ Family func(family []byte) ([]byte, error)

+ ID func() common.ItemID

+ SortedField func() []byte

+ Time func() uint64

+ Val func() ([]byte, error)

+ type Iterator interface

+ Close func() error

+ Next func() bool

+ Val func() Item

+ type Path struct

+ func NewPath(entries []Entry) Path

+ func (p Path) Prepand(entry Entry) Path

+ type ScopedShard struct

+ func (sd *ScopedShard) Close() error

+ func (sd *ScopedShard) ID() common.ShardID

+ func (sd *ScopedShard) Index() IndexDatabase

+ func (sd *ScopedShard) Series() SeriesDatabase

+ func (sd *ScopedShard) State() ShardState

+ type Seeker interface

+ Seek func() ([]Iterator, error)

+ type SeekerBuilder interface

+ Build func() (Seeker, error)

+ Filter func(indexRule *databasev1.IndexRule, condition Condition) SeekerBuilder

+ OrderByIndex func(indexRule *databasev1.IndexRule, order modelv1.Sort) SeekerBuilder

+ OrderByTime func(order modelv1.Sort) SeekerBuilder

+ type Series interface

+ Get func(id GlobalItemID) (Item, io.Closer, error)

+ ID func() common.SeriesID

+ Span func(timeRange timestamp.TimeRange) (SeriesSpan, error)

+ type SeriesDatabase interface

+ Get func(entity Entity) (Series, error)

+ GetByHashKey func(key []byte) (Series, error)

+ GetByID func(id common.SeriesID) (Series, error)

+ List func(path Path) (SeriesList, error)

+ type SeriesList []Series

+ func (a SeriesList) Len() int

+ func (a SeriesList) Less(i, j int) bool

+ func (a SeriesList) Swap(i, j int)

+ type SeriesSpan interface

+ SeekerBuilder func() SeekerBuilder

+ WriterBuilder func() WriterBuilder

+ type Shard interface

+ ID func() common.ShardID

+ Index func() IndexDatabase

+ Series func() SeriesDatabase

+ State func() ShardState

+ func NewScopedShard(scope Entry, delegated Shard) Shard

+ func OpenShard(ctx context.Context, id common.ShardID, root string, ...) (Shard, error)

+ type ShardState struct

+ Blocks []BlockState

+ OpenBlocks []BlockID

+ type Supplier interface

+ SupplyTSDB func() Database

+ type WalkFn func(suffix, absolutePath string) error

+ type Writer interface

+ ItemID func() GlobalItemID

+ String func() string

+ Write func() (GlobalItemID, error)

+ type WriterBuilder interface

+ Build func() (Writer, error)

+ Family func(name []byte, val []byte) WriterBuilder

+ Time func(ts time.Time) WriterBuilder

+ Val func(val []byte) WriterBuilder

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