Initial distributor implementation

appengine/cmd/dm/frontend/init.go

Index: appengine/cmd/dm/frontend/init.go
diff --git a/appengine/cmd/dm/frontend/init.go b/appengine/cmd/dm/frontend/init.go
index c597e0f533ca38ef643e0be1cc23cd75791bbfc4..14c112517e6c40002d45b7c0906e47355cf8f6bd 100644
--- a/appengine/cmd/dm/frontend/init.go
+++ b/appengine/cmd/dm/frontend/init.go
@@ -9,6 +9,8 @@ import (
 
 	"github.com/GoogleCloudPlatform/go-endpoints/endpoints"
 	"github.com/julienschmidt/httprouter"
+	"github.com/luci/luci-go/appengine/cmd/dm/distributor"
+	"github.com/luci/luci-go/appengine/cmd/dm/distributor/impl/swarmingV1"
 	dm "github.com/luci/luci-go/appengine/cmd/dm/service"
 	"github.com/luci/luci-go/appengine/tumble"
 )
@@ -16,6 +18,9 @@ import (
 var myTumble = tumble.DefaultConfig()
 
 func init() {
+	reg := distributor.Registry{}
+	swarmingV1.Register(reg)
+
 	srv := endpoints.NewServer("")
 	err := dm.RegisterEndpointsService(srv)
 	if err != nil {