route_fetcher

package
v0.0.0-...-2fc2a81 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 28, 2018 License: Apache-2.0, BSD-2-Clause-Views, BSD-3-Clause, + 1 more Imports: 14 Imported by: 0

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 {
	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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.