Versions in this module Expand all Collapse all v0 v0.55.0 May 4, 2024 v0.54.0 Apr 4, 2024 Changes in this version + var RuntimeMetricsAlias = map[string]string + func ContextForwardWait(ctx context.Context) context.Context + type Agent struct + func NewAgent(opts AgentOptions) (agent *Agent) + func (agent *Agent) BulkForward(ctx context.Context, list []Metric) error + func (agent *Agent) Forward(ctx context.Context, m Metric) (err error) + func (agent *Agent) Stop() + type AgentOptions struct + Collectors []Collector + Forwarders []Forwarder + Interval time.Duration + Metadata *Metadata + Name string + Timestamp Timestamper + type BufferForwarder struct + func NewBufferForwarder(f Formatter) *BufferForwarder + func (buf *BufferForwarder) Bytes() (b []byte) + func (buf *BufferForwarder) Close() error + func (buf *BufferForwarder) Formatter() Formatter + func (buf *BufferForwarder) Write(wire []byte) (n int, err error) + type Collector interface + Collect func(timestamp int64) []Metric + type DsvFormatter struct + func NewDsvFormatter(sep rune, metricsAlias map[string]string) (dsv *DsvFormatter) + func (dsv *DsvFormatter) BulkFormat(listm []Metric, md *Metadata) []byte + func (dsv *DsvFormatter) Format(m Metric, md *Metadata) []byte + func (dsv *DsvFormatter) Name() string + type FileForwarder struct + func NewFileForwarder(fmt Formatter, file io.WriteCloser) (fwd *FileForwarder) + func (fwd *FileForwarder) Close() (err error) + func (fwd *FileForwarder) Formatter() Formatter + func (fwd *FileForwarder) Forward(wire []byte) (err error) + type Formatter interface + BulkFormat func(listm []Metric, md *Metadata) []byte + Format func(m Metric, md *Metadata) []byte + Name func() string + type Forwarder interface + Formatter func() Formatter + type GoMemStatsCollector struct + func NewGoMemStatsCollector(filter *regexp.Regexp) (col *GoMemStatsCollector) + func (col *GoMemStatsCollector) Collect(ts int64) (list []Metric) + type GoMetricsCollector struct + func NewGoMetricsCollector(filter *regexp.Regexp) (col *GoMetricsCollector) + func (col *GoMetricsCollector) Collect(timestamp int64) (list []Metric) + type IlpFormatter struct + func NewIlpFormatter(measurement string) (ilp *IlpFormatter) + func (ilp *IlpFormatter) BulkFormat(list []Metric, md *Metadata) []byte + func (ilp *IlpFormatter) Format(m Metric, md *Metadata) []byte + func (ilp *IlpFormatter) Name() string + type Metadata struct + func NewMetadata() (md *Metadata) + func (md *Metadata) Delete(key string) + func (md *Metadata) Get(key string) string + func (md *Metadata) Keys() (keys []string) + func (md *Metadata) KeysMap() (keys []string, vals map[string]string) + func (md *Metadata) Set(key, value string) + func (md *Metadata) String() string + func (md *Metadata) Version() int + type Metric struct + Name string + Timestamp int64 + Value float64 + type QuestdbForwarder struct + func NewQuestdbForwarder(opts QuestdbOptions) (fwd *QuestdbForwarder, err error) + func (fwd *QuestdbForwarder) Close() (err error) + func (fwd *QuestdbForwarder) Formatter() Formatter + func (fwd *QuestdbForwarder) Write(b []byte) (n int, err error) + type QuestdbOptions struct + Fmt Formatter + ServerURL string + Timeout time.Duration + type StdoutForwarder struct + func NewStdoutForwarder(f Formatter) *StdoutForwarder + func (stdout *StdoutForwarder) Close() error + func (stdout *StdoutForwarder) Formatter() Formatter + func (stdout *StdoutForwarder) Write(wire []byte) (n int, err error) + type Timestamper func() int64 + func DummyTimestamp() Timestamper + func MilliTimestamp() Timestamper + func NanoTimestamp() Timestamper + func SecondTimestamp() Timestamper