This repository has been archived by the owner on Sep 23, 2018. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 19
/
api.go
58 lines (48 loc) · 1.72 KB
/
api.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package curator
import (
"github.com/samuel/go-zookeeper/zk"
)
var (
ErrConnectionClosed = zk.ErrConnectionClosed
ErrUnknown = zk.ErrUnknown
ErrAPIError = zk.ErrAPIError
ErrNoNode = zk.ErrNoNode
ErrNoAuth = zk.ErrNoAuth
ErrBadVersion = zk.ErrBadVersion
ErrNoChildrenForEphemerals = zk.ErrNoChildrenForEphemerals
ErrNodeExists = zk.ErrNodeExists
ErrNotEmpty = zk.ErrNotEmpty
ErrSessionExpired = zk.ErrSessionExpired
ErrInvalidACL = zk.ErrInvalidACL
ErrAuthFailed = zk.ErrAuthFailed
ErrClosing = zk.ErrClosing
ErrNothing = zk.ErrNothing
ErrSessionMoved = zk.ErrSessionMoved
)
var (
EventNodeCreated = zk.EventNodeCreated
EventNodeDeleted = zk.EventNodeDeleted
EventNodeDataChanged = zk.EventNodeDataChanged
EventNodeChildrenChanged = zk.EventNodeChildrenChanged
)
const AnyVersion int32 = -1
type CreateMode int32
const (
PERSISTENT CreateMode = 0
PERSISTENT_SEQUENTIAL = zk.FlagSequence
EPHEMERAL = zk.FlagEphemeral
EPHEMERAL_SEQUENTIAL = zk.FlagEphemeral + zk.FlagSequence
)
func (m CreateMode) IsSequential() bool { return (m & zk.FlagSequence) == zk.FlagSequence }
func (m CreateMode) IsEphemeral() bool { return (m & zk.FlagEphemeral) == zk.FlagEphemeral }
// Called when the async background operation completes
type BackgroundCallback func(client CuratorFramework, event CuratorEvent) error
type backgrounding struct {
inBackground bool
context interface{}
callback BackgroundCallback
}
type watching struct {
watcher Watcher
watched bool
}