registrar

Documentation

Index

• func NewNoopRoutesConfigWatcher() *noopRoutesConfigWatcher
• func NewRoutesConfigWatcher(logger lager.Logger, watchInterval time.Duration, globs []string, host string, ...) *routesConfigWatcher
• type PeriodicHealthcheckCloseChan
• type PeriodicHealthcheckCloseChans
  • func (p *PeriodicHealthcheckCloseChans) Add(route config.Route) chan struct{}
  • func (p *PeriodicHealthcheckCloseChans) CloseAll()
  • func (p *PeriodicHealthcheckCloseChans) CloseForRoute(route config.Route)
• type Registrar
  • func NewRegistrar(clientConfig config.Config, healthChecker healthchecker.HealthChecker, ...) Registrar
• type RoutesConfigSchema

Functions

func NewNoopRoutesConfigWatcher

func NewNoopRoutesConfigWatcher() *noopRoutesConfigWatcher

func NewRoutesConfigWatcher

func NewRoutesConfigWatcher(logger lager.Logger, watchInterval time.Duration, globs []string, host string, routeDiscoveredChan chan config.Route, routeRemovedChan chan config.Route) *routesConfigWatcher

Types

type PeriodicHealthcheckCloseChan

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

type PeriodicHealthcheckCloseChans

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

func (*PeriodicHealthcheckCloseChans) Add

func (p *PeriodicHealthcheckCloseChans) Add(route config.Route) chan struct{}

func (*PeriodicHealthcheckCloseChans) CloseAll

func (p *PeriodicHealthcheckCloseChans) CloseAll()

func (*PeriodicHealthcheckCloseChans) CloseForRoute

func (p *PeriodicHealthcheckCloseChans) CloseForRoute(route config.Route)

type Registrar

type Registrar interface {
	Run(signals <-chan os.Signal, ready chan<- struct{}) error
}

func NewRegistrar

func NewRegistrar(
	clientConfig config.Config,
	healthChecker healthchecker.HealthChecker,
	logger lager.Logger,
	messageBus messagebus.MessageBus,
	routingAPI api,
	dynamicConfigDiscoveryInterval time.Duration,
) Registrar

type RoutesConfigSchema

type RoutesConfigSchema struct {
	Routes []config.RouteSchema `json:"routes"`
}