internal

Documentation

Overview

Package internal offers helper interfaces that are internal to the Wavefront Go SDK. Interfaces within this package are not guaranteed to be backwards compatible between releases.

Index

• func DeltaCounterName(name string) string
• func GetHostname(defaultVal string) string
• func HasDeltaPrefix(name string) bool
• type ConnectionHandler
  • func NewProxyConnectionHandler(address string, flushInterval time.Duration) ConnectionHandler
• type Flusher
• type FunctionalGauge
• type LineHandler
  • func NewLineHandler(reporter Reporter, format string, flushInterval time.Duration, ...) *LineHandler
  • func (lh *LineHandler) Flush() error
  • func (lh *LineHandler) FlushAll() error
  • func (lh *LineHandler) GetFailureCount() int64
  • func (lh *LineHandler) HandleLine(line string) error
  • func (lh *LineHandler) Start()
  • func (lh *LineHandler) Stop()
• type LineHandlerOption
  • func SetHandlerPrefix(prefix string) LineHandlerOption
  • func SetRegistry(registry *MetricRegistry) LineHandlerOption
• type MetricCounter
• type MetricRegistry
  • 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 ProxyConnectionHandler
  • 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 RegistryOption
  • 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
• type Reporter
  • func NewDirectReporter(server string, token string) Reporter

Functions

func DeltaCounterName

func DeltaCounterName(name string) string

Gets a delta counter name prefixed with ∆.

func GetHostname

func GetHostname(defaultVal string) string

func HasDeltaPrefix

func HasDeltaPrefix(name string) bool

Types

type ConnectionHandler

type ConnectionHandler interface {
	Connect() error
	Connected() bool
	Close()
	SendData(lines string) error

	Flusher
}

func NewProxyConnectionHandler

func NewProxyConnectionHandler(address string, flushInterval time.Duration) ConnectionHandler

type Flusher

type Flusher interface {
	Flush() error
	GetFailureCount() int64
	Start()
}

type FunctionalGauge

type FunctionalGauge struct {
	// contains filtered or unexported fields
}

functional gauge for internal metrics

type LineHandler

type LineHandler struct {
	Reporter      Reporter
	BatchSize     int
	MaxBufferSize int
	Format        string
	// contains filtered or unexported fields
}

func NewLineHandler

func NewLineHandler(reporter Reporter, format string, flushInterval time.Duration, batchSize, maxBufferSize int, setters ...LineHandlerOption) *LineHandler

func (*LineHandler) Flush

func (lh *LineHandler) Flush() error

func (*LineHandler) FlushAll

func (lh *LineHandler) FlushAll() error

func (*LineHandler) GetFailureCount

func (lh *LineHandler) GetFailureCount() int64

func (*LineHandler) HandleLine

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

func (*LineHandler) Start

func (lh *LineHandler) Start()

func (*LineHandler) Stop

func (lh *LineHandler) Stop()

type LineHandlerOption

type LineHandlerOption func(*LineHandler)

func SetHandlerPrefix

func SetHandlerPrefix(prefix string) LineHandlerOption

func SetRegistry

func SetRegistry(registry *MetricRegistry) LineHandlerOption

type MetricCounter

type MetricCounter struct {
	// contains filtered or unexported fields
}

counter for internal metrics

type MetricRegistry

type MetricRegistry struct {
	// contains filtered or unexported fields
}

metric registry for internal metrics

func NewMetricRegistry

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

func (*MetricRegistry) NewCounter

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

func (*MetricRegistry) NewGauge

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

func (*MetricRegistry) Start

func (registry *MetricRegistry) Start()

func (*MetricRegistry) Stop

func (registry *MetricRegistry) Stop()

type ProxyConnectionHandler

type ProxyConnectionHandler struct {
	// contains filtered or unexported fields
}

func (*ProxyConnectionHandler) Close

func (handler *ProxyConnectionHandler) Close()

func (*ProxyConnectionHandler) Connect

func (handler *ProxyConnectionHandler) Connect() error

func (*ProxyConnectionHandler) Connected

func (handler *ProxyConnectionHandler) Connected() bool

func (*ProxyConnectionHandler) Flush

func (handler *ProxyConnectionHandler) Flush() error

func (*ProxyConnectionHandler) GetFailureCount

func (handler *ProxyConnectionHandler) GetFailureCount() int64

func (*ProxyConnectionHandler) SendData

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

func (*ProxyConnectionHandler) Start

func (handler *ProxyConnectionHandler) Start()

type RegistryOption

type RegistryOption func(*MetricRegistry)

func SetInterval

func SetInterval(interval int) RegistryOption

func SetPrefix

func SetPrefix(prefix string) RegistryOption

func SetSource

func SetSource(source string) RegistryOption

func SetTag

func SetTag(key, value string) RegistryOption

func SetTags

func SetTags(tags map[string]string) RegistryOption

type Reporter

type Reporter interface {
	Report(format string, pointLines string) (*http.Response, error)
	Server() string
}

Reporter is an interface for reporting data to a Wavefront service.

func NewDirectReporter

func NewDirectReporter(server string, token string) Reporter