sender

Documentation

Index

• type DiagnoseSenderManager
• type Sender
• type SenderManager

Types

type DiagnoseSenderManager

type DiagnoseSenderManager interface {
	LazyGetSenderManager() (SenderManager, error)
}

DiagnoseSenderManager is the SenderManager used by the diagnose command It creates an instance of senderManager lazily to keep the same behavior as before.

type Sender

type Sender interface {
	Commit()
	Gauge(metric string, value float64, hostname string, tags []string)
	GaugeNoIndex(metric string, value float64, hostname string, tags []string)
	Rate(metric string, value float64, hostname string, tags []string)
	Count(metric string, value float64, hostname string, tags []string)
	MonotonicCount(metric string, value float64, hostname string, tags []string)
	MonotonicCountWithFlushFirstValue(metric string, value float64, hostname string, tags []string, flushFirstValue bool)
	Counter(metric string, value float64, hostname string, tags []string)
	Histogram(metric string, value float64, hostname string, tags []string)
	Historate(metric string, value float64, hostname string, tags []string)
	Distribution(metric string, value float64, hostname string, tags []string)
	ServiceCheck(checkName string, status servicecheck.ServiceCheckStatus, hostname string, tags []string, message string)
	HistogramBucket(metric string, value int64, lowerBound, upperBound float64, monotonic bool, hostname string, tags []string, flushFirstValue bool)
	// GaugeWithTimestamp reports a new gauge value to the intake with the given timestamp.
	// Gauge time series measure a simple value over time.
	// Unlike Gauge(), each submitted value will be passed to the intake as is, without aggregation. Each time series can have only one value per timestamp.
	GaugeWithTimestamp(metric string, value float64, hostname string, tags []string, timestamp float64) error
	// CountWithTimestamp reports a new count value to the intake with the given timestamp.
	// Count time series measure how many times something happened in some time period.
	// Unlike Count(), each submitted value will be passed to the intake as is, without aggregation. Each time series can have only one value per timestamp.
	CountWithTimestamp(metric string, value float64, hostname string, tags []string, timestamp float64) error
	Event(e event.Event)
	EventPlatformEvent(rawEvent []byte, eventType string)
	GetSenderStats() stats.SenderStats
	DisableDefaultHostname(disable bool)
	SetCheckCustomTags(tags []string)
	SetCheckService(service string)
	SetNoIndex(noIndex bool)
	FinalizeCheckServiceTag()
	OrchestratorMetadata(msgs []types.ProcessMessageBody, clusterID string, nodeType int)
	OrchestratorManifest(msgs []types.ProcessMessageBody, clusterID string)
}

Sender allows sending metrics from checks/a check

type SenderManager

type SenderManager interface {
	GetSender(id checkid.ID) (Sender, error)
	SetSender(Sender, checkid.ID) error
	DestroySender(id checkid.ID)
	GetDefaultSender() (Sender, error)
}