zookeeper

package

v1.2.0 Latest Latest Go to latest Published: Oct 2, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apache/kvrocks-controller

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
type Zookeeper
- func New(id string, cfg *Config) (*Zookeeper, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Addrs     []string `yaml:"addrs"`
	Scheme    string   `yaml:"scheme"`
	Auth      string   `yaml:"auth"`
	ElectPath string   `yaml:"elect_path"`
}

type Zookeeper ¶

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

func New ¶

func New(id string, cfg *Config) (*Zookeeper, error)

func (*Zookeeper) Close ¶

func (e *Zookeeper) Close() error

func (*Zookeeper) Create ¶

func (e *Zookeeper) Create(ctx context.Context, key string, value []byte, flags int32) error

func (*Zookeeper) Delete ¶

func (e *Zookeeper) Delete(ctx context.Context, key string) error

func (*Zookeeper) Exists ¶

func (e *Zookeeper) Exists(ctx context.Context, key string) (bool, error)

func (*Zookeeper) Get ¶

func (e *Zookeeper) Get(ctx context.Context, key string) ([]byte, error)

func (*Zookeeper) ID ¶

func (e *Zookeeper) ID() string

func (*Zookeeper) IsReady ¶

func (e *Zookeeper) IsReady(ctx context.Context) bool

func (*Zookeeper) Leader ¶

func (e *Zookeeper) Leader() string

func (*Zookeeper) LeaderChange ¶

func (e *Zookeeper) LeaderChange() <-chan bool

func (*Zookeeper) List ¶

func (e *Zookeeper) List(ctx context.Context, prefix string) ([]engine.Entry, error)

func (*Zookeeper) Set ¶

func (e *Zookeeper) Set(ctx context.Context, key string, value []byte) error

Set sets the value for the key. If the key exists, it will be set; if not, it will be created.

func (*Zookeeper) SetleaderID ¶

func (e *Zookeeper) SetleaderID(newLeaderID string)

Source Files ¶

View all Source files

zookeeper.go

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