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 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 ¶
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.