54
logger log.Logger,
55
staleTTL dynamicconfig.DurationPropertyFn,
57
>
r := &CachingRedirector[C]{
58
>
connections: connections,
59
>
historyServiceResolver: historyServiceResolver,
60
>
logger: logger,
61
>
membershipUpdateCh: make(chan *membership.ChangedEvent, 1),
62
>
staleTTL: staleTTL,
63
>
listenerName: fmt.Sprintf("cachingRedirectorListener-%s", uuid.New().String()),
64
>
}
65
>
r.mu.cache = make(map[int32]cacheEntry[C])
66
>
67
>
r.goros.Go(r.eventLoop)
68
>
69
>
return r
70
>
}
71
73
>
r.goros.Cancel()
74
>
r.goros.Wait()
75
>
}
76
77
func (r *CachingRedirector[C]) Close() {