kit: Index | Files | Directories

package sd

import ""

Package sd provides utilities related to service discovery. That includes the client-side loadbalancer pattern, where a microservice subscribes to a service discovery system in order to reach remote instances; as well as the registrator pattern, where a microservice registers itself in a service discovery system. Implementations are provided for most common systems.


Package Files

doc.go factory.go fixed_subscriber.go registrar.go subscriber.go

type Factory Uses

type Factory func(instance string) (endpoint.Endpoint, io.Closer, error)

Factory is a function that converts an instance string (e.g. host:port) to a specific endpoint. Instances that provide multiple endpoints require multiple factories. A factory also returns an io.Closer that's invoked when the instance goes away and needs to be cleaned up. Factories may return nil closers.

Users are expected to provide their own factory functions that assume specific transports, or can deduce transports by parsing the instance string.

type FixedSubscriber Uses

type FixedSubscriber []endpoint.Endpoint

FixedSubscriber yields a fixed set of services.

func (FixedSubscriber) Endpoints Uses

func (s FixedSubscriber) Endpoints() ([]endpoint.Endpoint, error)

Endpoints implements Subscriber.

type Registrar Uses

type Registrar interface {

Registrar registers instance information to a service discovery system when an instance becomes alive and healthy, and deregisters that information when the service becomes unhealthy or goes away.

Registrar implementations exist for various service discovery systems. Note that identifying instance information (e.g. host:port) must be given via the concrete constructor; this interface merely signals lifecycle changes.

type Subscriber Uses

type Subscriber interface {
    Endpoints() ([]endpoint.Endpoint, error)

Subscriber listens to a service discovery system and yields a set of identical endpoints on demand. An error indicates a problem with connectivity to the service discovery system, or within the system itself; a subscriber may yield no endpoints without error.


consulPackage consul provides subscriber and registrar implementations for Consul.
dnssrvPackage dnssrv provides a subscriber implementation for DNS SRV records.
etcdPackage etcd provides a Subscriber and Registrar implementation for etcd.
eurekaPackage eureka provides subscriber and registrar implementations for Netflix OSS's Eureka
lbPackage lb implements the client-side load balancer pattern.
zkPackage zk provides subscriber and registrar implementations for ZooKeeper.

Package sd imports 2 packages (graph) and is imported by 29 packages. Updated 2017-04-10. Refresh now. Tools for package owners.