Documentation
¶
Index ¶
- func GetDefaultImage() string
- type Client
- 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 NewSingleBinary(name string, flags map[string]string, image string, httpPort, grpcPort int, ...) *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, orgID string) (*Client, error)
NewClient makes a new Cortex client
func (*Client) GetAlertmanagerConfig ¶
GetAlertmanagerConfig gets the status of an alertmanager instance
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 NewSingleBinary ¶
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
Click to show internal directories.
Click to hide internal directories.