added simple get and put commands

examples/get/.gitignore

@@ -0,0 +1 @@
+get

examples/get/get.go

@@ -0,0 +1,92 @@
+// Copyright 2013-2014 Aerospike, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package main
+
+import (
+	"flag"
+	"fmt"
+	. "github.com/aerospike/aerospike-client-go"
+	"os"
+	"strconv"
+)
+
+var (
+	host      string = "127.0.0.1"
+	port      int    = 3000
+	namespace string = "test"
+	set       string = "demo"
+)
+
+// fuck yeah
+func main() {
+
+	var err error
+
+	// arguments
+	flag.StringVar(&host, "host", host, "Remote host")
+	flag.IntVar(&port, "port", port, "Remote port")
+	flag.StringVar(&namespace, "namespace", namespace, "Namespace")
+	flag.StringVar(&set, "set", set, "Set name")
+
+	// parse flags
+	flag.Parse()
+
+	// args
+	args := flag.Args()
+
+	if len(args) < 1 {
+		printError("Missing argument")
+	}
+
+	client, err := NewClient(host, port)
+	panicOnError(err)
+
+	var key *Key = nil
+
+	skey := flag.Arg(0)
+	ikey, err := strconv.ParseInt(skey, 10, 64)
+	if err == nil {
+		key, err = NewKey(namespace, set, ikey)
+		panicOnError(err)
+	} else {
+		key, err = NewKey(namespace, set, skey)
+		panicOnError(err)
+	}
+
+	policy := NewPolicy()
+	rec, err := client.Get(policy, key)
+	panicOnError(err)
+	if rec != nil {
+		printOK("%v", rec.Bins)
+	} else {
+		printError("record not found: namespace=%s set=%s key=%v", key.Namespace(), key.SetName(), key.Value())
+	}
+}
+
+func panicOnError(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
+
+func printOK(format string, a ...interface{}) {
+	fmt.Printf("ok: "+format+"\n", a...)
+	os.Exit(0)
+}
+
+func printError(format string, a ...interface{}) {
+	fmt.Printf("error: "+format+"\n", a...)
+	os.Exit(1)
+}

examples/put/.gitignore

@@ -0,0 +1 @@
+put

examples/put/put.go

@@ -0,0 +1,108 @@
+// Copyright 2013-2014 Aerospike, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package main
+
+import (
+	"encoding/json"
+	"flag"
+	"fmt"
+	. "github.com/aerospike/aerospike-client-go"
+	"os"
+	"strconv"
+)
+
+var (
+	host      string = "127.0.0.1"
+	port      int    = 3000
+	namespace string = "test"
+	set       string = "demo"
+)
+
+// fuck yeah
+func main() {
+
+	var err error
+
+	// arguments
+	flag.StringVar(&host, "host", host, "Remote host")
+	flag.IntVar(&port, "port", port, "Remote port")
+	flag.StringVar(&namespace, "namespace", namespace, "Namespace")
+	flag.StringVar(&set, "set", set, "Set name")
+
+	// parse flags
+	flag.Parse()
+
+	// args
+	args := flag.Args()
+
+	if len(args) < 2 {
+		printError("Missing argument(s)")
+	}
+
+	client, err := NewClient(host, port)
+	panicOnError(err)
+
+	var key *Key = nil
+	var rec BinMap
+
+	skey := flag.Arg(0)
+	ikey, err := strconv.ParseInt(skey, 10, 64)
+	if err == nil {
+		key, err = NewKey(namespace, set, ikey)
+		panicOnError(err)
+	} else {
+		key, err = NewKey(namespace, set, skey)
+		panicOnError(err)
+	}
+
+	srec := flag.Arg(1)
+	json.Unmarshal([]byte(srec), &rec)
+
+	for k, v := range rec {
+		switch w := v.(type) {
+		case float64:
+			rec[k] = int64(w)
+		case bool:
+			if w {
+				rec[k] = int64(1)
+			} else {
+				rec[k] = int64(0)
+			}
+		}
+	}
+
+	policy := NewWritePolicy(0, 0)
+	err = client.Put(policy, key, rec)
+	panicOnError(err)
+	if rec != nil {
+		printError("record updated: namespace=%s set=%s key=%v", key.Namespace(), key.SetName(), key.Value())
+	}
+}
+
+func panicOnError(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
+
+func printOK(format string, a ...interface{}) {
+	fmt.Printf("ok: "+format+"\n", a...)
+	os.Exit(0)
+}
+
+func printError(format string, a ...interface{}) {
+	fmt.Printf("error: "+format+"\n", a...)
+	os.Exit(1)
+}