push

package
v0.0.0-...-3936e01 Latest Latest
Warning

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

Go to latest
Published: May 18, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

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

func NewHandler

func NewHandler(cortexAddress string, lokiAddress string) (*Handler, error)

func (*Handler) Follow

func (h *Handler) Follow(name string, follower *stream.Follower)

func (*Handler) Handle

func (h *Handler) Handle(frame can.Frame)

func (*Handler) RegisterRunListener

func (h *Handler) RegisterRunListener(rl model.RunListener)

TODO this is not thread safe

func (*Handler) SendLog

func (h *Handler) SendLog(labels labels.Labels, timestamp time.Time, entry string)

func (*Handler) SendMetric

func (h *Handler) SendMetric(metricName string, additionalLabels labels.Labels, timestamp time.Time, val float64)

func (*Handler) Unfollow

func (h *Handler) Unfollow(name string, follower *stream.Follower)

type Packet

type Packet struct {
	Labels labels.Labels
	Sample client.Sample
}

type TimeSeries

type TimeSeries struct {
	Labels  []labels.Labels
	Samples []client.Sample
}

Jump to

Keyboard shortcuts

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