route_fetcher

Documentation

Index

• Constants
• type RouteFetcher
  • func NewRouteFetcher(logger *slog.Logger, uaaTokenFetcher uaaclient.TokenFetcher, ...) *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 {
	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)

func (*RouteFetcher) Run

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