Documentation ¶
Index ¶
- type PrometheusJob
- type QueryExecutor
- type QueryWorker
- type SendWorker
- type Sender
- func (s *Sender) BroadcastMessage(message config.Message)
- func (s *Sender) ProcessNextMessage(ctx context.Context, client *http.Client, index int, target config.Target)
- func (s *Sender) Run(ctx context.Context)
- func (s *Sender) SendHTTPRequest(log *zap.SugaredLogger, client *http.Client, target config.Target, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PrometheusJob ¶
type PrometheusJob struct {
// contains filtered or unexported fields
}
func NewPrometheusJob ¶
func NewPrometheusJob(ctx context.Context, genConfig *config.GeneralConfig, jobConfig config.QueryJob) *PrometheusJob
type QueryExecutor ¶
type QueryExecutor struct {
// contains filtered or unexported fields
}
func NewQueryExecutor ¶
func NewQueryExecutor(queue chan config.Message, jobName string, queryConfig *config.QueryConfig, generalConfig *config.GeneralConfig, metricName string, log *zap.SugaredLogger) *QueryExecutor
func (*QueryExecutor) Run ¶
func (qe *QueryExecutor) Run(ctx context.Context)
type QueryWorker ¶
type SendWorker ¶
type Sender ¶
type Sender struct {
// contains filtered or unexported fields
}
func NewSender ¶
func NewSender(queue chan config.Message, sendConfig *config.SendConfig, generalConfig *config.GeneralConfig, log *zap.SugaredLogger) *Sender
func (*Sender) BroadcastMessage ¶
func (*Sender) ProcessNextMessage ¶
Click to show internal directories.
Click to hide internal directories.