omloader

type GoogleStorage interface {
	Storage
	RegisterFinalizeNotification(bucketName, projectID, topicID string) error
}

type GoogleWatcherConfig struct {
	ProjectID      string
	TopicID        string
	BucketName     string
	BucketPath     string
	SubscriptionID string
}

type HttpSenderConfig struct {
	URL string
}

type LabelMutatorFn func(labels []prompb.Label) []prompb.Label

type Processor interface {
	Process(reader io.Reader) error
	AddMutator(mutator LabelMutatorFn)
}

type Reader interface {
	Read() error
}

type Sender interface {
	Send(timeSeriesSlice []prompb.TimeSeries) error
}

type Storage interface {
	Read(path string) (io.ReadCloser, error)
	Move(src, dst string) error
	Delete(path string) error
	io.Closer
}