stats

package

v2.5.2 Latest Latest Go to latest Published: Apr 27, 2022 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/fmoor/loki

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func IsEnabled(ctx context.Context) bool
func ShouldTrackHTTPGRPCResponse(r *httpgrpc.HTTPResponse) bool
type Stats
- func ContextWithEmptyStats(ctx context.Context) (*Stats, context.Context)
- func FromContext(ctx context.Context) *Stats
type WallTimeMiddleware
- func NewWallTimeMiddleware() WallTimeMiddleware
- func (m WallTimeMiddleware) Wrap(next http.Handler) http.Handler

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 IsEnabled ¶

func IsEnabled(ctx context.Context) bool

IsEnabled returns whether stats tracking is enabled in the context.

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 ¶

func ContextWithEmptyStats(ctx context.Context) (*Stats, context.Context)

ContextWithEmptyStats returns a context with empty stats.

func FromContext ¶

func FromContext(ctx context.Context) *Stats

FromContext gets the Stats out of the Context. Returns nil if stats have not been initialised in the context.

func (*Stats) AddFetchedChunkBytes ¶

func (s *Stats) AddFetchedChunkBytes(bytes uint64)

func (*Stats) AddFetchedSeries ¶

func (s *Stats) AddFetchedSeries(series uint64)

func (*Stats) AddWallTime ¶

func (s *Stats) AddWallTime(t time.Duration)

AddWallTime adds some time to the counter.

func (*Stats) Descriptor ¶

func (*Stats) Descriptor() ([]byte, []int)

func (*Stats) Equal ¶

func (this *Stats) Equal(that interface{}) bool

func (*Stats) GetFetchedChunkBytes ¶

func (m *Stats) GetFetchedChunkBytes() uint64

func (*Stats) GetFetchedSeriesCount ¶

func (m *Stats) GetFetchedSeriesCount() uint64

func (*Stats) GetWallTime ¶

func (m *Stats) GetWallTime() time.Duration

func (*Stats) GoString ¶

func (this *Stats) GoString() string

func (*Stats) LoadFetchedChunkBytes ¶

func (s *Stats) LoadFetchedChunkBytes() uint64

func (*Stats) LoadFetchedSeries ¶

func (s *Stats) LoadFetchedSeries() uint64

func (*Stats) LoadWallTime ¶

func (s *Stats) LoadWallTime() time.Duration

LoadWallTime returns current wall time.

func (*Stats) Marshal ¶

func (m *Stats) Marshal() (dAtA []byte, err error)

func (*Stats) MarshalTo ¶

func (m *Stats) MarshalTo(dAtA []byte) (int, error)

func (*Stats) MarshalToSizedBuffer ¶

func (m *Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Stats) Merge ¶

func (s *Stats) Merge(other *Stats)

Merge the provide Stats into this one.

func (*Stats) ProtoMessage ¶

func (*Stats) ProtoMessage()

func (*Stats) Reset ¶

func (m *Stats) Reset()

func (*Stats) Size ¶

func (m *Stats) Size() (n int)

func (*Stats) String ¶

func (this *Stats) String() string

func (*Stats) Unmarshal ¶

func (m *Stats) Unmarshal(dAtA []byte) error

func (*Stats) XXX_DiscardUnknown ¶

func (m *Stats) XXX_DiscardUnknown()

func (*Stats) XXX_Marshal ¶

func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stats) XXX_Merge ¶

func (m *Stats) XXX_Merge(src proto.Message)

func (*Stats) XXX_Size ¶

func (m *Stats) XXX_Size() int

func (*Stats) XXX_Unmarshal ¶

func (m *Stats) XXX_Unmarshal(b []byte) error

type WallTimeMiddleware ¶

type WallTimeMiddleware struct{}

WallTimeMiddleware tracks the wall time.

func NewWallTimeMiddleware ¶

func NewWallTimeMiddleware() WallTimeMiddleware

NewWallTimeMiddleware makes a new WallTimeMiddleware.

func (WallTimeMiddleware) Wrap ¶

func (m WallTimeMiddleware) Wrap(next http.Handler) http.Handler

Wrap implements middleware.Interface.

Source Files ¶

View all Source files

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