Documentation ¶
Index ¶
- Constants
- func LabelsFromTaggedName(name string, tags []string, builder *labels.Builder) (labels.Labels, error)
- func LabelsFromUntaggedName(name string, builder *labels.Builder) labels.Labels
- type Config
- type MetricDataPayload
- func (m MetricDataPayload) GeneratePreallocTimeseries(ctx context.Context) ([]mimirpb.PreallocTimeseries, error)
- func (m MetricDataPayload) GeneratePromMetrics() ([]labels.Labels, []mimirpb.Sample, error)
- func (m MetricDataPayload) GeneratePromTimeSeries(ctx context.Context) ([]prompb.TimeSeries, error)
- type Recorder
- type RemoteWriteProxy
Constants ¶
View Source
const ( TaggedMetricName = "graphite_tagged" UntaggedMetricName = "graphite_untagged" )
Variables ¶
This section is empty.
Functions ¶
func LabelsFromTaggedName ¶
Types ¶
type Config ¶
type Config struct {
RemoteWriteConfig remotewrite.Config `yaml:"remote_write"`
}
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to config this to the given FlagSet
type MetricDataPayload ¶
type MetricDataPayload []*schema.MetricData
func (MetricDataPayload) GeneratePreallocTimeseries ¶
func (m MetricDataPayload) GeneratePreallocTimeseries(ctx context.Context) ([]mimirpb.PreallocTimeseries, error)
func (MetricDataPayload) GeneratePromMetrics ¶
func (MetricDataPayload) GeneratePromTimeSeries ¶
func (m MetricDataPayload) GeneratePromTimeSeries(ctx context.Context) ([]prompb.TimeSeries, error)
type Recorder ¶
type Recorder interface {
// contains filtered or unexported methods
}
func NewRecorder ¶
func NewRecorder(reg prometheus.Registerer) Recorder
NewRecorder returns a new Prometheus metrics Recorder. It ensures that the graphite ingester metrics are properly registered.
type RemoteWriteProxy ¶
type RemoteWriteProxy struct {
// contains filtered or unexported fields
}
func NewRemoteWriteProxy ¶
func NewRemoteWriteProxy(client remotewrite.Client, recorder Recorder) *RemoteWriteProxy
func (*RemoteWriteProxy) ServeHTTP ¶
func (wp *RemoteWriteProxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
Click to show internal directories.
Click to hide internal directories.