internal

package
v0.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 24, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

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

Constants

View Source 
const (
	DeltaPrefix    = "\u2206"
	AltDeltaPrefix = "\u0394"
)
View Source 
const (
	MetricFormat    = "wavefront"
	HistogramFormat = "histogram"
	TraceFormat     = "trace"
	SpanLogsFormat  = "spanLogs"
	EventFormat     = "event"
)

Variables

This section is empty.

Functions

func DeltaCounterName 

func DeltaCounterName(name string) string

Gets a delta counter name prefixed with ∆.

func GetBuffer added in v0.9.8 

func GetBuffer() *bytes.Buffer

GetBuffer fetches a buffers from the pool

func GetHostname 

func GetHostname(defaultVal string) string

func GetSemVer added in v0.9.8 

func GetSemVer(version string) (float64, error)

func HasDeltaPrefix 

func HasDeltaPrefix(name string) bool

func PutBuffer added in v0.9.8 

func PutBuffer(buf *bytes.Buffer)

PutBuffer returns a buffers to the pool

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, prefix string, internalRegistry *MetricRegistry) ConnectionHandler

type DeltaCounter added in v0.9.8 

type DeltaCounter struct {
	MetricCounter
}

type Flusher 

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

type FunctionalGauge added in v0.9.3 

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

functional gauge for internal metrics

type FunctionalGaugeFloat64 added in v0.9.8 

type FunctionalGaugeFloat64 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 added in v0.9.3 

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 added in v0.9.3 

func (lh *LineHandler) FlushAll() error

func (*LineHandler) GetFailureCount 

func (lh *LineHandler) GetFailureCount() int64

func (*LineHandler) GetThrottledCount added in v0.9.5 

func (lh *LineHandler) GetThrottledCount() int64

GetThrottledCount returns the number of Throttled errors received.

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 added in v0.9.3 

type LineHandlerOption func(*LineHandler)

func SetHandlerPrefix added in v0.9.3 

func SetHandlerPrefix(prefix string) LineHandlerOption

func SetLockOnThrottledError added in v0.9.5 

func SetLockOnThrottledError(lock bool) LineHandlerOption

func SetRegistry added in v0.9.3 

func SetRegistry(registry *MetricRegistry) LineHandlerOption

type MetricCounter added in v0.9.3 

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

counter for internal metrics

func (*MetricCounter) Inc added in v0.9.8 

func (c *MetricCounter) Inc()

type MetricRegistry added in v0.9.3 

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

metric registry for internal metrics

func NewMetricRegistry added in v0.9.3 

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

func (*MetricRegistry) NewCounter added in v0.9.3 

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

func (*MetricRegistry) NewDeltaCounter added in v0.9.8 

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

func (*MetricRegistry) NewGauge added in v0.9.3 

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

func (*MetricRegistry) NewGaugeFloat64 added in v0.9.8 

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

func (*MetricRegistry) Start added in v0.9.3 

func (registry *MetricRegistry) Start()

func (*MetricRegistry) Stop added in v0.9.3 

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 added in v0.9.3 

type RegistryOption func(*MetricRegistry)

func SetInterval added in v0.9.3 

func SetInterval(interval time.Duration) RegistryOption

func SetPrefix added in v0.9.3 

func SetPrefix(prefix string) RegistryOption

func SetSource added in v0.9.3 

func SetSource(source string) RegistryOption

func SetTag added in v0.9.3 

func SetTag(key, value string) RegistryOption

func SetTags added in v0.9.3 

func SetTags(tags map[string]string) RegistryOption

type Reporter 

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

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

func NewDirectReporter 

func NewDirectReporter(server string, token string) Reporter

NewDirectReporter create a metrics Reporter

func NewReporter added in v0.9.8 

func NewReporter(server string, token string) Reporter

NewReporter create a metrics Reporter

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.