Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RouteHandler ¶
type RouteHandler interface {
HandleEvent(logger lager.Logger, event models.Event)
Sync(
logger lager.Logger,
desired []*models.DesiredLRP,
runningActual []*models.ActualLRP,
domains models.DomainSet,
cachedEvents map[string]models.Event,
)
EmitExternal(logger lager.Logger)
EmitInternal(logger lager.Logger)
ShouldRefreshDesired(*models.ActualLRP) bool
RefreshDesired(lager.Logger, []*models.DesiredLRP)
}
type Watcher ¶
type Watcher struct {
// contains filtered or unexported fields
}
func NewWatcher ¶
func NewWatcher( cellID string, bbsClient bbs.Client, clock clock.Clock, routeHandler RouteHandler, syncCh chan struct{}, emitExternalCh chan struct{}, emitInternalCh chan struct{}, logger lager.Logger, metronClient loggingclient.IngressClient, ) *Watcher
Click to show internal directories.
Click to hide internal directories.