newrelic

Documentation

Index

• func Start(interupt <-chan os.Signal)
• type Collector
  • func NewCollector(r *registry.Accumulators) *Collector
  • func (c *Collector) Accumulators() *registry.Accumulators
  • func (c *Collector) Append(i accumulators.Interface)
  • func (c *Collector) Length() int
• type Harvester
  • func NewHarvester(c *Collector) *Harvester
  • func (h *Harvester) Accumulators() []accumulators.Interface
  • func (h *Harvester) Harvest()
• type NewRelic
• type Router
  • func NewRouter(f *firehose.Firehose, c *Collector) *Router
  • func (r *Router) Close()
  • func (r *Router) Start()
• type Streams

Functions

func Start

func Start(interupt <-chan os.Signal)

Start New Relic Processing

Types

type Collector

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

Collector Metrics In-Memory Store

func NewCollector

func NewCollector(r *registry.Accumulators) *Collector

NewCollector ...

func (*Collector) Accumulators

func (c *Collector) Accumulators() *registry.Accumulators

Accumulators returns pointer to slice of registered Accumulators

func (*Collector) Append

func (c *Collector) Append(i accumulators.Interface)

Append ...

func (*Collector) Length

func (c *Collector) Length() int

Length ...

type Harvester

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

Harvester ...

func NewHarvester

func NewHarvester(c *Collector) *Harvester

NewHarvester ...

func (*Harvester) Accumulators

func (h *Harvester) Accumulators() []accumulators.Interface

Accumulators return iterable list of registered Accumulators

func (*Harvester) Harvest

func (h *Harvester) Harvest()

Harvest queues processed metrics

type NewRelic

type NewRelic struct {
	App          *app.Application
	CFAppManager *cfapps.CFAppManager
	Firehose     *firehose.Firehose
	Router       *Router
	Streams      Streams
	Harvester    *Harvester
	Harvest      *time.Ticker
	Collector    *Collector
	ErrorChan    chan error
	Running      chan bool
}

NewRelic Object

type Router

type Router struct {
	App       *app.Application
	Consumer  *firehose.OneToOneEnvelope
	Streams   Streams
	Collector *Collector
	ErrorChan chan error
	// contains filtered or unexported fields
}

Router object

func NewRouter

func NewRouter(f *firehose.Firehose, c *Collector) *Router

NewRouter with Firehose

func (*Router) Close

func (r *Router) Close()

Close Router

func (*Router) Start

func (r *Router) Start()

Start Router

type Streams

type Streams map[string][]accumulators.Interface

Streams ...