zookeeper

Documentation

Index

• Constants
• Variables
• func Ignore(path string) bool
• type PathCache
  • func NewPathCache(conn *zk.Conn, path string, owner string, isSvcPath bool, autoFillNode bool) (*PathCache, error)
  • func (p *PathCache) Events() <-chan PathCacheEvent
  • func (p *PathCache) Stop()
• type PathCacheEvent
• type PathCacheEventType

Constants

const (
	PermRead = 1 << iota
	PermWrite
	PermCreate
	PermDelete
	PermAdmin
	PermAll = 0x1f
)

Constants for ACL permissions

Variables

var (
	DubboRootPath    = "/dubbo"
	ProvidersPath    = "providers"
	ConsumersPath    = "consumers"
	IgnoredHostNames = []string{"metadata", "config"}
	ConfiguratorPath = DubboRootPath + "/config/dubbo"
)

Some default settings.

Functions

func Ignore

func Ignore(path string) bool

Ignore ...

Types

type PathCache

type PathCache struct {
	Path   string
	Cached map[string]bool
	// contains filtered or unexported fields
}

PathCache ...

func NewPathCache

func NewPathCache(conn *zk.Conn, path string, owner string, isSvcPath bool, autoFillNode bool) (*PathCache, error)

NewPathCache we need a cache manager for a given path, In some scenario it probably creates plenty of PathCaches by a registry client.

func (*PathCache) Events

func (p *PathCache) Events() <-chan PathCacheEvent

Events ...

func (*PathCache) Stop

func (p *PathCache) Stop()

Stop ...

type PathCacheEvent

type PathCacheEvent struct {
	EventType PathCacheEventType
	Path      string
	Paths     []string
}

PathCacheEvent ...

type PathCacheEventType

type PathCacheEventType int

PathCacheEventType ...

const (
	PathCacheEventAdded PathCacheEventType = iota
	PathCacheEventDeleted
	PathCacheEventChanged
	PathCacheEventChildrenReplaced
)

Enumeration of PathCacheEventType