zk

Documentation

Overview

Package zk encapsulates our interactions with ZooKeeper.

Index

• Constants
• type Client
  • func NewClient(zkquorum string, st time.Duration, ...) Client
• type ResourceName
  • func (r ResourceName) Prepend(prefix string) ResourceName

Constants

const (
	// Meta is a ResourceName that indicates that the location of the Meta
	// table is what will be fetched
	Meta = ResourceName("/meta-region-server")

	// Master is a ResourceName that indicates that the location of the Master
	// server is what will be fetched
	Master = ResourceName("/master")
)

Types

type Client

type Client interface {
	LocateResource(ResourceName) (string, error)
}

Client is an interface of client that retrieves meta infomation from zookeeper

func NewClient

func NewClient(zkquorum string, st time.Duration,
	dialer func(ctx context.Context, network, addr string) (net.Conn, error),
	slogger *slog.Logger) Client

NewClient establishes connection to zookeeper and returns the client

type ResourceName

type ResourceName string

ResourceName is a type alias that is used to represent different resources in ZooKeeper

func (ResourceName) Prepend

func (r ResourceName) Prepend(prefix string) ResourceName

Prepend creates a new ResourceName with prefix prepended to the former ResourceName.