route_fetcher

Documentation

Index

• Constants
• type RouteFetcher
  • func NewRouteFetcher(logger logger.Logger, uaaClient uaa_client.Client, ...) *RouteFetcher
  • func (r *RouteFetcher) FetchRoutes() error
  • func (r *RouteFetcher) HandleEvent(e routing_api.Event)
  • func (r *RouteFetcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Constants

const (
	TokenFetchErrors      = "token_fetch_errors"
	SubscribeEventsErrors = "subscribe_events_errors"
)

Types

type RouteFetcher

type RouteFetcher struct {
	UaaClient                          uaa_client.Client
	RouteRegistry                      registry.Registry
	FetchRoutesInterval                time.Duration
	SubscriptionRetryIntervalInSeconds int
	// contains filtered or unexported fields
}

func NewRouteFetcher

func NewRouteFetcher(logger logger.Logger, uaaClient uaa_client.Client, routeRegistry registry.Registry,
	cfg *config.Config, client routing_api.Client, subscriptionRetryInterval int, clock clock.Clock) *RouteFetcher

func (*RouteFetcher) FetchRoutes

func (r *RouteFetcher) FetchRoutes() error

func (*RouteFetcher) HandleEvent

func (r *RouteFetcher) HandleEvent(e routing_api.Event)

func (*RouteFetcher) Run

func (r *RouteFetcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error