internal

Aug 31, 2023

Changes in this version

+ type RealLineHandler struct

+ BatchSize int

+ Format string

+ MaxBufferSize int

+ Reporter Reporter

+ func (lh *RealLineHandler) Flush() error

+ func (lh *RealLineHandler) FlushAll() error

+ func (lh *RealLineHandler) GetFailureCount() int64

+ func (lh *RealLineHandler) GetThrottledCount() int64

+ func (lh *RealLineHandler) HandleLine(line string) error

+ func (lh *RealLineHandler) Start()

+ func (lh *RealLineHandler) Stop()

Jan 24, 2023

Changes in this version

+ func NewClient(timeout time.Duration, tlsConfig *tls.Config) *http.Client

+ func Sanitize(str string) string

+ func SanitizeValue(str string) string

Feb 6, 2021

Changes in this version

+ const AltDeltaPrefix

+ const DeltaPrefix

+ func GetBuffer() *bytes.Buffer

+ func GetSemVer(version string) (float64, error)

+ func PutBuffer(buf *bytes.Buffer)

+ type DeltaCounter struct

+ type FunctionalGaugeFloat64 struct

type MetricCounter

+ func (c *MetricCounter) Inc()

type MetricRegistry

+ func (registry *MetricRegistry) NewDeltaCounter(name string) *DeltaCounter

+ func (registry *MetricRegistry) NewGaugeFloat64(name string, f func() float64) *FunctionalGaugeFloat64

type Reporter

+ func NewReporter(server string, token string) Reporter

Jan 23, 2020

Changes in this version

+ const EventFormat

+ const HistogramFormat

+ const MetricFormat

+ const SpanLogsFormat

+ const TraceFormat

type LineHandler

+ func (lh *LineHandler) GetThrottledCount() int64

type LineHandlerOption

+ func SetLockOnThrottledError(lock bool) LineHandlerOption

type Reporter

+ ReportEvent func(event string) (*http.Response, error)

Jul 22, 2019

Changes in this version

+ type FunctionalGauge struct

type LineHandler

+ func NewLineHandler(reporter Reporter, format string, flushInterval time.Duration, ...) *LineHandler

+ func (lh *LineHandler) FlushAll() error

+ type LineHandlerOption func(*LineHandler)

+ func SetHandlerPrefix(prefix string) LineHandlerOption

+ func SetRegistry(registry *MetricRegistry) LineHandlerOption

+ type MetricCounter struct

+ type MetricRegistry struct

+ func NewMetricRegistry(sender internalSender, setters ...RegistryOption) *MetricRegistry

+ func (registry *MetricRegistry) NewCounter(name string) *MetricCounter

+ func (registry *MetricRegistry) NewGauge(name string, f func() int64) *FunctionalGauge

+ func (registry *MetricRegistry) Start()

+ func (registry *MetricRegistry) Stop()

+ type RegistryOption func(*MetricRegistry)

+ func SetInterval(interval int) RegistryOption

+ func SetPrefix(prefix string) RegistryOption

+ func SetSource(source string) RegistryOption

+ func SetTag(key, value string) RegistryOption

+ func SetTags(tags map[string]string) RegistryOption

Nov 6, 2018

Changes in this version

+ func DeltaCounterName(name string) string

+ func GetHostname(defaultVal string) string

+ func HasDeltaPrefix(name string) bool

+ type ConnectionHandler interface

+ Close func()

+ Connect func() error

+ Connected func() bool

+ SendData func(lines string) error

+ func NewProxyConnectionHandler(address string, ticker *time.Ticker) ConnectionHandler

+ type Flusher interface

+ Flush func() error

+ GetFailureCount func() int64

+ Start func()

+ type LineHandler struct

+ BatchSize int

+ FlushTicker *time.Ticker

+ Format string

+ MaxBufferSize int

+ Reporter Reporter

+ func (lh *LineHandler) Flush() error

+ func (lh *LineHandler) GetFailureCount() int64

+ func (lh *LineHandler) HandleLine(line string) error

+ func (lh *LineHandler) Start()

+ func (lh *LineHandler) Stop()

+ type ProxyConnectionHandler struct

+ func (handler *ProxyConnectionHandler) Close()

+ func (handler *ProxyConnectionHandler) Connect() error

+ func (handler *ProxyConnectionHandler) Connected() bool

+ func (handler *ProxyConnectionHandler) Flush() error

+ func (handler *ProxyConnectionHandler) GetFailureCount() int64

+ func (handler *ProxyConnectionHandler) SendData(lines string) error

+ func (handler *ProxyConnectionHandler) Start()

+ type Reporter interface

+ Report func(format string, pointLines string) (*http.Response, error)

+ Server func() string

+ func NewDirectReporter(server string, token string) Reporter