zk

Documentation

Index

• Constants
• func DeleteMetadata(cluster *v1alpha1.ZookeeperCluster) error
• func UpdateMetadata(cluster *v1alpha1.ZookeeperCluster) error
• type Client
  • func NewZkClient(cluster *v1alpha1.ZookeeperCluster) (*Client, error)
  • func (c *Client) Close()

Constants

const (
	// ClusterMetadataParentZNode defines the znode to store metadata for the ZookeeperCluster objects
	ClusterMetadataParentZNode = "/zookeeper/operator-cluster-metadata"
)

Functions

func DeleteMetadata

func DeleteMetadata(cluster *v1alpha1.ZookeeperCluster) error

DeleteMetadata deletes all zNodes created by the zookeeper cluster

func UpdateMetadata

func UpdateMetadata(cluster *v1alpha1.ZookeeperCluster) error

UpdateMetadata update the metadata of the specified cluster

Types

type Client

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

func NewZkClient

func NewZkClient(cluster *v1alpha1.ZookeeperCluster) (*Client, error)

NewZkClient creates a new zookeeper client connected to the specified cluster

func (*Client) Close

func (c *Client) Close()

Close closes the zookeeper connection