stsmetrics

package
v0.0.0-...-0172641 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2020 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Cron

func Cron(natsEndpoint string, cronExpr string)

Cron triggers the job command every cron iteration

func JobRequest

func JobRequest(natsEndpoint string, stream int32)

JobRequest takes in a stream (or all) and sends a request to process timeseries info

func StartWatch

func StartWatch(natsEndpoint string)

StartWatch monitors timeseries requests

Types

type MetricTimeSeries

type MetricTimeSeries struct {
	Stream int32     `json:"stream"`
	Count  int       `json:"count"`
	Time   time.Time `json:"time"`
}

MetricTimeSeries the data structure

type STSRequest

type STSRequest struct {
	Stream int32 `json:"stream"`
}

STSRequest requests generation of timeseries data for a particular stream

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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