storage

Documentation

Index

• Variables
• func CloseDatabase(db *Etcd)
• func Delete(db *Etcd, key string) (*clientv3.DeleteResponse, error)
• func DeleteWithPrefix(db *Etcd, key string) (bool, error)
• func Get(db *Etcd, key string) (*clientv3.GetResponse, error)
• func GetDevCountForNodeID(db *Etcd, nodeid string) (int, error)
• func GetWithPrefix(db *Etcd, prefix string) (*clientv3.GetResponse, error)
• func Put(db *Etcd, key, val string) error
• type Etcd
  • func OpenDatabase(c *cli.Context) (*Etcd, error)

Variables

var (
	ErrAlreadyExists   = errors.New("object already exists")
	ErrDoesNotExist    = errors.New("object does not exist")
	ErrNodeInvalidName = errors.New("invalid node name")
)

errors

Functions

func CloseDatabase

func CloseDatabase(db *Etcd)

CloseDatabase close the database

func Delete

func Delete(db *Etcd, key string) (*clientv3.DeleteResponse, error)

Delete

func DeleteWithPrefix

func DeleteWithPrefix(db *Etcd, key string) (bool, error)

Delete key with prefix

func Get

func Get(db *Etcd, key string) (*clientv3.GetResponse, error)

Query key

func GetDevCountForNodeID

func GetDevCountForNodeID(db *Etcd, nodeid string) (int, error)

func GetWithPrefix

func GetWithPrefix(db *Etcd, prefix string) (*clientv3.GetResponse, error)

Query keys with Prefix

func Put

func Put(db *Etcd, key, val string) error

Write key-value

Types

type Etcd

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

func OpenDatabase

func OpenDatabase(c *cli.Context) (*Etcd, error)

OpenDatabase opens the database