e2ethanos

Documentation

Index

• func CleanScenario(t *testing.T, s *e2e.Scenario) func()
• func DefaultAlertmanagerImage() string
• func DefaultImage() string
• func DefaultPrometheusImage() string
• func NewAlertmanager(sharedDir string, name string) (*e2e.HTTPService, error)
• func NewCompactor(sharedDir string, name string, bucketConfig client.BucketConfig, ...) (*e2e.HTTPService, error)
• func NewMemcached(name string) *e2e.ConcreteService
• func NewPrometheus(sharedDir string, name string, config, promImage string) (*e2e.HTTPService, string, error)
• func NewQueryFrontend(name string, downstreamURL string, ...) (*e2e.HTTPService, error)
• func NewSingleHostReverseProxy(target *url.URL, externalPrefix string) *httputil.ReverseProxy
• func RemoteWriteEndpoint(addr string) string
• type Service
  • func NewPrometheusWithSidecar(sharedDir string, netName string, name string, config, promImage string) (*e2e.HTTPService, *Service, error)
  • func NewQuerier(sharedDir, name string, ...) (*Service, error)
  • func NewReceiver(sharedDir string, networkName string, name string, replicationFactor int, ...) (*Service, error)
  • func NewRuler(sharedDir string, name string, ruleSubDir string, ...) (*Service, error)
  • func NewService(name string, image string, command *e2e.Command, ...) *Service
  • func NewStoreGW(sharedDir string, name string, bucketConfig client.BucketConfig, ...) (*Service, error)
  • func (s *Service) GRPCEndpoint() string
  • func (s *Service) GRPCNetworkEndpoint() string
  • func (s *Service) GRPCNetworkEndpointFor(networkName string) string

Functions

func CleanScenario

func CleanScenario(t *testing.T, s *e2e.Scenario) func()

func DefaultAlertmanagerImage

func DefaultAlertmanagerImage() string

func DefaultImage

func DefaultImage() string

DefaultImage returns the local docker image to use to run Thanos.

func DefaultPrometheusImage

func DefaultPrometheusImage() string

TODO(bwplotka): Run against multiple?

func NewAlertmanager

func NewAlertmanager(sharedDir string, name string) (*e2e.HTTPService, error)

func NewCompactor

func NewCompactor(sharedDir string, name string, bucketConfig client.BucketConfig, relabelConfig []relabel.Config, extArgs ...string) (*e2e.HTTPService, error)

func NewMemcached

func NewMemcached(name string) *e2e.ConcreteService

func NewPrometheus

func NewPrometheus(sharedDir string, name string, config, promImage string) (*e2e.HTTPService, string, error)

func NewQueryFrontend

func NewQueryFrontend(name string, downstreamURL string, cacheConfig queryfrontend.CacheProviderConfig) (*e2e.HTTPService, error)

func NewSingleHostReverseProxy

func NewSingleHostReverseProxy(target *url.URL, externalPrefix string) *httputil.ReverseProxy

NewSingleHostReverseProxy is almost same as httputil.NewSingleHostReverseProxy but it performs a url path rewrite.

func RemoteWriteEndpoint

func RemoteWriteEndpoint(addr string) string

Types

type Service

type Service struct {
	*e2e.HTTPService
	// contains filtered or unexported fields
}

func NewPrometheusWithSidecar

func NewPrometheusWithSidecar(sharedDir string, netName string, name string, config, promImage string) (*e2e.HTTPService, *Service, error)

func NewQuerier

func NewQuerier(sharedDir, name string, storeAddresses, fileSDStoreAddresses, ruleAddresses []string, routePrefix, externalPrefix string) (*Service, error)

func NewReceiver

func NewReceiver(sharedDir string, networkName string, name string, replicationFactor int, hashring ...receive.HashringConfig) (*Service, error)

func NewRuler

func NewRuler(sharedDir string, name string, ruleSubDir string, amCfg []alert.AlertmanagerConfig, queryCfg []query.Config) (*Service, error)

func NewService

func NewService(
	name string,
	image string,
	command *e2e.Command,
	readiness *e2e.HTTPReadinessProbe,
	http, grpc int,
	otherPorts ...int,
) *Service

func NewStoreGW

func NewStoreGW(sharedDir string, name string, bucketConfig client.BucketConfig, relabelConfig ...relabel.Config) (*Service, error)

func (*Service) GRPCEndpoint

func (s *Service) GRPCEndpoint() string

func (*Service) GRPCNetworkEndpoint

func (s *Service) GRPCNetworkEndpoint() string

func (*Service) GRPCNetworkEndpointFor

func (s *Service) GRPCNetworkEndpointFor(networkName string) string