json

package

v0.20.0 Latest Latest Go to latest Published: Mar 22, 2018 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(fs afero.Fs, fname string) (*Collector, error)

func (c *Collector) Collect(samples []stats.Sample)

func (c *Collector) GetRequiredSystemTags() lib.TagSet

GetRequiredSystemTags returns which sample tags are needed by this collector

func (c *Collector) HandleMetric(m *stats.Metric)

func (c *Collector) HasSeenMetric(str string) bool

func (c *Collector) Init() error

func (c *Collector) Link() string

func (c *Collector) Run(ctx context.Context)

type Envelope struct {
	Type   string      `json:"type"`
	Data   interface{} `json:"data"`
	Metric string      `json:"metric,omitempty"`
}

func WrapMetric(metric *stats.Metric) *Envelope

func WrapSample(sample *stats.Sample) *Envelope

type JSONSample struct {
	Time  time.Time         `json:"time"`
	Value float64           `json:"value"`
	Tags  map[string]string `json:"tags"`
}

func NewJSONSample(sample *stats.Sample) *JSONSample