testing

package

Go to main page

Versions in this module

v1

v1.2.2

Nov 19, 2019

Changes in this version

type SpyMetricRegistrar

+ func (r *SpyMetricRegistrar) FetchOption(name string) func() *float64

v1.2.1

Nov 8, 2019

Changes in this version

+ type SpyAdapter struct

+ CommittedPoints []*rpc.Point

+ func NewSpyAdapter() *SpyAdapter

+ func (s *SpyAdapter) WritePoints(points []*rpc.Point) error

+ type SpyMetricRegistrar struct

+ func NewSpyMetricRegistrar() *SpyMetricRegistrar

+ func (r *SpyMetricRegistrar) Add(name string, delta float64, labels ...string)

+ func (r *SpyMetricRegistrar) Fetch(name string) func() float64

+ func (r *SpyMetricRegistrar) Gatherer() prometheus.Gatherer

+ func (r *SpyMetricRegistrar) Inc(name string, labels ...string)

+ func (r *SpyMetricRegistrar) Registerer() prometheus.Registerer

+ func (r *SpyMetricRegistrar) Set(name string, value float64, labels ...string)

type SpyMetricStore

+ func (s *SpyMetricStore) Stop()

+ type SpyMetricStoreAddrs struct

+ EgressAddr string

+ IngressAddr string

+ type SpyStorage struct

+ func NewSpyStorage(querier storage.Querier) *SpyStorage

+ func (s *SpyStorage) Appender() (storage.Appender, error)

+ func (s *SpyStorage) Close() error

+ func (s *SpyStorage) Querier(ctx context.Context, mint int64, maxt int64) (storage.Querier, error)

+ func (s *SpyStorage) StartTime() (int64, error)

+ type SpyUAA struct

+ func NewSpyUAA(tlsConfig *tls.Config) *SpyUAA

+ func (s *SpyUAA) Start() error

+ func (s *SpyUAA) Url() string

v1.1.2

Apr 22, 2019

Changes in this version

+ const UNDEFINED_METRIC

+ func Asset(name string) ([]byte, error)

+ func AssetDir(name string) ([]string, error)

+ func AssetInfo(name string) (os.FileInfo, error)

+ func AssetNames() []string

+ func BuildExpectedLog(timestamp time.Time, ...) string

+ func BuildRequest(method, url, remoteAddr, requestId, forwardedFor string) *http.Request

+ func Cert(filename string) string

+ func FormatTimeWithDecimalMillis(t time.Time) string

+ func GetFreePort() int

+ func GrpcTLSCredentials() credentials.TransportCredentials

+ func MakeTLSReq(addr, path string) (*http.Response, error)

+ func MustAsset(name string) []byte

+ func NewIngressClient(addr string) (client rpc.IngressClient, cleanup func())

+ func NewMutualTLSConfig(caPath, certPath, keyPath, cn string) (*tls.Config, error)

+ func NewServerRequest(method, uri string, body io.Reader) (*http.Request, error)

+ func RestoreAsset(dir, name string) error

+ func RestoreAssets(dir, name string) error

+ func StartGoProcess(importPath string, env []string, args ...string) *gexec.Session

+ func WaitForHealthCheck(healthAddr string)

+ func WaitForServer(addr string)

+ type Point struct

+ Time int64

+ Value float64

+ type Series struct

+ Labels map[string]string

+ Points []Point

+ func ExplodeSeriesSet(seriesSet storage.SeriesSet) []Series

+ type SpyDataReader struct

+ LabelValuesError error

+ LabelValuesResponse *rpc.PromQL_LabelValuesQueryResult

+ LabelsError error

+ LabelsResponse *rpc.PromQL_LabelsQueryResult

+ ReadEnds []int64

+ ReadErrs []error

+ ReadResults []*rpc.PromQL_Matrix

+ ReadStarts []int64

+ func NewSpyDataReader() *SpyDataReader

+ func (s *SpyDataReader) LabelValues(ctx context.Context, in *rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)

