zkregistry

package module

v0.1.1 Latest Latest Go to latest Published: Nov 11, 2016 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrNilConn         = errors.New("can't create registry with <nil> zk connection")
	ErrServiceNotFound = errors.New("service not found")
)

Common errors.

View Source

var ParseConfigPath = parseConfigPath

ParseConfigPath extracts name, version and endpoint from a Zookeeper event.

This section is empty.

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

ZKRegistry is an implementation of the registry with Zookeeper.

func New(conn *zk.Conn, zkPath string, logger zk.Logger) (*ZKRegistry, error)

New .

func (reg *ZKRegistry) Add(name, version, endpoint string)

Add adds the given endpoit for the service name/version.

func (reg *ZKRegistry) Close() error

Close terminates the registry.

func (reg *ZKRegistry) DeleteEndpoint(name, version, endpoint string)

DeleteEndpoint removes the given endpoit for the service name/version.

func (reg *ZKRegistry) DeleteService(name string)

DeleteService removes the given service.

func (reg *ZKRegistry) DeleteVersion(name, version string)

DeleteVersion removes the given version for the service name.

func (reg *ZKRegistry) Failure(name, version, endpoint string, err error)

Failure marks the given endpoint for service name/version as failed.

func (reg *ZKRegistry) Lookup(name, version string) ([]string, error)

Lookup return the endpoint list for the given service name/version.

func (reg *ZKRegistry) SetLogger(logger zk.Logger) *ZKRegistry

SetLogger overrides the default logger.

func (reg *ZKRegistry) String() string

String returns the json representation of the registered services. NOTE: induces a lock. You should not let users call this.