Versions in this module Expand all Collapse all v0 v0.0.1 Jul 2, 2024 Changes in this version + const NetworkModeAgent + const NetworkModePod + func BoolToFloat64(b bool) float64 + func NsEnterHelpProcesResponse(respBytes []byte, accumulator Accumulator) error + type Accumulator interface + AddMetric func(*model.Metric) + func WithPrefix(a Accumulator, prefix string) Accumulator + type CollectContext struct + AlignedTimestamp int64 + type Input interface + Collect func(Accumulator) error + type InputExt interface + DebugInfo func() map[string]interface{} + UpdateFrom func(interface{}) + type InputExtNsEnter interface + ExecuteRequest func([]byte) ([]byte, error) + GenerateErrorMetrics func(a Accumulator) + NetworkMode func() string + ProcessResponse func(interface{}, []byte, error, Accumulator) error + SerializeRequest func() (interface{}, string, []byte, time.Duration, error) + type InputWithPrefix interface + GetDefaultPrefix func() string + type MemoryAccumulator struct + Metrics []*model.Metric + func NewMemoryAccumulator() *MemoryAccumulator + func (ma *MemoryAccumulator) AddMetric(metric *model.Metric) + func (ma *MemoryAccumulator) PrintTo(writer io.Writer) error + type Pipeline interface + Key func() string + SetupConsumer func(st *SubTask) error + Start func() error + Stop func() + Update func(func(Pipeline)) + View func(func(Pipeline)) + type PipelineUpdateAware interface + UpdateFrom func(Pipeline) + type SubTask struct + CT *collecttask.CollectTask + SqlTask *collectconfig.SQLTask
Go to main page