From f807cc71b2d33f64f0bb8ef82a6ff51fda93042b Mon Sep 17 00:00:00 2001 From: bel Date: Wed, 26 Jun 2019 18:42:25 -0600 Subject: [PATCH] clean --- riak.go | 73 --------------------------------------------------------- 1 file changed, 73 deletions(-) delete mode 100644 riak.go diff --git a/riak.go b/riak.go deleted file mode 100644 index a0c066a..0000000 --- a/riak.go +++ /dev/null @@ -1,73 +0,0 @@ -package storage - -import ( - "errors" - - riak "github.com/basho/riak-go-client" -) - -type Riak struct { - db *riak.Client -} - -func NewRiak(addr string, addrs ...string) (*Riak, error) { - return nil, ErrNotImpl - clientOpts := &riak.NewClientOptions{ - RemoteAddresses: append(addrs, addr), - } - - db, err := riak.NewClient(clientOpts) - if err != nil { - return nil, err - } - - ok, err := db.Ping() - if !ok { - return nil, ErrCantConnect - } - - return &Riak{ - db: db, - }, err -} - -func (r *Riak) List(ns []string, limits ...string) ([]string, error) { - return nil, errors.New("not impl") -} - -func (r *Riak) Get(key string, ns ...string) ([]byte, error) { - namespace := resolveNamespace(ns) - obj := &riak.Object{} - - cmd, err := riak.NewFetchValueCommandBuilder(). - WithBucket(namespace). - WithKey(key). - Build() - if err != nil { - return nil, err - } - - err = r.db.Execute(cmd) - return obj.Value, err -} - -func (r *Riak) Set(key string, value []byte, ns ...string) error { - namespace := resolveNamespace(ns) - obj := &riak.Object{ - Value: value, - } - - cmd, err := riak.NewStoreValueCommandBuilder(). - WithBucket(namespace). - WithContent(obj). - Build() - if err != nil { - return err - } - - return r.db.Execute(cmd) -} - -func (r *Riak) Close() error { - return r.db.Stop() -}