AppManager: Support exposing cross-cluster ports
Change-Id: I4bdb3573209935f6777656ec2f3481e79d84a9c9
diff --git a/core/installer/cmd/dodo_app.go b/core/installer/cmd/dodo_app.go
index adc8beb..9b5da30 100644
--- a/core/installer/cmd/dodo_app.go
+++ b/core/installer/cmd/dodo_app.go
@@ -245,6 +245,8 @@
return s.Start()
}
+// TODO(gio): this should be removed, all of app installtions including dodo app
+// must be done directly by main app manager.
type proxyConfigurator struct {
apiAddr string
}
@@ -262,7 +264,7 @@
To string `json:"to"`
}
-func (pc *proxyConfigurator) AddProxy(src, dst string) error {
+func (pc *proxyConfigurator) AddIngressProxy(src, dst string) error {
var buf bytes.Buffer
if err := json.NewEncoder(&buf).Encode(proxyPair{src, dst}); err != nil {
return err
@@ -279,7 +281,17 @@
return nil
}
-func (pc *proxyConfigurator) RemoveProxy(src, dst string) error {
+func (pc *proxyConfigurator) AddProxy(src int, dst string, protocol installer.Protocol) (string, error) {
+ // TODO(gio): implement
+ return "", fmt.Errorf("NOT IMPLEMENTED")
+}
+
+func (pc *proxyConfigurator) RemoveProxy(src int, dst string, protocol installer.Protocol) error {
+ // TODO(gio): implement
+ return fmt.Errorf("NOT IMPLEMENTED")
+}
+
+func (pc *proxyConfigurator) RemoveIngressProxy(src, dst string) error {
var buf bytes.Buffer
if err := json.NewEncoder(&buf).Encode(proxyPair{src, dst}); err != nil {
return err