aboutsummaryrefslogtreecommitdiffstats
path: root/examples/object_storage/main.go
diff options
context:
space:
mode:
Diffstat (limited to 'examples/object_storage/main.go')
-rw-r--r--examples/object_storage/main.go74
1 files changed, 0 insertions, 74 deletions
diff --git a/examples/object_storage/main.go b/examples/object_storage/main.go
deleted file mode 100644
index 22fa426..0000000
--- a/examples/object_storage/main.go
+++ /dev/null
@@ -1,74 +0,0 @@
-package main
-
-import (
- "fmt"
- "io"
- "os"
- "time"
-
- "github.com/aerospike/aerospike-client-go"
-
- "gopkg.in/src-d/go-git.v4"
-)
-
-func main() {
- url := os.Args[2]
- client, err := aerospike.NewClient("127.0.0.1", 3000)
- if err != nil {
- panic(err)
- }
-
- s := NewAerospikeStorage(url, client)
- r, err := git.NewRepository(s)
- if err != nil {
- panic(err)
- }
-
- switch os.Args[1] {
- case "clone":
- clone(r, url)
- case "list":
- list(r)
- default:
- panic("unknown option")
- }
-}
-
-func clone(r *git.Repository, url string) {
- fmt.Printf("Cloning %q ...\n", os.Args[2])
- start := time.Now()
-
- if err := r.Clone(&git.CloneOptions{URL: url}); err != nil {
- panic(err)
- }
-
- fmt.Printf("Time elapsed %s\n", time.Since(start))
-}
-
-func list(r *git.Repository) {
- fmt.Printf("Listing commits from %q ...\n", os.Args[1])
-
- iter, err := r.Commits()
- if err != nil {
- panic(err)
- }
- defer iter.Close()
-
- var count int
- for {
- //the commits are not shorted in any special order
- commit, err := iter.Next()
- if err != nil {
- if err == io.EOF {
- break
- }
-
- panic(err)
- }
-
- count++
- fmt.Println(commit)
- }
-
- fmt.Printf("Total number of commits %d\n", count)
-}