+ func (s *SpyDataReader) Labels(ctx context.Context, in *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)

+ func (s *SpyDataReader) Read(ctx context.Context, params *storage.SelectParams, ...) (storage.SeriesSet, error)

+ type SpyMetricStore struct

+ QueryError error

+ func NewSpyMetricStore(tlsConfig *tls.Config) *SpyMetricStore

+ func (s *SpyMetricStore) GetLabelsQueryRequests() []*rpc.PromQL_LabelsQueryRequest

+ func (s *SpyMetricStore) GetPoints() []*rpc.Point

+ func (s *SpyMetricStore) GetQueryRequests() []*rpc.PromQL_InstantQueryRequest

+ func (s *SpyMetricStore) GetRangeQueryRequests() []*rpc.PromQL_RangeQueryRequest

+ func (s *SpyMetricStore) GetSeriesQueryRequests() []*rpc.PromQL_SeriesQueryRequest

+ func (s *SpyMetricStore) InstantQuery(ctx context.Context, r *rpc.PromQL_InstantQueryRequest) (*rpc.PromQL_InstantQueryResult, error)

+ func (s *SpyMetricStore) LabelValuesQuery(ctx context.Context, req *rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)

+ func (s *SpyMetricStore) LabelsQuery(ctx context.Context, req *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)

+ func (s *SpyMetricStore) RangeQuery(ctx context.Context, r *rpc.PromQL_RangeQueryRequest) (*rpc.PromQL_RangeQueryResult, error)

+ func (s *SpyMetricStore) Send(ctx context.Context, r *rpc.SendRequest) (*rpc.SendResponse, error)

+ func (s *SpyMetricStore) SeriesQuery(ctx context.Context, req *rpc.PromQL_SeriesQueryRequest) (*rpc.PromQL_SeriesQueryResult, error)

+ func (s *SpyMetricStore) SetValue(value float64)

+ func (s *SpyMetricStore) Start() string

+ type SpyMetrics struct

+ func NewSpyMetrics() *SpyMetrics

+ func (s *SpyMetrics) Get(name string) float64

+ func (s *SpyMetrics) GetUnit(name string) string

+ func (s *SpyMetrics) Getter(name string) func() float64

+ func (s *SpyMetrics) NewCounter(name string) func(uint64)

+ func (s *SpyMetrics) NewGauge(name, unit string) func(float64)

+ func (s *SpyMetrics) NewSummary(name, unit string) func(float64)

+ func (s *SpyMetrics) SummaryObservationsGetter(name string) func() []float64

+ type SpyQueryEngine struct

+ InstantQueryDataReader query.DataReader

+ RangeQueryDataReader query.DataReader

+ RespondWithError bool

+ SeriesQueryDataReader query.DataReader

+ func NewSpyQueryEngine() *SpyQueryEngine

+ func (q *SpyQueryEngine) InstantQuery(ctx context.Context, req *rpc.PromQL_InstantQueryRequest, ...) (*rpc.PromQL_InstantQueryResult, error)

+ func (q *SpyQueryEngine) LabelsQuery(ctx context.Context, req *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)

+ func (q *SpyQueryEngine) RangeQuery(ctx context.Context, req *rpc.PromQL_RangeQueryRequest, ...) (*rpc.PromQL_RangeQueryResult, error)

+ func (q *SpyQueryEngine) SeriesQuery(ctx context.Context, req *rpc.PromQL_SeriesQueryRequest, ...) (*rpc.PromQL_SeriesQueryResult, error)

+ type SpyStore struct

+ End int64

+ GetErr error

+ GetPoints storage.SeriesSet

+ Name string

+ Start int64

+ func NewSpyStoreReader() *SpyStore

+ func (s *SpyStore) Get(params *storage.SelectParams, labelMatchers ...*labels.Matcher) (storage.SeriesSet, error)

+ func (s *SpyStore) LabelValues(*rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)

+ func (s *SpyStore) Labels() (*rpc.PromQL_LabelsQueryResult, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL