Documentation
¶
Index ¶
- Variables
- func NewCounterLogExporter(counter *CounterSet) stats.LogExporter
- func Update(ctx context.Context, fn func(*CounterSet), extraCounterSets ...*CounterSet)
- func WithCounterSet(ctx context.Context, sets ...*CounterSet) context.Context
- func WithCounterSetFrom(ctx context.Context, fromCtx context.Context) context.Context
- type CounterLogExporter
- type CounterSet
- type CounterSets
- type DistTAECounterSet
- type FileServiceCounterSet
- type IterFieldsFunc
- type TAECounterSet
Constants ¶
This section is empty.
Variables ¶
View Source
var CtxKeyCounters = ctxKeyCounters{}
Functions ¶
func NewCounterLogExporter ¶
func NewCounterLogExporter(counter *CounterSet) stats.LogExporter
func Update ¶
func Update(ctx context.Context, fn func(*CounterSet), extraCounterSets ...*CounterSet)
func WithCounterSet ¶
func WithCounterSet(ctx context.Context, sets ...*CounterSet) context.Context
Types ¶
type CounterLogExporter ¶
type CounterLogExporter struct {
// contains filtered or unexported fields
}
func (*CounterLogExporter) Export ¶
func (c *CounterLogExporter) Export() []zap.Field
Export returns the fields and its values in loggable format.
type CounterSet ¶
type CounterSet struct {
FileService FileServiceCounterSet
FileServiceByName map[string]*CounterSet
DistTAE DistTAECounterSet
TAE TAECounterSet
}
func (*CounterSet) IterFields ¶
func (c *CounterSet) IterFields(fn IterFieldsFunc) error
func (*CounterSet) ServeHTTP ¶
func (c *CounterSet) ServeHTTP(w http.ResponseWriter, req *http.Request)
type CounterSets ¶
type CounterSets = map[*CounterSet]struct{}
type DistTAECounterSet ¶
type DistTAECounterSet struct {
Logtail struct {
Entries stats.Counter
InsertEntries stats.Counter
MetadataInsertEntries stats.Counter
DeleteEntries stats.Counter
MetadataDeleteEntries stats.Counter
InsertRows stats.Counter
DeleteRows stats.Counter
ActiveRows stats.Counter
InsertBlocks stats.Counter
}
}
type FileServiceCounterSet ¶
type FileServiceCounterSet struct {
S3 struct {
List stats.Counter
Head stats.Counter
Put stats.Counter
Get stats.Counter
Delete stats.Counter
DeleteMulti stats.Counter
}
Cache struct {
Read stats.Counter
Hit stats.Counter
Memory struct {
Read stats.Counter
Hit stats.Counter
Capacity stats.Counter
Used stats.Counter
Available stats.Counter
}
Disk struct {
Read stats.Counter
Hit stats.Counter
GetFileContent stats.Counter
SetFileContent stats.Counter
OpenFile stats.Counter
StatFile stats.Counter
WriteFile stats.Counter
Error stats.Counter
Evict stats.Counter
EvictPending stats.Counter
EvictImmediately stats.Counter
}
LRU struct {
Evict stats.Counter
EvictWithZeroRead stats.Counter
}
}
FileWithChecksum struct {
Read stats.Counter
Write stats.Counter
UnderlyingRead stats.Counter
UnderlyingWrite stats.Counter
}
}
type TAECounterSet ¶
type TAECounterSet struct {
LogTail struct {
Entries stats.Counter
InsertEntries stats.Counter
DeleteEntries stats.Counter
}
CheckPoint struct {
DoGlobalCheckPoint stats.Counter
DoIncrementalCheckpoint stats.Counter
DeleteGlobalEntry stats.Counter
DeleteIncrementalEntry stats.Counter
}
Segment struct {
Create stats.Counter
CreateNonAppendable stats.Counter
SoftDelete stats.Counter
MergeBlocks stats.Counter
CompactBlock stats.Counter
}
Block struct {
Create stats.Counter
CreateNonAppendable stats.Counter
SoftDelete stats.Counter
Flush stats.Counter
}
}
Click to show internal directories.
Click to hide internal directories.