Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.