54 lines
1.5 KiB
Go
54 lines
1.5 KiB
Go
|
package zkhelper
|
||
|
|
|
||
|
|
import (
|
||
|
|
zk "github.com/ngaut/go-zookeeper/zk"
|
||
|
|
)
|
||
|
|
|
||
|
|
/*
|
||
|
|
type Stat interface {
|
||
|
|
Czxid() int64
|
||
|
|
Mzxid() int64
|
||
|
|
CTime() time.Time
|
||
|
|
MTime() time.Time
|
||
|
|
Version() int
|
||
|
|
CVersion() int
|
||
|
|
AVersion() int
|
||
|
|
EphemeralOwner() int64
|
||
|
|
DataLength() int
|
||
|
|
NumChildren() int
|
||
|
|
Pzxid() int64
|
||
|
|
}
|
||
|
|
*/
|
||
|
|
|
||
|
|
// This interface is really close to the zookeeper connection
|
||
|
|
// interface. It uses the Stat interface defined here instead of the
|
||
|
|
// zookeeper.Stat structure for stats. Everything else is the same as
|
||
|
|
// in zookeeper. So refer to the zookeeper docs for the conventions
|
||
|
|
// used here (for instance, using -1 as version to specify any
|
||
|
|
// version)
|
||
|
|
type Conn interface {
|
||
|
|
Get(path string) (data []byte, stat zk.Stat, err error)
|
||
|
|
GetW(path string) (data []byte, stat zk.Stat, watch <-chan zk.Event, err error)
|
||
|
|
|
||
|
|
Children(path string) (children []string, stat zk.Stat, err error)
|
||
|
|
ChildrenW(path string) (children []string, stat zk.Stat, watch <-chan zk.Event, err error)
|
||
|
|
|
||
|
|
Exists(path string) (exist bool, stat zk.Stat, err error)
|
||
|
|
ExistsW(path string) (exist bool, stat zk.Stat, watch <-chan zk.Event, err error)
|
||
|
|
|
||
|
|
Create(path string, value []byte, flags int32, aclv []zk.ACL) (pathCreated string, err error)
|
||
|
|
|
||
|
|
Set(path string, value []byte, version int32) (stat zk.Stat, err error)
|
||
|
|
|
||
|
|
Delete(path string, version int32) (err error)
|
||
|
|
|
||
|
|
Close()
|
||
|
|
|
||
|
|
//RetryChange(path string, flags int, acl []ACL, changeFunc ChangeFunc) error
|
||
|
|
|
||
|
|
GetACL(path string) ([]zk.ACL, zk.Stat, error)
|
||
|
|
SetACL(path string, aclv []zk.ACL, version int32) (zk.Stat, error)
|
||
|
|
|
||
|
|
Seq2Str(seq int64) string
|
||
|
|
}
|