appendable

Documentation

Index

• type FlowAppendable
  • func NewFlowAppendable(receivers ...*metrics.Receiver) *FlowAppendable
  • func (app *FlowAppendable) Appender(_ context.Context) storage.Appender
  • func (app *FlowAppendable) ListReceivers() []*metrics.Receiver
  • func (app *FlowAppendable) SetReceivers(receivers []*metrics.Receiver)
• type FlowMetric

Types

type FlowAppendable

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

FlowAppendable is a flow-specific implementation of an Appender.

func NewFlowAppendable

func NewFlowAppendable(receivers ...*metrics.Receiver) *FlowAppendable

NewFlowAppendable initializes the appendable.

func (*FlowAppendable) Appender

func (app *FlowAppendable) Appender(_ context.Context) storage.Appender

Appender implements the Prometheus Appendable interface.

func (*FlowAppendable) ListReceivers

func (app *FlowAppendable) ListReceivers() []*metrics.Receiver

ListReceivers is a test method for exposing the Appender's receivers.

func (*FlowAppendable) SetReceivers

func (app *FlowAppendable) SetReceivers(receivers []*metrics.Receiver)

SetReceivers defines the list of receivers for this appendable.

type FlowMetric

type FlowMetric struct {
	Labels labels.Labels
	Value  float64
}

FlowMetric is a wrapper around a single sample without the timestamp.