series

Documentation

Index

• type Desc
• type Instance
• type Labels
• type Series
• type Service
  • func NewSeriesService(pmseriesAPI pmseries.API, cacheSize int) (*Service, error)
  • func (s *Service) GetSeries(sids []string) (map[string]*Series, error)
  • func (s *Service) RefreshInstances(series *Series) error

Types

type Desc

type Desc = pmseries.DescsResponseItem

Desc describes a metric

type Instance

type Instance struct {
	Instance string
	Name     string
	Labels   Labels
}

Instance holds information about a PCP instance

type Labels

type Labels map[string]interface{}

Labels structure for storing labels

type Series

type Series struct {
	MetricName string
	Desc       Desc
	Labels     Labels
	Instances  map[string]Instance
}

Series is a single time series with descriptor, labels and instances, but without values

type Service

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

Service retrieves and caches series

func NewSeriesService

func NewSeriesService(pmseriesAPI pmseries.API, cacheSize int) (*Service, error)

NewSeriesService creates a new resource service

func (*Service) GetSeries

func (s *Service) GetSeries(sids []string) (map[string]*Series, error)

GetSeries retrieves multiple series and caches them this will be called from different goroutines (each QueryData call runs in a new goroutine) let's keep it simple and stupid for now with a lock if this isn't sufficient anymore, a solution like https://notes.shichao.io/gopl/ch9/#example-concurrent-non-blocking-cache will be required - a concurrent non-blocking memoizing cache, where the memoize function processes multiple keys

func (*Service) RefreshInstances

func (s *Service) RefreshInstances(series *Series) error

RefreshInstances refreshes instances of a series