wavefront

Documentation

Index

• type Server
  • func NewWavefrontAdapter(addr string) (Server, error)
• type WavefrontAdapter
  • func (wa *WavefrontAdapter) Addr() string
  • func (wa *WavefrontAdapter) Close() error
  • func (wa *WavefrontAdapter) HandleMetric(ctx context.Context, r *metric.HandleMetricRequest) (*v1beta1.ReportResult, error)
  • func (wa *WavefrontAdapter) Run(shutdown chan error)

Types

type Server

type Server interface {
	Addr() string
	Close() error
	Run(shutdown chan error)
}

Server is basic server interface

func NewWavefrontAdapter

func NewWavefrontAdapter(addr string) (Server, error)

NewWavefrontAdapter creates a new Wavefront adapter that listens at provided port.

type WavefrontAdapter

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

WavefrontAdapter supports metric template.

func (*WavefrontAdapter) Addr

func (wa *WavefrontAdapter) Addr() string

Addr returns the listening address of the server.

func (*WavefrontAdapter) Close

func (wa *WavefrontAdapter) Close() error

Close gracefully shuts down the server; used for testing.

func (*WavefrontAdapter) HandleMetric

func (wa *WavefrontAdapter) HandleMetric(ctx context.Context, r *metric.HandleMetricRequest) (*v1beta1.ReportResult, error)

HandleMetric records metric entries.

func (*WavefrontAdapter) Run

func (wa *WavefrontAdapter) Run(shutdown chan error)

Run starts the server run.