local

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithLogger 

func WithLogger(l *log.Logger) erpOption

Types

type EgressReverseProxy 

type EgressReverseProxy struct {
	// contains filtered or unexported fields
}

func NewEgressReverseProxy 

func NewEgressReverseProxy(
	localReader query.DataReader,
	engine QueryEngine,
	opts ...erpOption,
) *EgressReverseProxy

func (*EgressReverseProxy) InstantQuery 

func (erp *EgressReverseProxy) InstantQuery(ctx context.Context, req *rpc.PromQL_InstantQueryRequest) (*rpc.PromQL_InstantQueryResult, error)

func (*EgressReverseProxy) LabelValuesQuery 

func (erp *EgressReverseProxy) LabelValuesQuery(ctx context.Context, req *rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)

func (*EgressReverseProxy) LabelsQuery 

func (erp *EgressReverseProxy) LabelsQuery(ctx context.Context, req *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)

func (*EgressReverseProxy) RangeQuery 

func (erp *EgressReverseProxy) RangeQuery(ctx context.Context, req *rpc.PromQL_RangeQueryRequest) (*rpc.PromQL_RangeQueryResult, error)

func (*EgressReverseProxy) SeriesQuery 

func (erp *EgressReverseProxy) SeriesQuery(ctx context.Context, req *rpc.PromQL_SeriesQueryRequest) (*rpc.PromQL_SeriesQueryResult, error)

type IngressClientFunc 

type IngressClientFunc func(ctx context.Context, r *rpc.SendRequest, opts ...grpc.CallOption) (*rpc.SendResponse, error)

IngressClientFunc transforms a function into an IngressClient.

func (IngressClientFunc) Send 

func (f IngressClientFunc) Send(ctx context.Context, r *rpc.SendRequest, opts ...grpc.CallOption) (*rpc.SendResponse, error)

Send implements an IngressClient.

type IngressReverseProxy 

type IngressReverseProxy struct {
	// contains filtered or unexported fields
}

IngressReverseProxy is a reverse proxy for Ingress requests.

func NewIngressReverseProxy 

func NewIngressReverseProxy(
	localClient rpc.IngressClient,
	log *log.Logger,
) *IngressReverseProxy

NewIngressReverseProxy returns a new IngressReverseProxy.

func (*IngressReverseProxy) Send 

func (p *IngressReverseProxy) Send(ctx context.Context, r *rpc.SendRequest) (*rpc.SendResponse, error)

type LocalStoreReader 

type LocalStoreReader struct {
	// contains filtered or unexported fields
}

func NewLocalStoreReader 

func NewLocalStoreReader(store Store) *LocalStoreReader

func (LocalStoreReader) LabelValues 

func (reader LocalStoreReader) LabelValues(ctx context.Context, in *rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)

func (LocalStoreReader) Labels 

func (reader LocalStoreReader) Labels(ctx context.Context, in *rpc.PromQL_LabelsQueryRequest) (*rpc.PromQL_LabelsQueryResult, error)

func (LocalStoreReader) Read 

func (reader LocalStoreReader) Read(ctx context.Context, params *storage.SelectParams, labelMatchers ...*labels.Matcher) (storage.SeriesSet, error)

type QueryEngine 

type QueryEngine interface {
	InstantQuery(context.Context, *rpc.PromQL_InstantQueryRequest, query.DataReader) (*rpc.PromQL_InstantQueryResult, error)
	RangeQuery(context.Context, *rpc.PromQL_RangeQueryRequest, query.DataReader) (*rpc.PromQL_RangeQueryResult, error)
	SeriesQuery(context.Context, *rpc.PromQL_SeriesQueryRequest, query.DataReader) (*rpc.PromQL_SeriesQueryResult, error)
}

type Store 

type Store interface {
	Get(*storage.SelectParams, ...*labels.Matcher) (storage.SeriesSet, error)
	Labels() (*rpc.PromQL_LabelsQueryResult, error)
	LabelValues(*rpc.PromQL_LabelValuesQueryRequest) (*rpc.PromQL_LabelValuesQueryResult, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.