kvengine

package

v0.0.0-...-b83a8b2 Latest Latest Go to latest Published: Apr 8, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	Endp    = "127.0.0.1:2379"
	Timeout = 5 * time.Second
)

View Source

const (
	Addr   = "127.0.0.1:6379"
	Passwd = ""
)

View Source

var (
	ENotFound = errors.New("not found")
)

func IsENotFound(err error) bool

type Iterator interface {
	Valid() bool
	Key() string
	Value() string
	Next() error
	Close()
}

type KVEngine interface {
	Close() error
	Set(key string, value []byte) error
	Get(key string) ([]byte, error)
	Delete(key string) error
}

type KVEngineEtcd struct {
	// contains filtered or unexported fields
}

func NewETCDKV() *KVEngineEtcd

func (kv *KVEngineEtcd) Close() error

func (kv *KVEngineEtcd) Delete(key string) error

func (kv *KVEngineEtcd) Get(key string) ([]byte, error)

func (kv *KVEngineEtcd) Set(key string, value []byte) error

func (kv *KVEngineEtcd) Watch(prefix string)

type KVEngineRedis struct {
	// contains filtered or unexported fields
}

func NewRedisKV() *KVEngineRedis

func (kv *KVEngineRedis) Close() error

func (kv *KVEngineRedis) Delete(key string) error

func (kv *KVEngineRedis) Get(key string) ([]byte, error)

func (kv *KVEngineRedis) Set(key string, value []byte) error