controller: remove minio hook
diff --git a/controller/main.go b/controller/main.go
index 11498ad..f78134f 100644
--- a/controller/main.go
+++ b/controller/main.go
@@ -1,7 +1,6 @@
package main
import (
- "context"
"errors"
"flag"
"fmt"
@@ -10,8 +9,6 @@
"log"
"net/http"
- apiv1 "k8s.io/api/core/v1"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
corev1 "k8s.io/client-go/kubernetes/typed/core/v1"
"k8s.io/client-go/rest"
@@ -34,39 +31,7 @@
const getQuery = `{ "query": "{ get%s(id: \"%s\") { id objectPath } } " }`
type MinioWebhook struct {
- gql schema.GraphQLClient
- pods corev1.PodInterface
-}
-
-func (m *MinioWebhook) minioHandler(w http.ResponseWriter, r *http.Request) {
- // TODO(giolekva): move this to events processor
- resp := ""
- id, err := regogo.Get(resp, "input.addImage.image[0].id")
- if err != nil {
- glog.Error(err)
- http.Error(w, "Could not extract node id", http.StatusInternalServerError)
- return
- }
- glog.Infof("New image id: %s", id.String())
- pod := &apiv1.Pod{
- ObjectMeta: metav1.ObjectMeta{
- Name: fmt.Sprintf("detect-faces-%s", id.String())},
- Spec: apiv1.PodSpec{
- RestartPolicy: apiv1.RestartPolicyNever,
- Containers: []apiv1.Container{{
- Name: "detect-faces",
- Image: "face-detector:latest",
- ImagePullPolicy: apiv1.PullNever,
- Command: []string{"python", "main.py"},
- Args: []string{"http://pcloud-controller-service.pcloud.svc:1111/graphql", "http://minio-hl-svc.minio.svc:9000", id.String()}}}}}
- glog.Info("Creating pod...")
- result, err := m.pods.Create(context.TODO(), pod, metav1.CreateOptions{})
- if err != nil {
- glog.Error(err)
- http.Error(w, "Could not start face detector", http.StatusInternalServerError)
- return
- }
- glog.Infof("Created deployment %q.\n", result.GetObjectMeta().GetName())
+ gql schema.GraphQLClient
}
type query struct {
@@ -126,16 +91,6 @@
func main() {
flag.Parse()
- config, err := getKubeConfig()
- if err != nil {
- panic(err.Error())
- }
- clientset, err := kubernetes.NewForConfig(config)
- if err != nil {
- panic(err)
- }
- pods := clientset.CoreV1().Pods("pcloud")
-
gqlClient, err := schema.NewDgraphClient(
*dgraphGqlAddress, *dgraphSchemaAddress)
if err != nil {
@@ -173,7 +128,7 @@
if err != nil {
panic(err)
}
- mw := MinioWebhook{gqlClient, pods}
+ mw := MinioWebhook{gqlClient}
http.HandleFunc("/graphql", mw.graphqlHandler)
log.Fatal(http.ListenAndServe(fmt.Sprintf(":%d", *port), nil))
}