explorer

package
v0.0.0-...-250ed9d Latest Latest
Warning

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

Go to latest
Published: May 28, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FORMAT = "2006-01-02T15:04:05.000Z"
)

Variables

This section is empty.

Functions

func ConvertToUnixTime

func ConvertToUnixTime(input interface{}) (time.Time, error)

Types

type Edge

type Edge struct {
	Source  uint64
	Target  uint64
	Pearson float32
}

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 (m *Metric) ComputePrometheusGraphURL(prometheusBaseURL string, timeRange string, endTime string)

func (*Metric) ComputePrometheusQuery

func (m *Metric) ComputePrometheusQuery() string

func (*Metric) MetricString

func (m *Metric) MetricString() string

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

Jump to

Keyboard shortcuts

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