wavefront

Documentation

Index

• type Listener
  • func NewListener(sendTo dpsink.Sink, passedConf *ListenerConfig) (*Listener, error)
  • func (listener *Listener) Addr() net.Addr
  • func (listener *Listener) Close() error
  • func (listener *Listener) Datapoints() []*datapoint.Datapoint
  • func (listener *Listener) DebugDatapoints() []*datapoint.Datapoint
  • func (listener *Listener) DefaultDatapoints() []*datapoint.Datapoint
• type ListenerConfig

Types

type Listener

type Listener struct {
	protocol.CloseableHealthCheck
	// contains filtered or unexported fields
}

Listener once setup will listen for wavefront protocol points to forward on

func NewListener

func NewListener(sendTo dpsink.Sink, passedConf *ListenerConfig) (*Listener, error)

NewListener creates a new listener for wavefront datapoints

func (*Listener) Addr

func (listener *Listener) Addr() net.Addr

Addr returns the listening address of this wavefront listener

func (*Listener) Close

func (listener *Listener) Close() error

Close the exposed wavefront port

func (*Listener) Datapoints

func (listener *Listener) Datapoints() []*datapoint.Datapoint

Datapoints reports information about the total points seen by wavefront

func (*Listener) DebugDatapoints

func (listener *Listener) DebugDatapoints() []*datapoint.Datapoint

DebugDatapoints returns datapoints that are used for debugging the listener

func (*Listener) DefaultDatapoints

func (listener *Listener) DefaultDatapoints() []*datapoint.Datapoint

DefaultDatapoints returns datapoints that should always be reported from the listener

type ListenerConfig

type ListenerConfig struct {
	ServerAcceptDeadline      *time.Duration
	ConnectionTimeout         *time.Duration
	ListenAddr                *string
	Logger                    log.Logger
	ExtractCollectdDimensions *bool
}

ListenerConfig controls optional parameters for wavefront listeners