Instancer yields instances stored in the Eureka registry for the given app. Changes in that app are watched and will update the subscribers.
type Instancer struct {
// contains filtered or unexported fields
}
func NewInstancer(conn fargoConnection, app string, logger log.Logger) *Instancer
NewInstancer returns a Eureka Instancer. It will start watching the given app string for changes, and update the subscribers accordingly.
func (s *Instancer) Deregister(ch chan<- sd.Event)
Deregister implements Instancer.
func (s *Instancer) Register(ch chan<- sd.Event)
Register implements Instancer.
func (s *Instancer) Stop()
Stop terminates the Instancer.
Registrar maintains service instance liveness information in Eureka.
type Registrar struct {
sync.Mutex
// contains filtered or unexported fields
}
func NewRegistrar(conn fargoConnection, instance *fargo.Instance, logger log.Logger) *Registrar
NewRegistrar returns an Eureka Registrar acting on behalf of the provided Fargo connection and instance. See the integration test for usage examples.
func (r *Registrar) Deregister()
Deregister implements sd.Registrar.
func (r *Registrar) Register()
Register implements sd.Registrar.