Documentation
¶
Index ¶
- Constants
- func AlertmanagerBinary() string
- func Copy(t testing.TB, src, dst string)
- func CreateBlock(ctx context.Context, dir string, series []labels.Labels, numSamples int, ...) (id ulid.ULID, err error)
- func CreateBlockWithBlockDelay(ctx context.Context, dir string, series []labels.Labels, numSamples int, ...) (ulid.ULID, error)
- func CreateBlockWithTombstone(ctx context.Context, dir string, series []labels.Labels, numSamples int, ...) (id ulid.ULID, err error)
- func CreateEmptyBlock(dir string, mint, maxt int64, extLset labels.Labels, resolution int64) (ulid.ULID, error)
- func ForeachPrometheus(t *testing.T, testFn func(t testing.TB, p *Prometheus))
- func FreePort() (int, error)
- func MinioBinary() string
- func NewTSDB() (*tsdb.DB, error)
- func PrometheusBinary() string
- func SysProcAttr() *syscall.SysProcAttr
- type Prometheus
- func (p *Prometheus) Addr() string
- func (p *Prometheus) Appender() storage.Appender
- func (p *Prometheus) Dir() string
- func (p *Prometheus) DisableCompaction()
- func (p *Prometheus) Restart() error
- func (p *Prometheus) SetConfig(s string)
- func (p *Prometheus) Start() error
- func (p *Prometheus) Stop() error
- func (p *Prometheus) WaitPrometheusUp(ctx context.Context, logger log.Logger) error
Constants ¶
const (
// A placeholder for actual Prometheus instance address in the scrape config.
PromAddrPlaceHolder = "PROMETHEUS_ADDRESS"
)
Variables ¶
This section is empty.
Functions ¶
func AlertmanagerBinary ¶
func AlertmanagerBinary() string
func CreateBlock ¶
func CreateBlock( ctx context.Context, dir string, series []labels.Labels, numSamples int, mint, maxt int64, extLset labels.Labels, resolution int64, hashFunc metadata.HashFunc, ) (id ulid.ULID, err error)
CreateBlock writes a block with the given series and numSamples samples each. Samples will be in the time range [mint, maxt).
func CreateBlockWithBlockDelay ¶
func CreateBlockWithBlockDelay( ctx context.Context, dir string, series []labels.Labels, numSamples int, mint, maxt int64, blockDelay time.Duration, extLset labels.Labels, resolution int64, hashFunc metadata.HashFunc, ) (ulid.ULID, error)
CreateBlockWithBlockDelay writes a block with the given series and numSamples samples each. Samples will be in the time range [mint, maxt) Block ID will be created with a delay of time duration blockDelay.
func CreateBlockWithTombstone ¶
func CreateBlockWithTombstone( ctx context.Context, dir string, series []labels.Labels, numSamples int, mint, maxt int64, extLset labels.Labels, resolution int64, hashFunc metadata.HashFunc, ) (id ulid.ULID, err error)
CreateBlockWithTombstone is same as CreateBlock but leaves tombstones which mimics the Prometheus local block.
func CreateEmptyBlock ¶
func CreateEmptyBlock(dir string, mint, maxt int64, extLset labels.Labels, resolution int64) (ulid.ULID, error)
CreateEmptyBlock produces empty block like it was the case before fix: https://github.com/prometheus/tsdb/pull/374. (Prometheus pre v2.7.0).
func ForeachPrometheus ¶
func ForeachPrometheus(t *testing.T, testFn func(t testing.TB, p *Prometheus))
func MinioBinary ¶
func MinioBinary() string
func PrometheusBinary ¶
func PrometheusBinary() string
func SysProcAttr ¶
func SysProcAttr() *syscall.SysProcAttr
Types ¶
type Prometheus ¶
type Prometheus struct {
// contains filtered or unexported fields
}
Prometheus represents a test instance for integration testing. It can be populated with data before being started.
func NewPrometheus ¶
func NewPrometheus() (*Prometheus, error)
NewPrometheus creates a new test Prometheus instance that will listen on local address. Use ForeachPrometheus if you want to test against set of Prometheus versions. TODO(bwplotka): Improve it with https://github.com/thanos-io/thanos/issues/758.
func NewPrometheusOnPath ¶
func NewPrometheusOnPath(prefix string) (*Prometheus, error)
NewPrometheusOnPath creates a new test Prometheus instance that will listen on local address and given prefix path.
func (*Prometheus) Addr ¶
func (p *Prometheus) Addr() string
Addr returns correct address after Start method.
func (*Prometheus) Appender ¶
func (p *Prometheus) Appender() storage.Appender
Appender returns a new appender to populate the Prometheus instance with data. All appenders must be closed before Start is called and no new ones must be opened afterwards.
func (*Prometheus) DisableCompaction ¶
func (p *Prometheus) DisableCompaction()
func (*Prometheus) Restart ¶
func (p *Prometheus) Restart() error
func (*Prometheus) SetConfig ¶
func (p *Prometheus) SetConfig(s string)
SetConfig updates the contents of the config.
func (*Prometheus) Start ¶
func (p *Prometheus) Start() error
Start running the Prometheus instance and return.
func (*Prometheus) Stop ¶
func (p *Prometheus) Stop() error
Stop terminates Prometheus and clean up its data directory.
Source Files