Documentation
¶
Index ¶
- Variables
- func IsEnabled(ctx context.Context) bool
- func ShouldTrackHTTPGRPCResponse(r *httpgrpc.HTTPResponse) bool
- type Stats
- func (s *Stats) AddFetchedChunkBytes(bytes uint64)
- func (s *Stats) AddFetchedSeries(series uint64)
- func (s *Stats) AddWallTime(t time.Duration)
- func (*Stats) Descriptor() ([]byte, []int)
- func (this *Stats) Equal(that interface{}) bool
- func (m *Stats) GetFetchedChunkBytes() uint64
- func (m *Stats) GetFetchedSeriesCount() uint64
- func (m *Stats) GetWallTime() time.Duration
- func (this *Stats) GoString() string
- func (s *Stats) LoadFetchedChunkBytes() uint64
- func (s *Stats) LoadFetchedSeries() uint64
- func (s *Stats) LoadWallTime() time.Duration
- func (m *Stats) Marshal() (dAtA []byte, err error)
- func (m *Stats) MarshalTo(dAtA []byte) (int, error)
- func (m *Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (s *Stats) Merge(other *Stats)
- func (*Stats) ProtoMessage()
- func (m *Stats) Reset()
- func (m *Stats) Size() (n int)
- func (this *Stats) String() string
- func (m *Stats) Unmarshal(dAtA []byte) error
- func (m *Stats) XXX_DiscardUnknown()
- func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Stats) XXX_Merge(src proto.Message)
- func (m *Stats) XXX_Size() int
- func (m *Stats) XXX_Unmarshal(b []byte) error
- type WallTimeMiddleware
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStats = fmt.Errorf("proto: integer overflow") )
Functions ¶
func ShouldTrackHTTPGRPCResponse ¶
func ShouldTrackHTTPGRPCResponse(r *httpgrpc.HTTPResponse) bool
Types ¶
type Stats ¶
type Stats struct {
// The sum of all wall time spent in the querier to execute the query.
WallTime time.Duration `protobuf:"bytes,1,opt,name=wall_time,json=wallTime,proto3,stdduration" json:"wall_time"`
// The number of series fetched for the query
FetchedSeriesCount uint64 `protobuf:"varint,2,opt,name=fetched_series_count,json=fetchedSeriesCount,proto3" json:"fetched_series_count,omitempty"`
// The number of bytes of the chunks fetched for the query
FetchedChunkBytes uint64 `protobuf:"varint,3,opt,name=fetched_chunk_bytes,json=fetchedChunkBytes,proto3" json:"fetched_chunk_bytes,omitempty"`
}
func ContextWithEmptyStats ¶
ContextWithEmptyStats returns a context with empty stats.
func FromContext ¶
FromContext gets the Stats out of the Context. Returns nil if stats have not been initialised in the context.
func (*Stats) AddFetchedChunkBytes ¶
func (*Stats) AddFetchedSeries ¶
func (*Stats) AddWallTime ¶
AddWallTime adds some time to the counter.
func (*Stats) Descriptor ¶
func (*Stats) GetFetchedChunkBytes ¶
func (*Stats) GetFetchedSeriesCount ¶
func (*Stats) GetWallTime ¶
func (*Stats) LoadFetchedChunkBytes ¶
func (*Stats) LoadFetchedSeries ¶
func (*Stats) LoadWallTime ¶
LoadWallTime returns current wall time.
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) XXX_DiscardUnknown ¶
func (m *Stats) XXX_DiscardUnknown()
func (*Stats) XXX_Marshal ¶
func (*Stats) XXX_Unmarshal ¶
type WallTimeMiddleware ¶
type WallTimeMiddleware struct{}
WallTimeMiddleware tracks the wall time.
func NewWallTimeMiddleware ¶
func NewWallTimeMiddleware() WallTimeMiddleware
NewWallTimeMiddleware makes a new WallTimeMiddleware.
Source Files
Click to show internal directories.
Click to hide internal directories.