Skip to content

Instantly share code, notes, and snippets.

@arobson
Created February 8, 2011 01:27
Show Gist options
  • Save arobson/815665 to your computer and use it in GitHub Desktop.
Save arobson/815665 to your computer and use it in GitHub Desktop.
A really cheesy example of how the Repository and KeyValue APIs work for Riak.
class Program
{
static void Main(string[] args)
{
Assimilate
.Core<StructureMapAdapter>()
.AddConsoleLogger<RiakService>( x => x.Info().MessageLayout( m => m.Message().Newline() ) )
.Messaging()
.Daemon( x => x.Arguments( args ).Name( "Riak Demo" ) )
.Riak( x => x.AddNode( r => r.Address( "192.168.1.100" ) ) )
.RunDaemon();
}
}
[DataContract]
public class Person
{
[DataMember(Order = 1)]
public int Id { get; set; }
[DataMember(Order = 2)]
public string FirstName { get; set; }
[DataMember(Order = 3)]
public string LastName { get; set; }
public Person() {}
public Person( int id, string firstName, string lastName )
{
Id = id;
FirstName = firstName;
LastName = lastName;
}
}
public class PersonKeyAccessor
: IKeyAccessor<Person>
{
public string GetId( Person actor )
{
return actor.Id.ToString();
}
public void SetId<TKey>( Person actor, TKey id )
{
actor.Id = int.Parse( id.ToString() );
}
}
public class RiakService : IDaemon
{
public IKeyValueStore KeyValues { get; set; }
public IRepository Repository { get; set; }
public void Start()
{
"Starting Key Value Store Demo"
.ToInfo<RiakService>();
DemoKeyValueStore();
"Starting Repository Demo"
.ToInfo<RiakService>();
DemoRepository();
}
private void DemoKeyValueStore()
{
var newPerson = new Person( 1, "First", "Person" );
"Saving new person: {0} - {1} {2}".ToInfo<RiakService>(newPerson.Id, newPerson.FirstName, newPerson.LastName);
KeyValues.Persist( newPerson.Id.ToString(), newPerson );
"Retrieving new person".ToInfo<RiakService>();
var retrieved = KeyValues.Get<Person>( "1" );
"Retrieved: {0} - {1} {2}".ToInfo<RiakService>(retrieved.Id, retrieved.FirstName, retrieved.LastName);
var additional = new Person( 2, "Second", "Person" );
"Adding another person: {0} - {1} {2}".ToInfo<RiakService>(additional.Id, additional.FirstName, additional.LastName);
"Retrieving all people".ToInfo<RiakService>();
var people = KeyValues.GetAll<Person>();
"Retrieved {0} people.".ToInfo<RiakService>(people.Count());
"Deleting people".ToInfo<RiakService>();
KeyValues.Delete<Person>( "1" );
KeyValues.Delete<Person>( "2" );
}
private void DemoRepository()
{
var people = new Person[]
{
new Person(1, "First", "Person"),
new Person(2, "Second", "Person"),
new Person(3, "Third", "Person"),
new Person(4, "Fourth", "Person"),
new Person(5, "Fifth", "Person"),
};
"Saving all 5 people".ToInfo<RiakService>();
var success = people.All( Repository.Persist );
"People were persisted {0}".ToInfo<RiakService>( success ? "successfully" : "unsuccessully" );
"Retrieving all people".ToInfo<RiakService>();
var retrieved = Repository.GetAll<Person>();
"Retrieved {0} people".ToInfo<RiakService>( retrieved.Count() );
"Deleting all the people".ToInfo<RiakService>();
success = people.All( Repository.Delete );
"People were persisted {0}".ToInfo<RiakService>(success ? "successfully" : "unsuccessully");
}
public void Stop()
{
}
public RiakService( IKeyValueStore keyValues, IRepository repository )
{
KeyValues = keyValues;
Repository = repository;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment