Documentation ¶
Index ¶
- func NewTestSender() senders.Sender
- type TestSender
- func (t *TestSender) Close()
- func (t *TestSender) Flush() error
- func (t *TestSender) GetFailureCount() int64
- func (t *TestSender) GetReceivedLines() string
- func (t *TestSender) SendDeltaCounter(name string, value float64, source string, tags map[string]string) error
- func (t *TestSender) SendDistribution(name string, centroids []histogram.Centroid, ...) error
- func (t *TestSender) SendEvent(name string, startMillis, endMillis int64, source string, ...) error
- func (t *TestSender) SendMetric(name string, value float64, _ int64, source string, tags map[string]string) error
- func (t *TestSender) SendSpan(name string, startMillis, durationMillis int64, source, traceId, spanId string, ...) error
- func (t *TestSender) Start()
- type WavefrontSink
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTestSender ¶ added in v1.3.0
Types ¶
type TestSender ¶ added in v1.3.0
type TestSender struct {
// contains filtered or unexported fields
}
func (*TestSender) Close ¶ added in v1.3.0
func (t *TestSender) Close()
func (*TestSender) Flush ¶ added in v1.3.0
func (t *TestSender) Flush() error
func (*TestSender) GetFailureCount ¶ added in v1.3.0
func (t *TestSender) GetFailureCount() int64
func (*TestSender) GetReceivedLines ¶ added in v1.3.0
func (t *TestSender) GetReceivedLines() string
func (*TestSender) SendDeltaCounter ¶ added in v1.3.0
func (*TestSender) SendDistribution ¶ added in v1.3.0
func (*TestSender) SendMetric ¶ added in v1.3.0
func (*TestSender) Start ¶ added in v1.3.0
func (t *TestSender) Start()
type WavefrontSink ¶ added in v1.0.4
func NewWavefrontSink ¶
func NewWavefrontSink(cfg configuration.WavefrontSinkConfig) (WavefrontSink, error)
Click to show internal directories.
Click to hide internal directories.