dvzoo

package

v1.0.2 Latest Latest Go to latest Published: Jun 1, 2024 License: MIT Imports: 11 Imported by: 1

Details

View Source

const (
	ZooSysFolder     = "/zookeeper"
	ZooSysFolderPref = "/zookeeper/"
)

This section is empty.

func DeleteWholeFolder(conn *zk.Conn, path string, version int32, includeSys bool) (err error)

func EnsureZooPath(conn *zk.Conn, path string, version int32, defValue string) (string, int32, error)

func EnsureZooPathValue(conn *zk.Conn, path string, version int32, defValue string) (string, error)

func GetZooConnect() (*zk.Conn, error)

func LeaveZooConnect(zkConn *zk.Conn)

TODO provide the mechanism for caching connections

func ReadWholeFolder(conn *zk.Conn, path string, includeSys bool, includeErr bool, fullPath bool) (r *dvevaluation.DvVariable, err error)

func SaveWholeFolder(conn *zk.Conn, path string, r *dvevaluation.DvVariable, version int32, includeSys bool) (err error)

type ZooActionProvider struct{}

func (provider *ZooActionProvider) Delete(ctx *dvcontext.RequestContext, prefix string, key string) error

func (provider *ZooActionProvider) PathSupported() bool

func (provider *ZooActionProvider) Read(ctx *dvcontext.RequestContext, prefix string, key string) (interface{}, bool, error)

func (provider *ZooActionProvider) Save(ctx *dvcontext.RequestContext, prefix string, key string, value interface{}) error

type ZooFolderActionProvider struct{}

func (provider *ZooFolderActionProvider) Delete(ctx *dvcontext.RequestContext, prefix string, key string) error

func (provider *ZooFolderActionProvider) PathSupported() bool

func (provider *ZooFolderActionProvider) Read(ctx *dvcontext.RequestContext, prefix string, key string) (interface{}, bool, error)

func (provider *ZooFolderActionProvider) Save(ctx *dvcontext.RequestContext, prefix string, key string, value interface{}) error