constructor

Documentation

Index

• Variables
• type Cache
• type CardinalityStats
• type Constructor
  • func New(db DB, project *db.Project, cacheClients map[db.ProjectId]Cache, ...) *Constructor
  • func (c *Constructor) LoadWorld(ctx context.Context, from, to timeseries.Time, step timeseries.Duration, ...) (*model.World, error)
  • func (c *Constructor) QueryCache(ctx context.Context, cache Cache, project *db.Project, ...) (map[string][]*model.MetricValues, error)
• type DB
• type DestinationStats
  • func NewDestinationStats() *DestinationStats
• type Option
• type Profile
• type Query
  • func Q(name, query string, labels ...string) Query
• type QueryStats

Variables

var QUERIES = []Query{}/* 238 elements not displayed */

var RecordingRules = map[string]func(db *db.DB, p *db.Project, w *model.World) []*model.MetricValues{
	// contains filtered or unexported fields
}

Types

type Cache

type Cache interface {
	QueryRange(ctx context.Context, query string, from, to timeseries.Time, step timeseries.Duration, fillFunc timeseries.FillFunc) ([]*model.MetricValues, error)
	GetStep(from, to timeseries.Time) (timeseries.Duration, error)
}

type CardinalityStats

type CardinalityStats struct {
	ContainerId       int               `json:"container_id"`
	Destination       *DestinationStats `json:"destination,omitempty"`
	ActualDestination *DestinationStats `json:"actual_destination,omitempty"`
}

type Constructor

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

func New

func New(db DB, project *db.Project, cacheClients map[db.ProjectId]Cache, pricing *pricing.Manager, options ...Option) *Constructor

func (*Constructor) LoadWorld

func (c *Constructor) LoadWorld(ctx context.Context, from, to timeseries.Time, step timeseries.Duration, prof *Profile) (*model.World, error)

func (*Constructor) QueryCache

func (c *Constructor) QueryCache(ctx context.Context, cache Cache, project *db.Project, from, to timeseries.Time, step timeseries.Duration) (map[string][]*model.MetricValues, error)

type DB

type DB interface {
	GetCheckConfigs(projectId db.ProjectId) (model.CheckConfigs, error)
	GetApplicationDeployments(projectId db.ProjectId) (map[model.ApplicationId][]*model.ApplicationDeployment, error)
	GetApplicationIncidents(projectId db.ProjectId, from, to timeseries.Time) (map[model.ApplicationId][]*model.ApplicationIncident, error)
	GetApplicationSettingsByProject(projectId db.ProjectId) (map[model.ApplicationId]*model.ApplicationSettings, error)
	GetProjects() (map[string]*db.Project, error)
}

type DestinationStats

type DestinationStats struct {
	Unique         int `json:"unique"`
	ExternalTotal  int `json:"external_total"`
	ExternalUnique int `json:"external_unique"`
	PrivateTotal   int `json:"private_total"`
	PrivateUnique  int `json:"private_unique"`
	FqdnTotal      int `json:"fqdn_total"`
	FqdnUnique     int `json:"fqdn_unique"`
	LoopbackTotal  int `json:"loopback_total"`
	// contains filtered or unexported fields
}

func NewDestinationStats

func NewDestinationStats() *DestinationStats

type Option

type Option int

const (
	OptionLoadInstanceToInstanceConnections Option = iota
	OptionDoNotLoadRawSLIs
	OptionLoadContainerLogs
)

type Profile

type Profile struct {
	Stages  map[string]float32    `json:"stages"`
	Queries map[string]QueryStats `json:"queries"`
}

type Query

type Query struct {
	Name   string
	Query  string
	Labels *utils.StringSet

	InstanceToInstance bool
}

func Q

func Q(name, query string, labels ...string) Query

type QueryStats

type QueryStats struct {
	MetricsCount int               `json:"metrics_count"`
	QueryTime    float32           `json:"query_time"`
	Failed       bool              `json:"failed"`
	Cardinality  *CardinalityStats `json:"cardinality,omitempty"`
}