Minor refactoring, moving http request logic from storage to server

This commit is contained in:
Frederick F. Kautz IV 2015-01-18 15:50:53 -08:00
parent 4e644a1f41
commit d3d1c1afb3
2 changed files with 16 additions and 19 deletions

View File

@ -1,9 +1,12 @@
package server package server
import ( import (
"io"
"log" "log"
"net/http"
"reflect" "reflect"
"github.com/gorilla/mux"
"github.com/minio-io/minio/pkg/httpserver" "github.com/minio-io/minio/pkg/httpserver"
"github.com/minio-io/minio/pkg/storage" "github.com/minio-io/minio/pkg/storage"
) )
@ -16,7 +19,7 @@ func Start() {
ctrlChans = append(ctrlChans, ctrlChan) ctrlChans = append(ctrlChans, ctrlChan)
statusChans = append(statusChans, statusChan) statusChans = append(statusChans, statusChan)
ctrlChan, statusChan = httpserver.Start(storage.GetHttpHandler()) ctrlChan, statusChan = httpserver.Start(getHttpHandler())
ctrlChans = append(ctrlChans, ctrlChan) ctrlChans = append(ctrlChans, ctrlChan)
statusChans = append(statusChans, statusChan) statusChans = append(statusChans, statusChan)
@ -35,10 +38,10 @@ func Start() {
aliveStatusChans = append(aliveStatusChans, ch) aliveStatusChans = append(aliveStatusChans, ch)
} }
} }
// create new select cases without defunct channel
statusChans = aliveStatusChans statusChans = aliveStatusChans
cases = createSelectCases(statusChans) cases = createSelectCases(statusChans)
} }
// create new select case
} }
} }
@ -52,3 +55,13 @@ func createSelectCases(channels []<-chan error) []reflect.SelectCase {
} }
return cases return cases
} }
func getHttpHandler() http.Handler {
mux := mux.NewRouter()
mux.HandleFunc("/", storageHandler)
return mux
}
func storageHandler(w http.ResponseWriter, req *http.Request) {
io.WriteString(w, "MINIO")
}

View File

@ -1,22 +1,6 @@
package storage package storage
import ( import "errors"
"errors"
"io"
"net/http"
"github.com/gorilla/mux"
)
func GetHttpHandler() http.Handler {
mux := mux.NewRouter()
mux.HandleFunc("/", storageHandler)
return mux
}
func storageHandler(w http.ResponseWriter, req *http.Request) {
io.WriteString(w, "MINIO")
}
func Start() (chan<- string, <-chan error) { func Start() (chan<- string, <-chan error) {
ctrlChannel := make(chan string) ctrlChannel := make(chan string)