dao

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 24, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IRedisDao

type IRedisDao interface {
	ExecRedisCommand(command string, args ...interface{}) (interface{}, error)
	SendRedisPipeliningCommand(args [][]interface{}) error
	SendScriptCommand(keyCount int, src string, args ...interface{}) (interface{}, error)
}
var RedisDao IRedisDao

func InitRedisDao

func InitRedisDao(conf config.RedisConfig) IRedisDao

func NewRedisDao

func NewRedisDao() IRedisDao

type IZkDao

type IZkDao interface {
	WatchChildNode(path string) (<-chan zk.Event, error)
	GetChildrenNode(path string) ([]string, error)
	Get(path string) ([]byte, *zk.Stat, error)
	Set(path string, data []byte, version int32) (bool, error)
	Exists(path string) (bool, *zk.Stat, error)
	Lock(path string) error
	Unlock(path string) error
	EnsureNode(path string) error
	Create(path string, data []byte, flags int32) (string, error)
	Delete(path string, version int32) error
	Close()
}
var ZkDao IZkDao

func NewZkDao

func NewZkDao(host string, sessionTimeOut int) IZkDao

func ZkDaoInit

func ZkDaoInit(host string, sessionTimeOut int) IZkDao

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL