cache

Documentation

Index

• type Cache
  • func New(discovery api.ServiceDiscovery, pollInterval time.Duration) (*Cache, error)
  • func (c *Cache) ListInstances() ([]*api.ServiceInstance, error)
  • func (c *Cache) ListServiceInstances(serviceName string) ([]*api.ServiceInstance, error)
  • func (c *Cache) ListServices() ([]string, error)

Types

type Cache

type Cache struct {
	// contains filtered or unexported fields
}

Cache implements the ServiceDiscovery interface using a local cache. The cache is refreshed periodically using the provided ServiceDiscovery object.

func New

func New(discovery api.ServiceDiscovery, pollInterval time.Duration) (*Cache, error)

New constructs a new Cache. The cache is refreshed at the frequency specified by pollInterval using the provided ServiceDiscovery object.

func (*Cache) ListInstances

func (c *Cache) ListInstances() ([]*api.ServiceInstance, error)

ListInstances queries for the list of service instances currently registered.

func (*Cache) ListServiceInstances

func (c *Cache) ListServiceInstances(serviceName string) ([]*api.ServiceInstance, error)

ListServiceInstances queries for the list of service instances currently registered for the given service.

func (*Cache) ListServices

func (c *Cache) ListServices() ([]string, error)

ListServices queries for the list of services for which instances are currently registered.