renamed project to okq

Author: mc0

.gitignore

@@ -1,4 +1,4 @@
 .goat
 *.test
 *.prof
-redeque
+okq

.go.yaml

@@ -1,5 +1,5 @@
 ---
-path: github.com/mc0/redeque
+path: github.com/mc0/okq
 deps:
     - loc: github.com/fzzy/radix/redis
     - loc: github.com/mediocregopher/flagconfig

README.md

@@ -1,4 +1,4 @@
-Redeque
+okQ
 =======
 
 A simple go-based reliable event queueing with at-least-once support.
@@ -9,7 +9,7 @@ This allows swapping connecting directly to the service from any redis client.
 Commands
 --------
 
-Redeque is modeled as a left-to-right queue. Clients submit jobs on the left
+OkQ is modeled as a left-to-right queue. Clients submit jobs on the left
 side of the queue (with `QLPUSH`, and consumers read off the right side (with
 `QRPOP`).
 

clients/consumers.go

@@ -4,9 +4,9 @@ import (
 	"github.com/mediocregopher/pubsubch"
 	"time"
 
-	"github.com/mc0/redeque/config"
-	"github.com/mc0/redeque/db"
-	"github.com/mc0/redeque/log"
+	"github.com/mc0/okq/config"
+	"github.com/mc0/okq/db"
+	"github.com/mc0/okq/log"
 )
 
 // consumers are clients which have qregistered themselves as consuming some set

clients/consumers_test.go

@@ -7,7 +7,7 @@ import (
 	. "testing"
 	"time"
 
-	"github.com/mc0/redeque/db"
+	"github.com/mc0/okq/db"
 )
 
 func TestUpdateQueues(t *T) {

commands/commands.go

@@ -10,8 +10,8 @@ import (
 	"strings"
 	"time"
 
-	"github.com/mc0/redeque/clients"
-	"github.com/mc0/redeque/db"
+	"github.com/mc0/okq/clients"
+	"github.com/mc0/okq/db"
 )
 
 var commandMap = map[string]func(*clients.Client, []string) error{

commands/commands_test.go

@@ -9,7 +9,7 @@ import (
 	. "testing"
 	"time"
 
-	"github.com/mc0/redeque/clients"
+	"github.com/mc0/okq/clients"
 )
 
 func readAndAssertStr(t *T, client *clients.Client, expected string) {

db/db.go

@@ -9,8 +9,8 @@ import (
 	"github.com/fzzy/radix/redis"
 	"strings"
 
-	"github.com/mc0/redeque/config"
-	"github.com/mc0/redeque/log"
+	"github.com/mc0/okq/config"
+	"github.com/mc0/okq/log"
 )
 
 // A pool of redis connections which can be read from asynchronously by anyone

db/db_scanner.go

@@ -2,7 +2,7 @@ package db
 
 import (
 	"github.com/fzzy/radix/redis"
-	"github.com/mc0/redeque/log"
+	"github.com/mc0/okq/log"
 )
 
 type ScanResult struct {

log/log.go

@@ -8,10 +8,10 @@ import (
 	"os"
 	"strings"
 
-	"github.com/mc0/redeque/config"
+	"github.com/mc0/okq/config"
 )
 
-type RedequeLogger struct {
+type OkQLogger struct {
 	*log.Logger
 }
 
@@ -20,7 +20,7 @@ const defaultFlags = log.LstdFlags
 // This is what all logging methods should be called on. We leave this public
 // and don't make wrappers around it so that the Lshortfile flag will work
 // (prints out file and line number of logs)
-var L RedequeLogger
+var L OkQLogger
 
 func init() {
 	var flags int
@@ -29,18 +29,18 @@ func init() {
 	} else {
 		flags = log.LstdFlags
 	}
-	L = RedequeLogger{log.New(os.Stdout, "", flags)}
+	L = OkQLogger{log.New(os.Stdout, "", flags)}
 }
 
-func (l *RedequeLogger) Debug(v ...interface{}) {
+func (l *OkQLogger) Debug(v ...interface{}) {
 	if config.Debug {
 		format := strings.Repeat("%s", len(v))
 		s := fmt.Sprintf(format, v...)
 		l.Output(2, s)
 	}
 }
 
-func (l *RedequeLogger) Debugf(format string, args ...interface{}) {
+func (l *OkQLogger) Debugf(format string, args ...interface{}) {
 	if config.Debug {
 		s := fmt.Sprintf(format, args...)
 		l.Output(2, s)

restore/restore.go

@@ -7,8 +7,8 @@ import (
 	"github.com/fzzy/radix/redis"
 	"time"
 
-	"github.com/mc0/redeque/db"
-	"github.com/mc0/redeque/log"
+	"github.com/mc0/okq/db"
+	"github.com/mc0/okq/log"
 )
 
 func init() {

server.go

@@ -7,11 +7,11 @@ import (
 	"net"
 	"strings"
 
-	"github.com/mc0/redeque/clients"
-	"github.com/mc0/redeque/commands"
-	"github.com/mc0/redeque/config"
-	"github.com/mc0/redeque/log"
-	_ "github.com/mc0/redeque/restore"
+	"github.com/mc0/okq/clients"
+	"github.com/mc0/okq/commands"
+	"github.com/mc0/okq/config"
+	"github.com/mc0/okq/log"
+	_ "github.com/mc0/okq/restore"
 )
 
 func main() {