discoverypool

Documentation

Index

• type Pool
  • func New(svcInfo topology.IDAddrMap) (*Pool, error)
  • func (p *Pool) Choose() (discovery.InstanceInfo, error)
  • func (p *Pool) Update(svcInfo topology.IDAddrMap) error

Types

type Pool

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

Pool maps discovery service instances to their info.

func New

func New(svcInfo topology.IDAddrMap) (*Pool, error)

New populates the pool with discovery service instances from the map in svcInfo. At least one instance must be present.

func (*Pool) Choose

func (p *Pool) Choose() (discovery.InstanceInfo, error)

Choose returns the info for the discovery service instance with the minimal fail count in the pool.

func (*Pool) Update

func (p *Pool) Update(svcInfo topology.IDAddrMap) error

Update adds missing instances and removes instances which are no longer in the topology.