From 3243ae084b7a022fc12b652b262ecf46524d7561 Mon Sep 17 00:00:00 2001
From: Solomon Hykes <solomon@docker.com>
Date: Mon, 2 Jun 2014 07:14:06 +0000
Subject: [PATCH] Move each backend to a separate file

Signed-off-by: Solomon Hykes <solomon@docker.com>
---
 backends/backends.go   | 48 ------------------------------------------
 backends/debug.go      | 32 ++++++++++++++++++++++++++++
 backends/fakeclient.go | 30 ++++++++++++++++++++++++++
 3 files changed, 62 insertions(+), 48 deletions(-)
 create mode 100644 backends/debug.go
 create mode 100644 backends/fakeclient.go

diff --git a/backends/backends.go b/backends/backends.go
index 4a9ce1bc03..3358215b94 100644
--- a/backends/backends.go
+++ b/backends/backends.go
@@ -1,10 +1,7 @@
 package backends
 
 import (
-	"fmt"
 	"github.com/docker/libswarm/beam"
-	"strings"
-	"time"
 )
 
 // New returns a new engine, with all backends
@@ -21,48 +18,3 @@ func New() *beam.Object {
 	backends.Bind("forward", Forward())
 	return beam.Obj(backends)
 }
-
-func Debug() beam.Sender {
-	backend := beam.NewServer()
-	backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {
-		instance := beam.Task(func(in beam.Receiver, out beam.Sender) {
-			fmt.Printf("debug backend!")
-			for {
-				msg, err := in.Receive(beam.Ret)
-				if err != nil {
-					fmt.Printf("debug receive: %v", err)
-					return
-				}
-				fmt.Printf("[DEBUG] %s %s\n", msg.Verb, strings.Join(msg.Args, " "))
-				if _, err := out.Send(msg); err != nil {
-					fmt.Printf("debug send: %v", err)
-					return
-				}
-			}
-		})
-		_, err := ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: instance})
-		return err
-	}))
-	return backend
-}
-
-func FakeClient() beam.Sender {
-	backend := beam.NewServer()
-	backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {
-		// Instantiate a new fakeclient instance
-		instance := beam.Task(func(in beam.Receiver, out beam.Sender) {
-			fmt.Printf("fake client!\n")
-			defer fmt.Printf("end of fake client!\n")
-			o := beam.Obj(out)
-			o.Log("fake client starting")
-			defer o.Log("fake client terminating")
-			for {
-				time.Sleep(1 * time.Second)
-				o.Log("fake client heartbeat!")
-			}
-		})
-		_, err := ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: instance})
-		return err
-	}))
-	return backend
-}
diff --git a/backends/debug.go b/backends/debug.go
new file mode 100644
index 0000000000..42e4cad579
--- /dev/null
+++ b/backends/debug.go
@@ -0,0 +1,32 @@
+package backends
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/docker/libswarm/beam"
+)
+
+func Debug() beam.Sender {
+	backend := beam.NewServer()
+	backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {
+		instance := beam.Task(func(in beam.Receiver, out beam.Sender) {
+			fmt.Printf("debug backend!")
+			for {
+				msg, err := in.Receive(beam.Ret)
+				if err != nil {
+					fmt.Printf("debug receive: %v", err)
+					return
+				}
+				fmt.Printf("[DEBUG] %s %s\n", msg.Verb, strings.Join(msg.Args, " "))
+				if _, err := out.Send(msg); err != nil {
+					fmt.Printf("debug send: %v", err)
+					return
+				}
+			}
+		})
+		_, err := ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: instance})
+		return err
+	}))
+	return backend
+}
diff --git a/backends/fakeclient.go b/backends/fakeclient.go
new file mode 100644
index 0000000000..2f51940299
--- /dev/null
+++ b/backends/fakeclient.go
@@ -0,0 +1,30 @@
+package backends
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/docker/libswarm/beam"
+)
+
+func FakeClient() beam.Sender {
+	backend := beam.NewServer()
+	backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {
+		// Instantiate a new fakeclient instance
+		instance := beam.Task(func(in beam.Receiver, out beam.Sender) {
+			fmt.Printf("fake client!\n")
+			defer fmt.Printf("end of fake client!\n")
+			o := beam.Obj(out)
+			o.Log("fake client starting")
+			defer o.Log("fake client terminating")
+			for {
+				time.Sleep(1 * time.Second)
+				o.Log("fake client heartbeat!")
+			}
+		})
+		_, err := ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: instance})
+		return err
+	}))
+	return backend
+}
+