Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGoogleWatcher ¶
func NewGoogleWatcher(logger *zap.Logger, processor Processor, config GoogleWatcherConfig) (*googleWatcher, error)
Types ¶
type GoogleStorage ¶
type GoogleStorage interface { Storage RegisterFinalizeNotification(bucketName, projectID, topicID string) error }
func NewGoogleStorage ¶
func NewGoogleStorage() (GoogleStorage, error)
type GoogleWatcherConfig ¶
type HttpSenderConfig ¶
type HttpSenderConfig struct {
URL string
}
type Processor ¶
type Processor interface { Process(reader io.Reader) error AddMutator(mutator LabelMutatorFn) }
type Reader ¶
type Reader interface {
Read() error
}
func NewOpenMetricsReader ¶
func NewOpenMetricsReader(reader io.Reader, output chan<- *prompb.TimeSeries) Reader
type Sender ¶
type Sender interface {
Send(timeSeriesSlice []prompb.TimeSeries) error
}
func NewHttpSender ¶
func NewHttpSender(config HttpSenderConfig) Sender
Click to show internal directories.
Click to hide internal directories.