zookeeper

Documentation

Overview

* Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. *

Index

• type Config
• type Zookeeper
  • func New(id string, cfg *Config) (*Zookeeper, error)
  • func (e *Zookeeper) Close() error
  • func (e *Zookeeper) Create(ctx context.Context, key string, value []byte, flags int32) error
  • func (e *Zookeeper) Delete(ctx context.Context, key string) error
  • func (e *Zookeeper) Exists(ctx context.Context, key string) (bool, error)
  • func (e *Zookeeper) Get(ctx context.Context, key string) ([]byte, error)
  • func (e *Zookeeper) ID() string
  • func (e *Zookeeper) IsReady(ctx context.Context) bool
  • func (e *Zookeeper) Leader() string
  • func (e *Zookeeper) LeaderChange() <-chan bool
  • func (e *Zookeeper) List(ctx context.Context, prefix string) ([]engine.Entry, error)
  • func (e *Zookeeper) Set(ctx context.Context, key string, value []byte) error
  • func (e *Zookeeper) SetleaderID(newLeaderID string)

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

If the key exists, it will be set; if not, it will be created.

func (*Zookeeper) SetleaderID

func (e *Zookeeper) SetleaderID(newLeaderID string)