Documentation
¶
Index ¶
- Constants
- func ConvertToUnixTime(input interface{}) (time.Time, error)
- type Edge
- type Metric
- type ParquetExplorer
- func (p *ParquetExplorer) Delete() error
- func (p *ParquetExplorer) GetEdges(edgeChan chan<- []*Edge) error
- func (p *ParquetExplorer) GetMetrics(cache *map[uint64]*Metric) error
- func (p *ParquetExplorer) GetSubgraphs() (*SubgraphMemberships, error)
- func (p *ParquetExplorer) Initialize(filename string) error
- func (p *ParquetExplorer) LookupMetric(timeSeriesId uint64) (map[string]string, error)
- type SubgraphMemberships
Constants ¶
View Source
const (
FORMAT = "2006-01-02T15:04:05.000Z"
)
Variables ¶
This section is empty.
Functions ¶
func ConvertToUnixTime ¶
Types ¶
type Metric ¶
type Metric struct {
Fingerprint uint64 // this is a stable id for the metric.
RowId int // not needed, use the Fingerprint
LabelSet model.LabelSet
PrometheusGraphURL string // computed on demand
Constant bool
}
func (*Metric) ComputePrometheusGraphURL ¶
func (*Metric) ComputePrometheusQuery ¶
func (*Metric) MetricString ¶
type ParquetExplorer ¶
type ParquetExplorer struct {
// contains filtered or unexported fields
}
func NewParquetExplorer ¶
func NewParquetExplorer(filenameBase string) *ParquetExplorer
func (*ParquetExplorer) Delete ¶
func (p *ParquetExplorer) Delete() error
func (*ParquetExplorer) GetEdges ¶
func (p *ParquetExplorer) GetEdges(edgeChan chan<- []*Edge) error
func (*ParquetExplorer) GetMetrics ¶
func (p *ParquetExplorer) GetMetrics(cache *map[uint64]*Metric) error
func (*ParquetExplorer) GetSubgraphs ¶
func (p *ParquetExplorer) GetSubgraphs() (*SubgraphMemberships, error)
Read subgraph information from a parquet file.
func (*ParquetExplorer) Initialize ¶
func (p *ParquetExplorer) Initialize(filename string) error
func (*ParquetExplorer) LookupMetric ¶
func (p *ParquetExplorer) LookupMetric(timeSeriesId uint64) (map[string]string, error)
type SubgraphMemberships ¶
type SubgraphMemberships struct {
// Rows maps timeseries ids to subgraph ids
Rows map[uint64]int
// Sizes holds the size of each subgraph
Sizes map[int]int
// contains filtered or unexported fields
}
func (*SubgraphMemberships) GetGraphId ¶
func (s *SubgraphMemberships) GetGraphId(rowId uint64) int
Click to show internal directories.
Click to hide internal directories.