e2ethanos

Documentation

Index

• 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 NewPrometheus(sharedDir string, name string, config, promImage string) (*e2e.HTTPService, string, error)
• 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 string, name string, storeAddresses []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, readiness *e2e.ReadinessProbe, ...) *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 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 NewPrometheus

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

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 string, name string, storeAddresses []string, fileSDStoreAddresses []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.ReadinessProbe,
	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