first commit

LICENSE

@@ -0,0 +1,20 @@
+The MIT License (MIT)
+
+Copyright (c) 2016 Josh Baker
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+the Software, and to permit persons to whom the Software is furnished to do so,
+subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,110 @@
+Redcon [GoDoc](https://godoc.org/github.com/tidwall/redcon?status.svg)](https://godoc.org/github.com/tidwall/redcon)
+======
+Super fast Redis RESP server implementation.
+Supports pipelining and telnet commands.
+
+There is only one function `ListenAndServe`, and one type `Conn`.
+
+Here's a full example of a Redis clone that accepts:
+
+- SET key value
+- GET key
+- DEL key
+- PING
+- QUIT
+
+You can run this example from a terminal:
+
+```sh
+go run examples/clone.go
+```
+
+```go
+package main
+
+import (
+	"log"
+	"strings"
+	"sync"
+
+	"github.com/tidwall/redcon"
+)
+
+var addr = ":6380"
+
+func main() {
+	var mu sync.RWMutex
+	var items = make(map[string]string)
+	go log.Printf("started server at %s", addr)
+	err := redcon.ListenAndServe(addr,
+		func(conn redcon.Conn, commands [][]string) {
+			for _, args := range commands {
+				switch strings.ToLower(args[0]) {
+				default:
+					conn.WriteError("ERR unknown command '" + args[0] + "'")
+				case "ping":
+					conn.WriteString("PONG")
+				case "quit":
+					conn.WriteString("OK")
+					conn.Close()
+				case "set":
+					if len(args) != 3 {
+						conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command")
+						continue
+					}
+					mu.Lock()
+					items[args[1]] = args[2]
+					mu.Unlock()
+					conn.WriteString("OK")
+				case "get":
+					if len(args) != 2 {
+						conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command")
+						continue
+					}
+					mu.RLock()
+					val, ok := items[args[1]]
+					mu.RUnlock()
+					if !ok {
+						conn.WriteNull()
+					} else {
+						conn.WriteBulk(val)
+					}
+				case "del":
+					if len(args) != 2 {
+						conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command")
+						continue
+					}
+					mu.Lock()
+					_, ok := items[args[1]]
+					delete(items, args[1])
+					mu.Unlock()
+					if !ok {
+						conn.WriteInt(0)
+					} else {
+						conn.WriteInt(1)
+					}
+				}
+			}
+		},
+		func(conn redcon.Conn) bool {
+			log.Printf("accept: %s", conn.RemoteAddr())
+			return true
+		},
+		func(conn redcon.Conn, err error) {
+			log.Printf("closed: %s, err: %v", conn.RemoteAddr(), err)
+		},
+	)
+	if err != nil {
+		log.Fatal(err)
+	}
+}
+```
+
+Contact
+-------
+Josh Baker [@tidwall](http://twitter.com/tidwall)
+
+License
+-------
+Redcon source code is available under the MIT [License](/LICENSE).
+

example/clone.go

@@ -0,0 +1,78 @@
+package main
+
+import (
+	"log"
+	"strings"
+	"sync"
+
+	"github.com/tidwall/redcon"
+)
+
+var addr = ":6380"
+
+func main() {
+	var mu sync.RWMutex
+	var items = make(map[string]string)
+	go log.Printf("started server at %s", addr)
+	err := redcon.ListenAndServe(addr,
+		func(conn redcon.Conn, commands [][]string) {
+			for _, args := range commands {
+				switch strings.ToLower(args[0]) {
+				default:
+					conn.WriteError("ERR unknown command '" + args[0] + "'")
+				case "ping":
+					conn.WriteString("PONG")
+				case "quit":
+					conn.WriteString("OK")
+					conn.Close()
+				case "set":
+					if len(args) != 3 {
+						conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command")
+						continue
+					}
+					mu.Lock()
+					items[args[1]] = args[2]
+					mu.Unlock()
+					conn.WriteString("OK")
+				case "get":
+					if len(args) != 2 {
+						conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command")
+						continue
+					}
+					mu.RLock()
+					val, ok := items[args[1]]
+					mu.RUnlock()
+					if !ok {
+						conn.WriteNull()
+					} else {
+						conn.WriteBulk(val)
+					}
+				case "del":
+					if len(args) != 2 {
+						conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command")
+						continue
+					}
+					mu.Lock()
+					_, ok := items[args[1]]
+					delete(items, args[1])
+					mu.Unlock()
+					if !ok {
+						conn.WriteInt(0)
+					} else {
+						conn.WriteInt(1)
+					}
+				}
+			}
+		},
+		func(conn redcon.Conn) bool {
+			log.Printf("accept: %s", conn.RemoteAddr())
+			return true
+		},
+		func(conn redcon.Conn, err error) {
+			log.Printf("closed: %s, err: %v", conn.RemoteAddr(), err)
+		},
+	)
+	if err != nil {
+		log.Fatal(err)
+	}
+}