etcd

package

v1.11.1 Latest Latest Go to latest Published: Oct 11, 2015 License: Apache-2.0 Imports: 8 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

Repository

github.com/RaviTezu/deis

Links

Open Source Insights

Documentation ¶

Index ¶

func AcquireLock(c *Client, key string, ttl uint64) error
func Create(c *Client, key, value string, ttl uint64)
func Get(c *Client, key string) string
func GetHTTPEtcdUrls(host, etcdPeers string) []string
func GetList(c *Client, key string) []string
func Mkdir(c *Client, path string)
func PublishService(client *Client, etcdPath string, host string, externalPort int, ttl uint64, ...)
func ReleaseLock(c *Client)
func Set(c *Client, key, value string, ttl uint64)
func SetDefault(client *Client, key, value string)
func WaitForKeys(c *Client, keys []string, ttl time.Duration) error
type Client
- func NewClient(machines []string) *Client
type Error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AcquireLock ¶

func AcquireLock(c *Client, key string, ttl uint64) error

AcquireLock creates a pseudo lock in etcd with a specific ttl

func Create ¶

func Create(c *Client, key, value string, ttl uint64)

Create set the value of a key only if it does not exits

func Get ¶

func Get(c *Client, key string) string

Get returns the value inside a key or an empty string

func GetHTTPEtcdUrls ¶

func GetHTTPEtcdUrls(host, etcdPeers string) []string

GetHTTPEtcdUrls returns an array of urls that contains at least one host

func GetList ¶

func GetList(c *Client, key string) []string

GetList returns the list of elements inside a key or an empty list

func Mkdir ¶

func Mkdir(c *Client, path string)

Mkdir creates a directory only if does not exists

func PublishService ¶

func PublishService(
	client *Client,
	etcdPath string,
	host string,
	externalPort int,
	ttl uint64,
	timeout time.Duration)

PublishService publish a service to etcd periodically

func ReleaseLock ¶

func ReleaseLock(c *Client)

ReleaseLock releases the existing lock

func Set ¶

func Set(c *Client, key, value string, ttl uint64)

Set sets the value of a key. If the ttl is bigger than 0 it will expire after the specified time

func SetDefault ¶

func SetDefault(client *Client, key, value string)

SetDefault sets the value of a key without expiration

func WaitForKeys ¶

func WaitForKeys(c *Client, keys []string, ttl time.Duration) error

WaitForKeys wait for the required keys up to the timeout or forever if is nil

Types ¶

type Client ¶

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

Client etcd client

func NewClient ¶

func NewClient(machines []string) *Client

NewClient create a etcd client using the given machine list

type Error ¶

type Error struct {
	ErrorCode int    `json:"errorCode"`
	Message   string `json:"message"`
	Cause     string `json:"cause,omitempty"`
	Index     uint64 `json:"index"`
}

Error etcd error

Source Files ¶

View all Source files

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