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 (*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() }
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 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
Click to show internal directories.
Click to hide internal directories.