zookeeper

Documentation

Index

• type Config
• type Store
  • func NewStore(c *Config) (*Store, error)
  • func (s *Store) Delete(name string) error
  • func (s *Store) Get(name string) ([]byte, error)
  • func (s *Store) List() ([]string, error)
  • func (s *Store) Set(name string, b []byte) error

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.