zookeeper

package
v0.1.0-alpha.3 Latest Latest
Warning

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

Go to latest
Published: Aug 24, 2016 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Client zookeeper.Client
	Root   string
}

Config provides the zookeeper interface and the root to namespace keys.

type Store

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

Store is implemented on top of Zookeeper.

func NewStore

func NewStore(c *Config) (*Store, error)

NewStore creates a store from the config. It provides a default root value if the zero value was set in the Config.

func (*Store) Delete

func (s *Store) Delete(name string) error

Delete removes a key from zookeeper that defines a job.

func (*Store) Get

func (s *Store) Get(name string) ([]byte, error)

Get returns the raw bytes in zookeeper for the specified job.

func (*Store) List

func (s *Store) List() ([]string, error)

List shows all job names in zookeeper.

func (*Store) Set

func (s *Store) Set(name string, b []byte) error

Set creates or overwrites the key in zookeeper with the provided name.

Jump to

Keyboard shortcuts

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