e2ethanos

func CleanScenario ¶

func CleanScenario(t testing.TB, e *e2e.DockerEnvironment) func()

func DefaultAlertmanagerImage ¶

func DefaultAlertmanagerImage() string

DefaultAlertmanagerImage sets default Alertmanager image used in e2e service.

func DefaultImage ¶

func DefaultImage() string

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

func DefaultPromConfig ¶

func DefaultPromConfig(name string, replica int, remoteWriteEndpoint, ruleFile string, scrapeTargets ...string) string

DefaultPromConfig returns Prometheus config that sets Prometheus to: * expose 2 external labels, source and replica. * optionallly scrape self. This will produce up == 0 metric which we can assert on. * optionally remote write endpoint to write into.

func DefaultPrometheusImage ¶

func DefaultPrometheusImage() string

DefaultPrometheusImage sets default Prometheus image used in e2e service.

func NewMemcached ¶

func NewMemcached(e e2e.Environment, name string) *e2emon.InstrumentedRunnable

func NewMinio ¶

func NewMinio(e e2e.Environment, name, bktName string) *e2emon.InstrumentedRunnable

NewMinio returns minio server, used as a local replacement for S3. TODO(@matej-g): This is a temporary workaround for https://github.com/efficientgo/e2e/issues/11; after this is addresses fixed all calls should be replaced with e2edb.NewMinio.

func NewPrometheus ¶

func NewPrometheus(e e2e.Environment, name, promConfig, webConfig, promImage string, enableFeatures ...string) *e2emon.InstrumentedRunnable

func NewPrometheusWithSidecar ¶

func NewPrometheusWithSidecar(e e2e.Environment, name, promConfig, webConfig, promImage, minTime string, enableFeatures ...string) (*e2emon.InstrumentedRunnable, *e2emon.InstrumentedRunnable)

func NewPrometheusWithSidecarCustomImage ¶

func NewPrometheusWithSidecarCustomImage(e e2e.Environment, name, promConfig, webConfig, promImage, minTime string, sidecarImage string, enableFeatures ...string) (*e2emon.InstrumentedRunnable, *e2emon.InstrumentedRunnable)

func NewReverseProxy ¶

func NewReverseProxy(e e2e.Environment, name, tenantID, target string) *e2emon.InstrumentedRunnable

func NewS3Config ¶

func NewS3Config(bucket, endpoint, basePath string) s3.Config

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 NewToolsBucketWeb ¶

func NewToolsBucketWeb(
	e e2e.Environment,
	name string,
	bucketConfig client.BucketConfig,
	routePrefix,
	externalPrefix string,
	minTime string,
	maxTime string,
	relabelConfig string,
) *e2emon.InstrumentedRunnable