Function New

registry/cache/cache.go:562–585

New returns a new cache.

(r registry.Registry, opts ...Option)

// New returns a new cache.
func New(r registry.Registry, opts ...Option) Cache {

	options := Options{
		TTL:                  DefaultTTL,
		MinimumRetryInterval: DefaultMinimumRetryInterval,
		Logger:               log.DefaultLogger,
	}

	for _, o := range opts {
		o(&options)
	}

	return &cache{
		Registry:           r,
		opts:               options,
		watched:            make(map[string]bool),
		watchedRunning:     make(map[string]bool),
		cache:              make(map[string][]*registry.Service),
		ttls:               make(map[string]time.Time),
		nttls:              make(map[string]map[string]time.Time),
		lastRefreshAttempt: make(map[string]time.Time),
		exit:               make(chan bool),
	}
}