metricsgateway

package
v0.0.0-...-81a4f0c Latest Latest
Warning

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

Go to latest
Published: Dec 1, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const METRICS_FORWARDER_ORIGIN = "autoscaler_metrics_forwarder"

Variables

This section is empty.

Functions

This section is empty.

Types

type AppManager

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

func NewAppManager

func NewAppManager(logger lager.Logger, clock clock.Clock, interval time.Duration, policyDB db.PolicyDB) *AppManager

func (*AppManager) GetAppIDs

func (am *AppManager) GetAppIDs() map[string]bool

func (*AppManager) Start

func (am *AppManager) Start()

func (*AppManager) Stop

func (am *AppManager) Stop()

type Dispatcher

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

func NewDispatcher

func NewDispatcher(logger lager.Logger, envelopChan chan *loggregator_v2.Envelope, emitters []Emitter) *Dispatcher

func (*Dispatcher) Start

func (d *Dispatcher) Start()

func (*Dispatcher) Stop

func (d *Dispatcher) Stop()

type Emitter

type Emitter interface {
	Accept(envelope *loggregator_v2.Envelope)
	Emit(envelope *loggregator_v2.Envelope) error
	Start() error
	Stop()
}

func NewEnvelopeEmitter

func NewEnvelopeEmitter(logger lager.Logger, bufferSize int, eclock clock.Clock, keepAliveInterval time.Duration, wsHelper helpers.WSHelper) Emitter

type EnvelopeEmitter

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

func (*EnvelopeEmitter) Accept

func (e *EnvelopeEmitter) Accept(envelope *loggregator_v2.Envelope)

func (*EnvelopeEmitter) Emit

func (e *EnvelopeEmitter) Emit(envelope *loggregator_v2.Envelope) error

func (*EnvelopeEmitter) Start

func (e *EnvelopeEmitter) Start() error

func (*EnvelopeEmitter) Stop

func (e *EnvelopeEmitter) Stop()

type GetAppIDsFunc

type GetAppIDsFunc func() map[string]bool

type Nozzle

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

func NewNozzle

func NewNozzle(logger lager.Logger, index int, shardID string, rlpAddr string, tls *tls.Config, envelopChan chan *loggregator_v2.Envelope, getAppIDsFunc GetAppIDsFunc, envelopeCounterCollector healthendpoint.CounterCollector) *Nozzle

func (*Nozzle) Start

func (n *Nozzle) Start()

func (*Nozzle) Stop

func (n *Nozzle) Stop()

Directories

Path Synopsis
cmd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL