Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + var ErrIntOverflowDefinitions = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDefinitions = fmt.Errorf("proto: negative length found during unmarshaling") + type CachingOptions struct + Disabled bool + func (*CachingOptions) Descriptor() ([]byte, []int) + func (*CachingOptions) ProtoMessage() + func (m *CachingOptions) GetDisabled() bool + func (m *CachingOptions) Marshal() (dAtA []byte, err error) + func (m *CachingOptions) MarshalTo(dAtA []byte) (int, error) + func (m *CachingOptions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CachingOptions) Reset() + func (m *CachingOptions) Size() (n int) + func (m *CachingOptions) Unmarshal(dAtA []byte) error + func (m *CachingOptions) XXX_DiscardUnknown() + func (m *CachingOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CachingOptions) XXX_Merge(src proto.Message) + func (m *CachingOptions) XXX_Size() int + func (m *CachingOptions) XXX_Unmarshal(b []byte) error + func (this *CachingOptions) Equal(that interface{}) bool + func (this *CachingOptions) GoString() string + func (this *CachingOptions) String() string + type Codec interface + DecodeRequest func(_ context.Context, request *http.Request, forwardHeaders []string) (Request, error) + DecodeResponse func(context.Context, *http.Response, Request) (Response, error) + EncodeRequest func(context.Context, Request) (*http.Request, error) + EncodeResponse func(context.Context, Response) (*http.Response, error) + type Merger interface + MergeResponse func(...Response) (Response, error) + type PrometheusRequestHeader struct + Name string + Values []string + func (*PrometheusRequestHeader) Descriptor() ([]byte, []int) + func (*PrometheusRequestHeader) ProtoMessage() + func (m *PrometheusRequestHeader) GetName() string + func (m *PrometheusRequestHeader) GetValues() []string + func (m *PrometheusRequestHeader) Marshal() (dAtA []byte, err error) + func (m *PrometheusRequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *PrometheusRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrometheusRequestHeader) Reset() + func (m *PrometheusRequestHeader) Size() (n int) + func (m *PrometheusRequestHeader) Unmarshal(dAtA []byte) error + func (m *PrometheusRequestHeader) XXX_DiscardUnknown() + func (m *PrometheusRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrometheusRequestHeader) XXX_Merge(src proto.Message) + func (m *PrometheusRequestHeader) XXX_Size() int + func (m *PrometheusRequestHeader) XXX_Unmarshal(b []byte) error + func (this *PrometheusRequestHeader) Equal(that interface{}) bool + func (this *PrometheusRequestHeader) GoString() string + func (this *PrometheusRequestHeader) String() string + type PrometheusResponseHeader struct + Name string + Values []string + func (*PrometheusResponseHeader) Descriptor() ([]byte, []int) + func (*PrometheusResponseHeader) ProtoMessage() + func (m *PrometheusResponseHeader) GetName() string + func (m *PrometheusResponseHeader) GetValues() []string + func (m *PrometheusResponseHeader) Marshal() (dAtA []byte, err error) + func (m *PrometheusResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *PrometheusResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PrometheusResponseHeader) Reset() + func (m *PrometheusResponseHeader) Size() (n int) + func (m *PrometheusResponseHeader) Unmarshal(dAtA []byte) error + func (m *PrometheusResponseHeader) XXX_DiscardUnknown() + func (m *PrometheusResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrometheusResponseHeader) XXX_Merge(src proto.Message) + func (m *PrometheusResponseHeader) XXX_Size() int + func (m *PrometheusResponseHeader) XXX_Unmarshal(b []byte) error + func (this *PrometheusResponseHeader) Equal(that interface{}) bool + func (this *PrometheusResponseHeader) GoString() string + func (this *PrometheusResponseHeader) String() string + type Request interface + GetCachingOptions func() CachingOptions + GetEnd func() int64 + GetQuery func() string + GetStart func() int64 + GetStep func() int64 + LogToSpan func(opentracing.Span) + WithQuery func(string) Request + WithStartEnd func(startTime int64, endTime int64) Request + type Response interface + GetHeaders func() []*PrometheusResponseHeader