prometheus

Documentation

Index

• type PrometheusJob
  • func NewPrometheusJob(ctx context.Context, genConfig *config.GeneralConfig, ...) *PrometheusJob
  • func (pj *PrometheusJob) Run(ctx context.Context) error
• type QueryExecutor
  • func NewQueryExecutor(queue chan config.Message, jobName string, queryConfig *config.QueryConfig, ...) *QueryExecutor
  • func (qe *QueryExecutor) Run(ctx context.Context)
• type QueryWorker
• type SendWorker
• type Sender
  • func NewSender(queue chan config.Message, sendConfig *config.SendConfig, ...) *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

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

func (*PrometheusJob) Run

func (pj *PrometheusJob) Run(ctx context.Context) error

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 QueryWorker interface {
	Run(ctx context.Context, queue chan string)
}

type SendWorker

type SendWorker interface {
	Run(ctx context.Context, queue chan string)
}

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 (s *Sender) BroadcastMessage(message config.Message)

func (*Sender) ProcessNextMessage

func (s *Sender) ProcessNextMessage(ctx context.Context, client *http.Client, index int, target config.Target)

func (*Sender) Run

func (s *Sender) Run(ctx context.Context)

func (*Sender) SendHTTPRequest

func (s *Sender) SendHTTPRequest(log *zap.SugaredLogger, client *http.Client, target config.Target, message config.Message) error

TODO: Implement sending HTTP request