event-processor: query app-manager for triggers instead of hard coding them
diff --git a/events/cmd/main.go b/events/cmd/main.go
index 5a20c26..c272a4e 100644
--- a/events/cmd/main.go
+++ b/events/cmd/main.go
@@ -14,6 +14,7 @@
var kubeconfig = flag.String("kubeconfig", "", "Absolute path to the kubeconfig file.")
var apiAddr = flag.String("api_addr", "", "PCloud API server address.")
+var appManagerAddr = flag.String("app_manager_addr", "", "PCloud AppManager address.")
var objectStoreAddr = flag.String("object_store_addr", "", "S3 compatible object store address.")
func getKubeConfig() (*rest.Config, error) {
@@ -26,16 +27,16 @@
func main() {
flag.Parse()
- config, err := getKubeConfig()
+ kubeconfig, err := getKubeConfig()
if err != nil {
glog.Fatalf("Could not initialize Kubeconfig: %v", err)
}
- clientset, err := kubernetes.NewForConfig(config)
+ kube, err := kubernetes.NewForConfig(kubeconfig)
if err != nil {
glog.Fatalf("Could not create Kubernetes API client: %v", err)
}
- pods := clientset.CoreV1().Pods("default")
eventStore := events.NewGraphQLClient(*apiAddr)
+ appManager := events.NewAppManagerClient(*appManagerAddr)
events.NewSingleEventAtATimeProcessor(
- eventStore, pods, *apiAddr, *objectStoreAddr).Start()
+ eventStore, appManager, kube, *apiAddr, *objectStoreAddr).Start()
}