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
	SubscriptionRetryInterval time.Duration
	// 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 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)

func (*RouteFetcher) Run

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