route_fetcher

Documentation

Index

• type RouteFetcher
  • func NewRouteFetcher(logger *steno.Logger, tokenFetcher token_fetcher.TokenFetcher, ...) *RouteFetcher
  • func (r *RouteFetcher) FetchRoutes() error
  • func (r *RouteFetcher) HandleEvent(e routing_api.Event) error
  • func (r *RouteFetcher) StartEventCycle()
  • func (r *RouteFetcher) StartFetchCycle()

Types

type RouteFetcher

type RouteFetcher struct {
	TokenFetcher                       token_fetcher.TokenFetcher
	RouteRegistry                      registry.RegistryInterface
	FetchRoutesInterval                time.Duration
	SubscriptionRetryIntervalInSeconds int
	// contains filtered or unexported fields
}

func NewRouteFetcher

func NewRouteFetcher(logger *steno.Logger, tokenFetcher token_fetcher.TokenFetcher, routeRegistry registry.RegistryInterface, cfg *config.Config, client routing_api.Client, subscriptionRetryInterval int) *RouteFetcher

func (*RouteFetcher) FetchRoutes

func (r *RouteFetcher) FetchRoutes() error

func (*RouteFetcher) HandleEvent

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

func (*RouteFetcher) StartEventCycle

func (r *RouteFetcher) StartEventCycle()

func (*RouteFetcher) StartFetchCycle

func (r *RouteFetcher) StartFetchCycle()