zookeeper

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Mar 16, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultConnectionTimeout = time.Second * 30

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

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