memory

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 30, 2020

Changes in this version

type PartitionedMemoryIdx

+ func (p *PartitionedMemoryIdx) FindTerms(orgID uint32, tags []string, query tagquery.Query) (uint32, map[string]map[string]uint32)

type TagQueryContext

+ func (q *TagQueryContext) Run(index TagIndex, byId map[schema.MKey]*idx.Archive, mti *metaTagHierarchy, ...)

type UnpartitionedMemoryIdx

+ func (m *UnpartitionedMemoryIdx) FindTerms(orgID uint32, tags []string, query tagquery.Query) (uint32, map[string]map[string]uint32)

v0

v0.13.1

Nov 28, 2019

Changes in this version

+ var MetaTagSupport = false

v0.13.0

Sep 17, 2019

Changes in this version

+ func CloneArchive(a *idx.Archive) idx.Archive

type MemoryIndex

+ UpdateArchiveLastSave func(schema.MKey, int32, uint32)

type PartitionedMemoryIdx

+ func (p *PartitionedMemoryIdx) FindTagValuesWithQuery(orgId uint32, tag, prefix string, query tagquery.Query, limit uint) []string

+ func (p *PartitionedMemoryIdx) FindTagsWithQuery(orgId uint32, prefix string, query tagquery.Query, limit uint) []string

+ func (p *PartitionedMemoryIdx) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) (uint32, uint32, error)

+ func (p *PartitionedMemoryIdx) UpdateArchiveLastSave(id schema.MKey, partition int32, lastSave uint32)

+ type TagQueryContext struct

+ func NewTagQueryContext(query tagquery.Query) TagQueryContext

+ func (q *TagQueryContext) RunBlocking(index TagIndex, byId map[schema.MKey]*idx.Archive, mti metaTagIndex, ...)

+ func (q *TagQueryContext) RunGetTags(index TagIndex, byId map[schema.MKey]*idx.Archive, mti metaTagIndex, ...) map[string]struct{}

+ func (q *TagQueryContext) RunNonBlocking(index TagIndex, byId map[schema.MKey]*idx.Archive, mti metaTagIndex, ...)

+ type TagValues map[string]IdSet

type UnpartitionedMemoryIdx

+ func (m *UnpartitionedMemoryIdx) FindTagValuesWithQuery(orgId uint32, tag, prefix string, query tagquery.Query, limit uint) []string

+ func (m *UnpartitionedMemoryIdx) FindTagsWithQuery(orgId uint32, prefix string, query tagquery.Query, limit uint) []string

+ func (m *UnpartitionedMemoryIdx) MetaTagRecordSwap(orgId uint32, records []tagquery.MetaTagRecord) (uint32, uint32, error)

+ func (m *UnpartitionedMemoryIdx) UpdateArchiveLastSave(id schema.MKey, partition int32, lastSave uint32)

+ type WriteQueue struct

+ func NewWriteQueue(index *UnpartitionedMemoryIdx, maxDelay time.Duration, maxBuffered int) *WriteQueue

+ func (wq *WriteQueue) Get(id schema.MKey) (*idx.Archive, bool)

+ func (wq *WriteQueue) Queue(archive *idx.Archive)

+ func (wq *WriteQueue) Stop()

v0.12.0

May 14, 2019

Changes in this version

+ var Partitioned bool

+ type FindCache struct

+ func NewFindCache(size, invalidateQueueSize, invalidateMaxSize int, ...) *FindCache

+ func (c *FindCache) Add(orgId uint32, pattern string, nodes []*Node)

+ func (c *FindCache) Get(orgId uint32, pattern string) ([]*Node, bool)

+ func (c *FindCache) InvalidateFor(orgId uint32, path string)

+ func (c *FindCache) Purge(orgId uint32)

+ func (c *FindCache) PurgeAll()

+ func (c *FindCache) Shutdown()

+ type MemoryIndex interface

+ ForceInvalidationFindCache func()

+ LoadPartition func(int32, []schema.MetricDefinition) int

+ PurgeFindCache func()

+ UpdateArchive func(idx.Archive)

+ type PartitionedMemoryIdx struct

+ Partition map[int32]*UnpartitionedMemoryIdx

+ func NewPartitionedMemoryIdx() *PartitionedMemoryIdx

+ func (p *PartitionedMemoryIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)

+ func (p *PartitionedMemoryIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, error)

