zookeeper

Documentation

Overview

Package zookeeper is a Metricbeat module for ZooKeeper servers.

Index

• func GetZookeeperEnvHost() string
• func GetZookeeperEnvPort() string
• func RunCommand(command, address string, timeout time.Duration) (io.Reader, error)

Functions

func GetZookeeperEnvHost

func GetZookeeperEnvHost() string

GetZookeeperEnvHost returns the hostname of the ZooKeeper server to use for testing. It reads the value from the ZOOKEEPER_HOST environment variable and returns localhost if it is not set.

func GetZookeeperEnvPort

func GetZookeeperEnvPort() string

GetZookeeperEnvPort returns the port of the ZooKeeper server to use for testing. It reads the value from the ZOOKEEPER_PORT environment variable and returns 2181 if it is not set.

func RunCommand

func RunCommand(command, address string, timeout time.Duration) (io.Reader, error)

RunCommand establishes a TCP connection the ZooKeeper command port that accepts the four-letter ZooKeeper commands and sends the given command. It reads all response data received on the socket and returns an io.Reader containing that data.