zookeeper

Documentation

Index

• Constants
• type ZKStateStore
  • func NewZKStateStore() *ZKStateStore
  • func (s *ZKStateStore) Close()
  • func (s *ZKStateStore) Configure(config core.StringMap) (err error)
  • func (s *ZKStateStore) GetType() string
  • func (s *ZKStateStore) Load(key string) (data []byte, err error)
  • func (s *ZKStateStore) Save(key string, value []byte) (err error)
• type ZKStateStoreConfig

Constants

const DefaultConnectionTimeout = time.Second * 30

Types

type ZKStateStore

type ZKStateStore struct {
	core.StateStore
	// contains filtered or unexported fields
}

func NewZKStateStore

func NewZKStateStore() *ZKStateStore

func (*ZKStateStore) Close

func (s *ZKStateStore) Close()

func (*ZKStateStore) Configure

func (s *ZKStateStore) Configure(config core.StringMap) (err error)

func (*ZKStateStore) GetType

func (s *ZKStateStore) GetType() string

func (*ZKStateStore) Load

func (s *ZKStateStore) Load(key string) (data []byte, err error)

func (*ZKStateStore) Save

func (s *ZKStateStore) Save(key string, value []byte) (err error)

type ZKStateStoreConfig

type ZKStateStoreConfig struct {
	Addresses []string
	RootPath  string
}