push

Documentation

Index

• type Handler
  • func NewHandler(cortexAddress string, lokiAddress string) (*Handler, error)
  • func (h *Handler) Follow(name string, follower *stream.Follower)
  • func (h *Handler) Handle(frame can.Frame)
  • func (h *Handler) RegisterRunListener(rl model.RunListener)
  • func (h *Handler) SendLog(labels labels.Labels, timestamp time.Time, entry string)
  • func (h *Handler) SendMetric(metricName string, additionalLabels labels.Labels, timestamp time.Time, ...)
  • func (h *Handler) Unfollow(name string, follower *stream.Follower)
• type Packet
• type TimeSeries

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
}