Documentation
¶
Index ¶
- func NewTestSender() senders.Sender
- func NewWavefrontSink(cfg configuration.SinkConfig) (sinks.Sink, error)
- 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTestSender ¶
func NewWavefrontSink ¶
func NewWavefrontSink(cfg configuration.SinkConfig) (sinks.Sink, error)
Types ¶
type TestSender ¶
type TestSender struct {
// contains filtered or unexported fields
}
func (*TestSender) Close ¶
func (t *TestSender) Close()
func (*TestSender) Flush ¶
func (t *TestSender) Flush() error
func (*TestSender) GetFailureCount ¶
func (t *TestSender) GetFailureCount() int64
func (*TestSender) GetReceivedLines ¶
func (t *TestSender) GetReceivedLines() string
func (*TestSender) SendDeltaCounter ¶
func (*TestSender) SendDistribution ¶
func (*TestSender) SendMetric ¶
func (*TestSender) Start ¶
func (t *TestSender) Start()
Source Files
Click to show internal directories.
Click to hide internal directories.