system

Documentation

Index

• Variables
• type Stats
  • func Read(ctx context.Context) (o Stats)
  • func (s *Stats) Read(ts time.Time)

Variables

var (
	SaveDuration = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "events_save_duration_seconds",
			Help:      "Time taken to persist events to the storage.",
			Buckets:   buckets,
		},
	)
	QueryDuration = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "events_query_duration_seconds",
			Help:      "Time taken to query.",
			Buckets:   buckets,
		},
	)
	DropSiteDuration = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "site_drop_duration_seconds",
			Help:      "Time taken to permanently delete a site.",
			Buckets:   buckets,
		},
	)
	SiteCacheDuration = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "site_cache_duration_seconds",
			Help:      "Time taken to load sites to cache.",
			Buckets:   buckets,
		},
	)
	CalendarReadDuration = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "calendar_read_duration_seconds",
			Help:      "Time taken to read a calendar from storage.",
			Buckets:   buckets,
		},
	)

	KeysPerBufferSave = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "ts_key_per_buffer_save",
			Help:      "Time number of keys created on a single timeseries buffer saving.",
			Buckets:   []float64{50, 100, 150, 200, 500},
		},
	)
	EntriesPerBufferSave = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "vince",
			Name:      "ts_entries_per_buffer_save",
			Help:      "Time number of entries buffered on a single buffer saving.",
			Buckets:   []float64{10, 20, 50, 100},
		},
	)
)

histograms

var (
	DataPointReceived = prometheus.NewCounter(prometheus.CounterOpts{
		Namespace: "vince",
		Name:      "data_point_received",
	})
	DataPointRejected = prometheus.NewCounter(prometheus.CounterOpts{
		Namespace: "vince",
		Name:      "data_point_rejected",
	})
	DataPointDropped = prometheus.NewCounter(prometheus.CounterOpts{
		Namespace: "vince",
		Name:      "data_point_dropped",
	})
	DataPointAccepted = prometheus.NewCounter(prometheus.CounterOpts{
		Namespace: "vince",
		Name:      "data_point_accepted",
	})
)

var (
	SitesInCache = prometheus.NewGauge(prometheus.GaugeOpts{
		Namespace: "vince",
		Name:      "sites_in_cache",
		Help:      "Active sites in memory cache.",
	})
)

gauges

Types

type Stats

type Stats struct {
	Timestamp         time.Time `parquet:"timestamp,timestamp"`
	SitesInCache      uint64    `parquet:"sites_in_cache"`
	DataPointReceived uint64    `parquet:"data_point_received,zstd"`
	DataPointRejected uint64    `parquet:"data_point_rejected,zstd"`
	DataPointDropped  uint64    `parquet:"data_point_dropped,zstd"`
	DataPointAccepted uint64    `parquet:"data_point_accepted,zstd"`
	TotalAllocation   uint64    `parquet:"total_allocation,zstd"`
}

func Read

func Read(ctx context.Context) (o Stats)

func (*Stats) Read

func (s *Stats) Read(ts time.Time)