+ func (p *PartitionedMemoryIdx) DeleteTagged(orgId uint32, paths []string) ([]idx.Archive, error)

+ func (p *PartitionedMemoryIdx) Find(orgId uint32, pattern string, from int64) ([]idx.Node, error)

+ func (p *PartitionedMemoryIdx) FindByTag(orgId uint32, expressions []string, from int64) ([]idx.Node, error)

+ func (p *PartitionedMemoryIdx) FindTagValues(orgId uint32, tag string, prefix string, expressions []string, from int64, ...) ([]string, error)

+ func (p *PartitionedMemoryIdx) FindTags(orgId uint32, prefix string, expressions []string, from int64, limit uint) ([]string, error)

+ func (p *PartitionedMemoryIdx) ForceInvalidationFindCache()

+ func (p *PartitionedMemoryIdx) Get(key schema.MKey) (idx.Archive, bool)

+ func (p *PartitionedMemoryIdx) GetPath(orgId uint32, path string) []idx.Archive

+ func (p *PartitionedMemoryIdx) Init() error

+ func (p *PartitionedMemoryIdx) List(orgId uint32) []idx.Archive

+ func (p *PartitionedMemoryIdx) LoadPartition(partition int32, defs []schema.MetricDefinition) int

+ func (p *PartitionedMemoryIdx) MetaTagRecordList(orgId uint32) []idx.MetaTagRecord

+ func (p *PartitionedMemoryIdx) MetaTagRecordUpsert(orgId uint32, rawRecord idx.MetaTagRecord) (idx.MetaTagRecord, bool, error)

+ func (p *PartitionedMemoryIdx) Prune(oldest time.Time) ([]idx.Archive, error)

+ func (p *PartitionedMemoryIdx) PurgeFindCache()

+ func (p *PartitionedMemoryIdx) Stop()

+ func (p *PartitionedMemoryIdx) TagDetails(orgId uint32, key string, filter string, from int64) (map[string]uint64, error)

+ func (p *PartitionedMemoryIdx) Tags(orgId uint32, filter string, from int64) ([]string, error)

+ func (p *PartitionedMemoryIdx) Update(point schema.MetricPoint, partition int32) (idx.Archive, int32, bool)

+ func (p *PartitionedMemoryIdx) UpdateArchive(archive idx.Archive)

+ type UnpartitionedMemoryIdx struct

+ func NewUnpartitionedMemoryIdx() *UnpartitionedMemoryIdx

+ func (m *UnpartitionedMemoryIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)

+ func (m *UnpartitionedMemoryIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, error)

+ func (m *UnpartitionedMemoryIdx) DeleteTagged(orgId uint32, paths []string) ([]idx.Archive, error)

+ func (m *UnpartitionedMemoryIdx) Find(orgId uint32, pattern string, from int64) ([]idx.Node, error)

+ func (m *UnpartitionedMemoryIdx) FindByTag(orgId uint32, expressions []string, from int64) ([]idx.Node, error)

+ func (m *UnpartitionedMemoryIdx) FindTagValues(orgId uint32, tag, prefix string, expressions []string, from int64, limit uint) ([]string, error)

+ func (m *UnpartitionedMemoryIdx) FindTags(orgId uint32, prefix string, expressions []string, from int64, limit uint) ([]string, error)

+ func (m *UnpartitionedMemoryIdx) ForceInvalidationFindCache()

+ func (m *UnpartitionedMemoryIdx) Get(id schema.MKey) (idx.Archive, bool)

+ func (m *UnpartitionedMemoryIdx) GetPath(orgId uint32, path string) []idx.Archive

+ func (m *UnpartitionedMemoryIdx) Init() error

+ func (m *UnpartitionedMemoryIdx) List(orgId uint32) []idx.Archive

+ func (m *UnpartitionedMemoryIdx) Load(defs []schema.MetricDefinition) int

+ func (m *UnpartitionedMemoryIdx) LoadPartition(partition int32, defs []schema.MetricDefinition) int

+ func (m *UnpartitionedMemoryIdx) MetaTagRecordList(orgId uint32) []idx.MetaTagRecord

+ func (m *UnpartitionedMemoryIdx) MetaTagRecordUpsert(orgId uint32, rawRecord idx.MetaTagRecord) (idx.MetaTagRecord, bool, error)

