DevFW-CICD/ingress-nginx-helm
12
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update dummy controller interface

Browse source
This commit is contained in:
Manuel de Brito Fontes 2017-06-11 15:59:44 -04:00
parent 748f686eca
commit 8a8e955b64
1 changed files with 4 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
examples/custom-controller/server.go
View file

@ -52,20 +52,11 @@ func (dc DummyController) SetConfig(cfgMap *api.ConfigMap) {
log.Printf("Config map %+v", cfgMap) log.Printf("Config map %+v", cfgMap)
} }
func (dc DummyController) Reload(data []byte) ([]byte, bool, error) {
out, err := exec.Command("echo", string(data)).CombinedOutput()
if err != nil {
return out, false, err
}
log.Printf("Reloaded new config %s", out)
return out, true, err
}
func (dc DummyController) Test(file string) *exec.Cmd { func (dc DummyController) Test(file string) *exec.Cmd {
return exec.Command("echo", file) return exec.Command("echo", file)
} }
func (dc DummyController) OnUpdate(updatePayload ingress.Configuration) ([]byte, error) { func (dc DummyController) OnUpdate(updatePayload ingress.Configuration) error {
log.Printf("Received OnUpdate notification") log.Printf("Received OnUpdate notification")
for _, b := range updatePayload.Backends { for _, b := range updatePayload.Backends {
eps := []string{} eps := []string{}
@ -74,7 +65,9 @@ func (dc DummyController) OnUpdate(updatePayload ingress.Configuration) ([]byte,
} }
log.Printf("%v: %v", b.Name, strings.Join(eps, ", ")) log.Printf("%v: %v", b.Name, strings.Join(eps, ", "))
} }
return []byte(`<string containing a configuration file>`), nil
log.Printf("Reloaded new config")
return nil
} }
func (dc DummyController) BackendDefaults() defaults.Backend { func (dc DummyController) BackendDefaults() defaults.Backend {