nozzle

type Config ¶

type Config struct {
	Logger                lager.Logger
	StatusMonitorInterval time.Duration
}

type Nozzle ¶

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

Nozzle reads events from eventsource.Source and routes events to targets by using eventrouter.Router

func New(eventSource eventsource.Source, eventRouter eventrouter.Router, config *Config) *Nozzle

func (f *Nozzle) Close() error

func (f *Nozzle) Start() error