Simple RIAK and C# Example

Install It:

• Have a linux box somewhere. i spun up a new centos 7.0 droplet on digital ocean for 5 bucks and turned it off when i was done with it.
• http://docs.basho.com/riak/latest/ops/building/installing/rhel-centos/
  • Basically, I logged into my new machine and ran:
  • sudo yum install http://yum.basho.com/gpg/basho-release-5-1.noarch.rpm
  • sudo yum install riak
• If you want this to be available outside of your machine, you need to modify the ip address riak is bound to.
  • If you were logged in as root, go to the /etc/riak folder and edit the app.config
  • Modify the “http” area to have your public ip address as well as the ‘PB’ area up top.
• Run “riak start” to start up riak
• Check http://:8098/riak/status should return some json

Use it:

• Open LINQpad (or whatever you want)
• NuGet search for riak
• Install CorrugatedIron
• Create a app.config file that is something like this:

<configuration> 
<configSections> 
    <section name="riakConfig" type="CorrugatedIron.Config.RiakClusterConfiguration, CorrugatedIron"/> 
</configSections> 
<riakConfig nodePollTime="5000" defaultRetryWaitTime="200" defaultRetryCount="3"> 
    <nodes> 
        <node name="mynodename" hostAddress="actualnodeaddress" pbcPort="8087" restPort="8098" poolSize="0" /> 
    </nodes> 
</riakConfig> 
</configuration>

Note: I think this file can be named anything really, I actually called it riak.config and included a path down below.

• try some c# code like this:

  void Main() {
      //config file location
      var fl = @"path to my app.config";
      //name of the config section in the config file above
      var cs = "riakConfig";
      //name of our riak bucket to store things in
      var b = "mybucket";
      //connect to the cluster using our config file
      var clst = RiakCluster.FromConfig(cs,fl);
      //create a client
      var clnt = clst.CreateClient();
      //create an object to store
      var kvp = new KeyValuePair<string,string>("0","zero");
      //put it in a bucket in riak, key it, and drop the object in there
      var o = new RiakObject(b,kvp.Key, kvp);
      //put the object in riak
      clnt.Put(o);
      //go get the object using the same key as above
      var r = clnt.Get(b,kvp.Key);
      //dump the value we got back
      r.Value.GetObject<KeyValuePair<string,string>>().Dump();
  }