m3db

Documentation

Index

• type ConsolidatedNSBlock
• type ConsolidatedSeriesBlock
• type ConsolidatedSeriesBlocks
• type ConsolidationFunc
• type MultiNamespaceSeries
  • func (n MultiNamespaceSeries) ID() ident.ID
• type MultiSeriesBlock
• type MultiSeriesBlocks
  • func SeriesBlockToMultiSeriesBlocks(multiNamespaceSeriesList []MultiNamespaceSeries, ...) (MultiSeriesBlocks, error)
• type NamespaceSeriesList
• type SeriesBlock
  • func (s SeriesBlock) Close()
• type SeriesBlocks
  • func ConvertM3DBSeriesIterators(iterators encoding.SeriesIterators, iterAlloc encoding.ReaderIteratorAllocate) ([]SeriesBlocks, error)
  • func (s SeriesBlocks) Close()

Types

type ConsolidatedNSBlock

type ConsolidatedNSBlock struct {
	ID              ident.ID
	Namespace       ident.ID
	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 NamespaceSeriesList

type NamespaceSeriesList struct {
	Namespace  string
	SeriesList []SeriesBlocks
}

NamespaceSeriesList represents a single namespace with multiple series

type SeriesBlock

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

SeriesBlock contains the individual series iterators

func (SeriesBlock) Close

func (s SeriesBlock) Close()

Close closes the series iterator in a SeriesBlock

type SeriesBlocks

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

SeriesBlocks contain information about the timeseries that gets returned from m3db. This includes meta data such as the ID, namespace and tags as well as the actual series iterators that contain the datapoints.

func ConvertM3DBSeriesIterators

func ConvertM3DBSeriesIterators(iterators encoding.SeriesIterators, iterAlloc encoding.ReaderIteratorAllocate) ([]SeriesBlocks, error)

ConvertM3DBSeriesIterators converts m3db SeriesIterators to SeriesBlocks which are used to construct Blocks for query processing.

func (SeriesBlocks) Close

func (s SeriesBlocks) Close()

Close closes the underlaying series iterator within each SeriesBlock as well as the ID, Namespace, and Tags.