cache

Documentation

Index

• type ServiceCache
  • func New(s discoverd.Service) (*ServiceCache, error)
  • func (d *ServiceCache) Addrs() []string
  • func (d *ServiceCache) Close() error
  • func (d *ServiceCache) Instances() []*discoverd.Instance
  • func (d *ServiceCache) Leader() []*discoverd.Instance
  • func (d *ServiceCache) LeaderAddr() []string
  • func (d *ServiceCache) Watch(ch chan *discoverd.Event, current bool) stream.Stream

Types

type ServiceCache

type ServiceCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(s discoverd.Service) (*ServiceCache, error)

func (*ServiceCache) Addrs

func (d *ServiceCache) Addrs() []string

func (*ServiceCache) Close

func (d *ServiceCache) Close() error

func (*ServiceCache) Instances

func (d *ServiceCache) Instances() []*discoverd.Instance

func (*ServiceCache) Leader

func (d *ServiceCache) Leader() []*discoverd.Instance

func (*ServiceCache) LeaderAddr

func (d *ServiceCache) LeaderAddr() []string

func (*ServiceCache) Watch

func (d *ServiceCache) Watch(ch chan *discoverd.Event, current bool) stream.Stream