client

Documentation

Index

• type QueryClient
  • func NewQueryClient(cfg QueryClientConfig, logger log.Logger, reg prometheus.Registerer) *QueryClient
  • func (c *QueryClient) Start()
• type QueryClientConfig
• type WriteClient
  • func NewWriteClient(cfg WriteClientConfig, logger log.Logger) *WriteClient
  • func (c *WriteClient) Start()
• type WriteClientConfig

Types

type QueryClient

type QueryClient struct {
	// contains filtered or unexported fields
}

func NewQueryClient

func NewQueryClient(cfg QueryClientConfig, logger log.Logger, reg prometheus.Registerer) *QueryClient

func (*QueryClient) Start

func (c *QueryClient) Start()

type QueryClientConfig

type QueryClientConfig struct {
	URL string

	// The tenant ID to use to push metrics to Cortex.
	UserID string

	QueryInterval time.Duration
	QueryTimeout  time.Duration
	QueryMaxAge   time.Duration

	ExpectedSeries        int
	ExpectedWriteInterval time.Duration

	AdditionalQueries []string
}

type WriteClient

type WriteClient struct {
	// contains filtered or unexported fields
}

func NewWriteClient

func NewWriteClient(cfg WriteClientConfig, logger log.Logger) *WriteClient

func (*WriteClient) Start

func (c *WriteClient) Start()

type WriteClientConfig

type WriteClientConfig struct {
	// Cortex URL.
	URL url.URL

	// The tenant ID to use to push metrics to Cortex.
	UserID string

	// Number of series to generate per write request.
	SeriesCount int

	// SeriesChurnPeriod is the time period during which all series gradually churn.
	// 0 to disable churning.
	SeriesChurnPeriod time.Duration

	// Number of extra labels to generate per write request.
	ExtraLabels int

	WriteInterval    time.Duration
	WriteTimeout     time.Duration
	WriteConcurrency int
	WriteBatchSize   int
}