Documentation
¶
Index ¶
Constants ¶
View Source
const ( TokenFetchErrors = "token_fetch_errors" SubscribeEventsErrors = "subscribe_events_errors" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RouteFetcher ¶
type RouteFetcher struct {
UaaTokenFetcher uaaclient.TokenFetcher
RouteRegistry registry.Registry
FetchRoutesInterval time.Duration
SubscriptionRetryInterval time.Duration
// contains filtered or unexported fields
}
func NewRouteFetcher ¶
func NewRouteFetcher( logger *slog.Logger, uaaTokenFetcher uaaclient.TokenFetcher, routeRegistry registry.Registry, cfg *config.Config, client routing_api.Client, subscriptionRetryInterval time.Duration, clock clock.Clock, ) *RouteFetcher
func (*RouteFetcher) FetchRoutes ¶
func (r *RouteFetcher) FetchRoutes() error
func (*RouteFetcher) HandleEvent ¶
func (r *RouteFetcher) HandleEvent(e routing_api.Event)
Click to show internal directories.
Click to hide internal directories.