m3db

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: May 26, 2018 License: Apache-2.0, MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConsolidatedNSBlock

type ConsolidatedNSBlock struct {
	ID              ident.ID
	Namespace       string
	Start           time.Time
	End             time.Time
	SeriesIterators encoding.SeriesIterators
}

ConsolidatedNSBlock is a single block for a given timeseries and namespace which contains all of the necessary SeriesIterators so that consolidation can happen across namespaces

type ConsolidatedSeriesBlock

type ConsolidatedSeriesBlock struct {
	Start                time.Time
	End                  time.Time
	ConsolidatedNSBlocks []ConsolidatedNSBlock
	// contains filtered or unexported fields
}

ConsolidatedSeriesBlock is a single series consolidated across different namespaces for a single block

type ConsolidatedSeriesBlocks

type ConsolidatedSeriesBlocks []ConsolidatedSeriesBlock

ConsolidatedSeriesBlocks contain all of the consolidated blocks for a single timeseries across namespaces. Each ConsolidatedBlockIterator will have the same size

type ConsolidationFunc

type ConsolidationFunc func(existing, toAdd float64, count int) float64

ConsolidationFunc determines how to consolidate across namespaces

type MultiNamespaceSeries

type MultiNamespaceSeries []SeriesBlocks

MultiNamespaceSeries is a single timeseries for multiple namespaces

func (MultiNamespaceSeries) ID

func (n MultiNamespaceSeries) ID() ident.ID

ID enforces the same ID across namespaces

type MultiSeriesBlock

type MultiSeriesBlock struct {
	Start  time.Time
	End    time.Time
	Blocks ConsolidatedSeriesBlocks
}

MultiSeriesBlock represents a vertically oriented block

type MultiSeriesBlocks

type MultiSeriesBlocks []MultiSeriesBlock

MultiSeriesBlocks is a slice of MultiSeriesBlock todo(braskin): add close method on this to close each SeriesIterator

func SeriesBlockToMultiSeriesBlocks

func SeriesBlockToMultiSeriesBlocks(multiNamespaceSeriesList []MultiNamespaceSeries, seriesIteratorsPool encoding.MutableSeriesIteratorsPool) (MultiSeriesBlocks, error)

SeriesBlockToMultiSeriesBlocks converts M3DB blocks to multi series blocks

type SeriesBlock

type SeriesBlock struct {
	Start          time.Time
	End            time.Time
	SeriesIterator encoding.SeriesIterator
}

SeriesBlock is a placeholder until it is added to M3DB

type SeriesBlocks

type SeriesBlocks struct {
	ID        ident.ID
	Namespace string
	Blocks    []SeriesBlock
}

SeriesBlocks is a placeholder until it is added to M3DB

Jump to

Keyboard shortcuts

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