videolabs/go-riak

Name: go-riak

Owner: Videolabs

Description: Riak protobuf client for Go

Created: 2015-04-17 02:27:04.0

Updated: 2015-05-11 22:21:51.0

Pushed: 2015-04-29 22:51:14.0

Homepage: null

Size: 192

Language: Go

GitHub Committers

User	Most Recent Commit	# Commits

Other Committers

User	Email	Most Recent Commit	# Commits

README

Go-riak

Go-riak is a Riak client for Go.
It is implemented as a small abstraction on top of Riak protocol buffer API.
Go-riak also provides a driver for pooly in order to handle multiple connections to Riak nodes.

Supported Operations

Riak 1.4

Operation | Functions ———-|——————————————— Server | ServerInfo, Ping Key-value | Get, Put, Del Bucket | GetBucket, SetBucket, ListBuckets, ListKeys Query | Index, MapRed, SearchQuery, GetMany

Riak 2.0

Operation | Functions ———-|——————————————— Server | Authenticate Bucket | ResetBucket, GetBucketType, SetBucketType Data type | DtFetch, DtUpdate Yokozuna | YokozunaIndexGet, YokozunaIndexPut, YokozunaIndexDelete, YokozunaSchemaGet, YokozunaSchemaPut

Riak 2.1

Operation | Functions ———-|——————————————— Server | BucketKeyPreflist

Build

et github.com/3XX0/go-riak

Example

age main

rt "github.com/3XX0/go-riak"
rt "github.com/3XX0/pooly"

 main() {
conf := new(pooly.ServiceConfig)
conf.Driver = riak.NewDriver()

s := pooly.NewService("riak", conf)
defer s.Close()

s.Add("10.0.0.254:8087")

c, err := s.GetConn()
if err != nil {
    panic(err)
}
info, err := riak.Client(c).ServerInfo()
if err != nil {
    panic(err)
}

println(info.String())

if err := c.Release(err, pooly.HostUp); err != nil {
    panic(err)
}