zookeeper

package
v0.0.0-...-6976cfd Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 3, 2016 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

package zookeeper contains definition of discovery logic to announce rpc instances in zookeeper and resolve them.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Chroot

func Chroot(chroot string) func(z *zookeeperAnnounceResolver)

Chroot option configure zookeeper path chroot, default "nano-services".

func New

func New(endpoints []string, options ...func(z *zookeeperAnnounceResolver)) discovery.AnnounceResolver

New creates a AnnounceResolver for zookeeper.

func Perms

func Perms(perms int32) func(z *zookeeperAnnounceResolver)

Perms option configure zookeeper path permission, default to open for all.

func Serializer

func Serializer(serial serializer.Serializer) func(z *zookeeperAnnounceResolver)

Serializer option configure serializer to use when reading values instance data from zookeeper, default to json serializer.

func Timeout

func Timeout(timeout time.Duration) func(z *zookeeperAnnounceResolver)

Timeout option configure connection timeout to zookeeper, default 3 seconds.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL