Affected by 
Documentation
¶
Index ¶
- func GetDefaultImage() string
- type Client
- func (c *Client) DeleteRuleGroup(namespace string, groupName string) error
- func (c *Client) GetAlertmanagerConfig(ctx context.Context) (*alertConfig.Config, error)
- func (c *Client) GetRuleGroups() (map[string][]rulefmt.RuleGroup, error)
- func (c *Client) LabelNames() ([]string, error)
- func (c *Client) LabelValues(label string) (model.LabelValues, error)
- func (c *Client) Push(timeseries []prompb.TimeSeries) (*http.Response, error)
- func (c *Client) Query(query string, ts time.Time) (model.Value, error)
- func (c *Client) QueryRaw(query string) (*http.Response, []byte, error)
- func (c *Client) SetRuleGroup(rulegroup rulefmt.RuleGroup, namespace string) error
- type CompositeCortexService
- type CortexService
- func NewAlertmanager(name string, flags map[string]string, image string) *CortexService
- func NewCortexService(name string, image string, command *e2e.Command, readiness e2e.ReadinessProbe, ...) *CortexService
- func NewDistributor(name string, consulAddress string, flags map[string]string, image string) *CortexService
- func NewDistributorWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
- func NewIngester(name string, consulAddress string, flags map[string]string, image string) *CortexService
- func NewIngesterWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
- func NewQuerier(name string, consulAddress string, flags map[string]string, image string) *CortexService
- func NewQuerierWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
- func NewQueryFrontend(name string, flags map[string]string, image string) *CortexService
- func NewQueryFrontendWithConfigFile(name, configFile string, flags map[string]string, image string) *CortexService
- func NewRuler(name string, flags map[string]string, image string) *CortexService
- func NewSingleBinary(name string, flags map[string]string, image string, otherPorts ...int) *CortexService
- func NewSingleBinaryWithConfigFile(name string, configFile string, flags map[string]string, image string, ...) *CortexService
- func NewStoreGateway(name string, consulAddress string, flags map[string]string, image string) *CortexService
- func NewStoreGatewayWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
- func NewTableManager(name string, flags map[string]string, image string) *CortexService
- func NewTableManagerWithConfigFile(name, configFile string, flags map[string]string, image string) *CortexService
- type S3Client
- type ServerStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDefaultImage ¶
func GetDefaultImage() string
GetDefaultImage returns the Docker image to use to run Cortex.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a client used to interact with Cortex in integration tests
func NewClient ¶
func NewClient( distributorAddress string, querierAddress string, alertmanagerAddress string, rulerAddress string, orgID string, ) (*Client, error)
NewClient makes a new Cortex client
func (*Client) DeleteRuleGroup ¶ added in v1.0.0
DeleteRuleGroup gets the status of an alertmanager instance
func (*Client) GetAlertmanagerConfig ¶
GetAlertmanagerConfig gets the status of an alertmanager instance
func (*Client) GetRuleGroups ¶ added in v1.0.0
GetRuleGroups gets the status of an alertmanager instance
func (*Client) LabelNames ¶ added in v1.1.0
LabelNames gets label names
func (*Client) LabelValues ¶ added in v1.1.0
func (c *Client) LabelValues(label string) (model.LabelValues, error)
LabelValues gets label values
type CompositeCortexService ¶ added in v1.1.0
type CompositeCortexService struct {
*e2e.CompositeHTTPService
}
CompositeCortexService abstract an higher-level service composed, under the hood, by 2+ CortexService.
func NewCompositeCortexService ¶ added in v1.1.0
func NewCompositeCortexService(services ...*CortexService) *CompositeCortexService
type CortexService ¶
type CortexService struct {
*e2e.HTTPService
// contains filtered or unexported fields
}
CortexService represents a Cortex service with at least an HTTP and GRPC port exposed.
func NewAlertmanager ¶
func NewAlertmanager(name string, flags map[string]string, image string) *CortexService
func NewCortexService ¶
func NewCortexService( name string, image string, command *e2e.Command, readiness e2e.ReadinessProbe, httpPort int, grpcPort int, otherPorts ...int, ) *CortexService
func NewDistributor ¶
func NewDistributorWithConfigFile ¶
func NewDistributorWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
func NewIngester ¶
func NewIngesterWithConfigFile ¶
func NewIngesterWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
func NewQuerier ¶
func NewQuerierWithConfigFile ¶
func NewQuerierWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
func NewQueryFrontend ¶
func NewQueryFrontend(name string, flags map[string]string, image string) *CortexService
func NewQueryFrontendWithConfigFile ¶
func NewQueryFrontendWithConfigFile(name, configFile string, flags map[string]string, image string) *CortexService
func NewRuler ¶ added in v1.0.0
func NewRuler(name string, flags map[string]string, image string) *CortexService
func NewSingleBinary ¶
func NewSingleBinaryWithConfigFile ¶ added in v1.1.0
func NewStoreGateway ¶ added in v1.1.0
func NewStoreGatewayWithConfigFile ¶ added in v1.1.0
func NewStoreGatewayWithConfigFile(name, consulAddress, configFile string, flags map[string]string, image string) *CortexService
func NewTableManager ¶
func NewTableManager(name string, flags map[string]string, image string) *CortexService
func NewTableManagerWithConfigFile ¶
func NewTableManagerWithConfigFile(name, configFile string, flags map[string]string, image string) *CortexService
func (*CortexService) GRPCEndpoint ¶
func (s *CortexService) GRPCEndpoint() string
func (*CortexService) NetworkGRPCEndpoint ¶
func (s *CortexService) NetworkGRPCEndpoint() string
type S3Client ¶
type S3Client struct {
// contains filtered or unexported fields
}
func NewS3ClientForMinio ¶
func NewS3ClientForMinio(minio *e2e.HTTPService, bucketName string) (*S3Client, error)
func (*S3Client) DeleteBlock ¶
DeleteBlock deletes a single block.
func (*S3Client) DeleteBlocks ¶
DeleteBlocks deletes all blocks for a tenant.
type ServerStatus ¶
type ServerStatus struct {
Data struct {
ConfigYaml string `json:"configYAML"`
} `json:"data"`
}
ServerStatus represents a Alertmanager status response TODO: Upgrade to Alertmanager v0.20.0+ and utilize vendored structs
Source Files
Click to show internal directories.
Click to hide internal directories.