kvengine

Documentation

Index

• Constants
• Variables
• func IsENotFound(err error) bool
• type Iterator
• type KVEngine
• type KVEngineEtcd
  • 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
  • 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

Constants

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

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

Variables

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

Functions

func IsENotFound

func IsENotFound(err error) bool

Types

type Iterator

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

type KVEngine

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

type KVEngineEtcd

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

func NewETCDKV

func NewETCDKV() *KVEngineEtcd

func (*KVEngineEtcd) Close

func (kv *KVEngineEtcd) Close() error

func (*KVEngineEtcd) Delete

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

func (*KVEngineEtcd) Get

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

func (*KVEngineEtcd) Set

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

func (*KVEngineEtcd) Watch

func (kv *KVEngineEtcd) Watch(prefix string)

type KVEngineRedis

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

func NewRedisKV

func NewRedisKV() *KVEngineRedis

func (*KVEngineRedis) Close

func (kv *KVEngineRedis) Close() error

func (*KVEngineRedis) Delete

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

func (*KVEngineRedis) Get

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

func (*KVEngineRedis) Set

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