zkctl

Documentation

Index

• Constants
• func MakeZooCfg(cnfFiles []string, cnf *ZkConfig, header string) (string, error)
• type ZkConfig
  • func MakeZkConfigFromString(cmdLine string, myId uint32) *ZkConfig
  • func NewZkConfig() *ZkConfig
  • func (cnf *ZkConfig) ConfigFile() string
  • func (cnf *ZkConfig) DataDir() string
  • func (cnf *ZkConfig) DirectoryList() []string
  • func (cnf *ZkConfig) LogDir() string
  • func (cnf *ZkConfig) MyidFile() string
  • func (cnf *ZkConfig) PidFile() string
  • func (cnf *ZkConfig) WriteMyid() error
• type Zkd
  • func NewZkd(config *ZkConfig) *Zkd
  • func (zkd *Zkd) CheckProcess() error
  • func (zkd *Zkd) ConfigChanged() (bool, error)
  • func (zkd *Zkd) Done() <-chan struct{}
  • func (zkd *Zkd) Init() error
  • func (zkd *Zkd) Inited() bool
  • func (zkd *Zkd) LocalClientAddr() string
  • func (zkd *Zkd) Reinit(preserveData bool) (err error)
  • func (zkd *Zkd) Shutdown() error
  • func (zkd *Zkd) Start() error
  • func (zkd *Zkd) Teardown() error

Constants

const (
	StartWaitTime    = 20 // number of seconds to wait at Start
	ShutdownWaitTime = 20 // number of seconds to wait at Shutdown
)

const GUESS_MYID = 0

Functions

func MakeZooCfg

func MakeZooCfg(cnfFiles []string, cnf *ZkConfig, header string) (string, error)

Search for first existing file in cnfFiles and subsitute in the right values.

Types

type ZkConfig

type ZkConfig struct {
	ServerId   uint32
	ClientPort int
	Servers    []zkServerAddr
	Global     bool
}

func MakeZkConfigFromString

func MakeZkConfigFromString(cmdLine string, myId uint32) *ZkConfig

Create a config for this instance.

<server_id>@<hostname>:<leader_port>:<election_port>:<client_port>

If server_id > 1000, then we assume this is a global quorum. server_id's must be 1-255, global id's are 1001-1255 mod 1000.

func NewZkConfig

func NewZkConfig() *ZkConfig

ServerId is a unique id for a server - must be 1-255

func (*ZkConfig) ConfigFile

func (cnf *ZkConfig) ConfigFile() string

func (*ZkConfig) DataDir

func (cnf *ZkConfig) DataDir() string

func (*ZkConfig) DirectoryList

func (cnf *ZkConfig) DirectoryList() []string

func (*ZkConfig) LogDir

func (cnf *ZkConfig) LogDir() string

func (*ZkConfig) MyidFile

func (cnf *ZkConfig) MyidFile() string

func (*ZkConfig) PidFile

func (cnf *ZkConfig) PidFile() string

func (*ZkConfig) WriteMyid

func (cnf *ZkConfig) WriteMyid() error

type Zkd

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

func NewZkd

func NewZkd(config *ZkConfig) *Zkd

func (*Zkd) CheckProcess

func (zkd *Zkd) CheckProcess() error

func (*Zkd) ConfigChanged

func (zkd *Zkd) ConfigChanged() (bool, error)

func (*Zkd) Done

func (zkd *Zkd) Done() <-chan struct{}

Done returns a channel that is closed when the underlying process started by this Zkd has terminated. If the process was started by someone else, this channel will never be closed.

func (*Zkd) Init

func (zkd *Zkd) Init() error

func (*Zkd) Inited

func (zkd *Zkd) Inited() bool

func (*Zkd) LocalClientAddr

func (zkd *Zkd) LocalClientAddr() string

func (*Zkd) Reinit

func (zkd *Zkd) Reinit(preserveData bool) (err error)

func (*Zkd) Shutdown

func (zkd *Zkd) Shutdown() error

func (*Zkd) Start

func (zkd *Zkd) Start() error

ZOO_LOG_DIR="" ZOO_CFG="/.../zoo.cfg" ZOOMAIN="org.apache.zookeeper.server.quorum.QuorumPeerMain" java -DZOO_LOG_DIR=${ZOO_LOG_DIR} -cp $CLASSPATH $ZOOMAIN $YT_ZK_CFG

func (*Zkd) Teardown

func (zkd *Zkd) Teardown() error