+ func (m *UnpartitionedMemoryIdx) Prune(now time.Time) ([]idx.Archive, error)

+ func (m *UnpartitionedMemoryIdx) PurgeFindCache()

+ func (m *UnpartitionedMemoryIdx) Stop()

+ func (m *UnpartitionedMemoryIdx) TagDetails(orgId uint32, key, filter string, from int64) (map[string]uint64, error)

+ func (m *UnpartitionedMemoryIdx) Tags(orgId uint32, filter string, from int64) ([]string, error)

+ func (m *UnpartitionedMemoryIdx) Update(point schema.MetricPoint, partition int32) (idx.Archive, int32, bool)

+ func (m *UnpartitionedMemoryIdx) UpdateArchive(archive idx.Archive)

v0.11.0

Dec 19, 2018

Changes in this version

+ const EQUAL

+ const MATCH

+ const MATCH_TAG

+ const NOT_EQUAL

+ const NOT_MATCH

+ const PREFIX

+ const PREFIX_TAG

+ var Enabled bool

+ var IndexRules conf.IndexRules

+ var TagQueryWorkers int

+ var TagSupport bool

+ func ConfigProcess()

+ func ConfigSetup()

+ type IdSet map[schema.MKey]struct

+ func (ids IdSet) String() string

+ type KvByCost []kv

+ func (a KvByCost) Len() int

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

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

+ type KvReByCost []kvRe

+ func (a KvReByCost) Len() int

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

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

+ type MemoryIdx struct

+ func New() *MemoryIdx

+ func (m *MemoryIdx) AddOrUpdate(mkey schema.MKey, data *schema.MetricData, partition int32) (idx.Archive, int32, bool)

+ func (m *MemoryIdx) Delete(orgId uint32, pattern string) ([]idx.Archive, error)

+ func (m *MemoryIdx) DeleteTagged(orgId uint32, paths []string) ([]idx.Archive, error)

+ func (m *MemoryIdx) Find(orgId uint32, pattern string, from int64) ([]idx.Node, error)

+ func (m *MemoryIdx) FindByTag(orgId uint32, expressions []string, from int64) ([]idx.Node, error)

+ func (m *MemoryIdx) FindTagValues(orgId uint32, tag, prefix string, expressions []string, from int64, limit uint) ([]string, error)

+ func (m *MemoryIdx) FindTags(orgId uint32, prefix string, expressions []string, from int64, limit uint) ([]string, error)

+ func (m *MemoryIdx) Get(id schema.MKey) (idx.Archive, bool)

+ func (m *MemoryIdx) GetPath(orgId uint32, path string) []idx.Archive

+ func (m *MemoryIdx) Init() error

+ func (m *MemoryIdx) List(orgId uint32) []idx.Archive

+ func (m *MemoryIdx) Load(defs []schema.MetricDefinition) int

+ func (m *MemoryIdx) Prune(now time.Time) ([]idx.Archive, error)

+ func (m *MemoryIdx) Stop()

+ func (m *MemoryIdx) TagDetails(orgId uint32, key, filter string, from int64) (map[string]uint64, error)

+ func (m *MemoryIdx) Tags(orgId uint32, filter string, from int64) ([]string, error)

+ func (m *MemoryIdx) Update(point schema.MetricPoint, partition int32) (idx.Archive, int32, bool)

+ func (m *MemoryIdx) UpdateArchive(archive idx.Archive)

+ type Node struct

+ Children []string

+ Defs []schema.MKey

+ Path string

+ func (n *Node) HasChildren() bool

+ func (n *Node) Leaf() bool

+ func (n *Node) String() string

+ type TagIndex map[string]TagValue

+ type TagQuery struct

+ func NewTagQuery(expressions []string, from int64) (TagQuery, error)

+ func (q *TagQuery) Run(index TagIndex, byId map[schema.MKey]*idx.Archive) IdSet

+ func (q *TagQuery) RunGetTags(index TagIndex, byId map[schema.MKey]*idx.Archive) map[string]struct{}

+ type TagValue map[string]IdSet

+ type TimeLimiter struct

+ func NewTimeLimiter(window, limit time.Duration, now time.Time) *TimeLimiter

+ func (l *TimeLimiter) Add(d time.Duration)

+ func (l *TimeLimiter) Wait()

+ type Tree struct

+ Items map[string]*Node

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