Documentation
¶
Index ¶
- Constants
- 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
- type Series
- type 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
- 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
- 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
- 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
Constants ¶
const (
UNDEFINED_METRIC float64 = 99999999999
)
Variables ¶
This section is empty.
Functions ¶
func Asset ¶
Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.
func AssetDir ¶
AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy:
data/
foo.txt
img/
a.png
b.png
then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.
func AssetInfo ¶
AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.
func BuildExpectedLog ¶
func BuildRequest ¶
func GetFreePort ¶
func GetFreePort() int
func GrpcTLSCredentials ¶
func GrpcTLSCredentials() credentials.TransportCredentials
func MustAsset ¶
MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.
func NewIngressClient ¶
func NewIngressClient(addr string) (client rpc.IngressClient, cleanup func())
func NewMutualTLSConfig ¶
func NewServerRequest ¶
func RestoreAsset ¶
RestoreAsset restores an asset under the given directory
func RestoreAssets ¶
RestoreAssets restores an asset under the given directory recursively
func StartGoProcess ¶
func WaitForHealthCheck ¶
func WaitForHealthCheck(healthAddr string)
func WaitForServer ¶
func WaitForServer(addr string)
Types ¶
type Series ¶
func ExplodeSeriesSet ¶
type SpyDataReader ¶
type SpyDataReader struct {
ReadStarts []int64
ReadEnds []int64
ReadResults []*rpc.PromQL_Matrix
ReadErrs []error
LabelsResponse *rpc.PromQL_LabelsQueryResult
LabelsError error
LabelValuesResponse *rpc.PromQL_LabelValuesQueryResult
LabelValuesError error
}
func NewSpyDataReader ¶
func NewSpyDataReader() *SpyDataReader
func (*SpyDataReader) LabelValues ¶
func (s *SpyDataReader) LabelValues(ctx context.Context, in *rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)
func (*SpyDataReader) Labels ¶
func (s *SpyDataReader) Labels(ctx context.Context, in *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)
type SpyMetricStore ¶
type SpyMetricStore struct {
QueryError error
// contains filtered or unexported fields
}
func NewSpyMetricStore ¶
func NewSpyMetricStore(tlsConfig *tls.Config) *SpyMetricStore
func (*SpyMetricStore) GetLabelsQueryRequests ¶
func (s *SpyMetricStore) GetLabelsQueryRequests() []*rpc.PromQL_LabelsQueryRequest
func (*SpyMetricStore) GetPoints ¶
func (s *SpyMetricStore) GetPoints() []*rpc.Point
func (*SpyMetricStore) GetQueryRequests ¶
func (s *SpyMetricStore) GetQueryRequests() []*rpc.PromQL_InstantQueryRequest
func (*SpyMetricStore) GetRangeQueryRequests ¶
func (s *SpyMetricStore) GetRangeQueryRequests() []*rpc.PromQL_RangeQueryRequest
func (*SpyMetricStore) GetSeriesQueryRequests ¶
func (s *SpyMetricStore) GetSeriesQueryRequests() []*rpc.PromQL_SeriesQueryRequest
func (*SpyMetricStore) InstantQuery ¶
func (s *SpyMetricStore) InstantQuery(ctx context.Context, r *rpc.PromQL_InstantQueryRequest) (*rpc.PromQL_InstantQueryResult, error)
func (*SpyMetricStore) LabelValuesQuery ¶
func (s *SpyMetricStore) LabelValuesQuery(ctx context.Context, req *rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)
func (*SpyMetricStore) LabelsQuery ¶
func (s *SpyMetricStore) LabelsQuery(ctx context.Context, req *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)
func (*SpyMetricStore) RangeQuery ¶
func (s *SpyMetricStore) RangeQuery(ctx context.Context, r *rpc.PromQL_RangeQueryRequest) (*rpc.PromQL_RangeQueryResult, error)
func (*SpyMetricStore) Send ¶
func (s *SpyMetricStore) Send(ctx context.Context, r *rpc.SendRequest) (*rpc.SendResponse, error)
func (*SpyMetricStore) SeriesQuery ¶
func (s *SpyMetricStore) SeriesQuery(ctx context.Context, req *rpc.PromQL_SeriesQueryRequest) (*rpc.PromQL_SeriesQueryResult, error)
func (*SpyMetricStore) SetValue ¶
func (s *SpyMetricStore) SetValue(value float64)
func (*SpyMetricStore) Start ¶
func (s *SpyMetricStore) Start() string
type SpyMetrics ¶
func NewSpyMetrics ¶
func NewSpyMetrics() *SpyMetrics
func (*SpyMetrics) Get ¶
func (s *SpyMetrics) Get(name string) float64
func (*SpyMetrics) GetUnit ¶
func (s *SpyMetrics) GetUnit(name string) string
func (*SpyMetrics) Getter ¶
func (s *SpyMetrics) Getter(name string) func() float64
func (*SpyMetrics) NewCounter ¶
func (s *SpyMetrics) NewCounter(name string) func(uint64)
func (*SpyMetrics) NewGauge ¶
func (s *SpyMetrics) NewGauge(name, unit string) func(float64)
func (*SpyMetrics) NewSummary ¶
func (s *SpyMetrics) NewSummary(name, unit string) func(float64)
func (*SpyMetrics) SummaryObservationsGetter ¶
func (s *SpyMetrics) SummaryObservationsGetter(name string) func() []float64
type SpyQueryEngine ¶
type SpyQueryEngine struct {
InstantQueryDataReader query.DataReader
RangeQueryDataReader query.DataReader
SeriesQueryDataReader query.DataReader
RespondWithError bool
}
func NewSpyQueryEngine ¶
func NewSpyQueryEngine() *SpyQueryEngine
func (*SpyQueryEngine) InstantQuery ¶
func (q *SpyQueryEngine) InstantQuery(ctx context.Context, req *rpc.PromQL_InstantQueryRequest, dataReader query.DataReader) (*rpc.PromQL_InstantQueryResult, error)
func (*SpyQueryEngine) LabelsQuery ¶
func (q *SpyQueryEngine) LabelsQuery(ctx context.Context, req *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)
func (*SpyQueryEngine) RangeQuery ¶
func (q *SpyQueryEngine) RangeQuery(ctx context.Context, req *rpc.PromQL_RangeQueryRequest, dataReader query.DataReader) (*rpc.PromQL_RangeQueryResult, error)
func (*SpyQueryEngine) SeriesQuery ¶
func (q *SpyQueryEngine) SeriesQuery(ctx context.Context, req *rpc.PromQL_SeriesQueryRequest, dataReader query.DataReader) (*rpc.PromQL_SeriesQueryResult, error)
type SpyStore ¶
func NewSpyStoreReader ¶
func NewSpyStoreReader() *SpyStore
func (*SpyStore) LabelValues ¶
func (s *SpyStore) LabelValues(*rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)