X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=lib%2Fagent%2Fapiv1.go;h=3ca84b954c84ff35e553070a9497d46daee9a2ed;hb=befb10519daefcbee85950a4e574678fe4b7f402;hp=c5f4d2210fbb54c2c3c5f683703df9027f25f5cb;hpb=a2cc38902ff7528870822110c4f04329a3918564;p=src%2Fxds%2Fxds-agent.git diff --git a/lib/agent/apiv1.go b/lib/agent/apiv1.go index c5f4d22..3ca84b9 100644 --- a/lib/agent/apiv1.go +++ b/lib/agent/apiv1.go @@ -21,6 +21,7 @@ import ( "fmt" "strconv" + "gerrit.automotivelinux.org/gerrit/src/xds/xds-agent/lib/xaapiv1" "gerrit.automotivelinux.org/gerrit/src/xds/xds-agent/lib/xdsconfig" "gerrit.automotivelinux.org/gerrit/src/xds/xds-server.git/lib/xsapiv1" "github.com/gin-gonic/gin" @@ -48,7 +49,7 @@ func NewAPIV1(ctx *Context) *APIService { s.apiRouter.GET("/config", s.getConfig) s.apiRouter.POST("/config", s.setConfig) - s.apiRouter.GET("/browse", s.browseFS) + // s.apiRouter.GET("/browse", s.browseFS) s.apiRouter.GET("/projects", s.getProjects) s.apiRouter.GET("/projects/:id", s.getProject) @@ -117,6 +118,7 @@ func (s *APIService) AddXdsServer(cfg xdsconfig.XDSServerConf) (*XdsServer, erro // Declare passthrough routes s.sdksPassthroughInit(svr) + s.targetsPassthroughInit(svr) // Register callback on Connection svr.ConnectOn(func(server *XdsServer) error { @@ -124,9 +126,9 @@ func (s *APIService) AddXdsServer(cfg xdsconfig.XDSServerConf) (*XdsServer, erro // Add server to list s.xdsServers[server.ID] = svr - // Register event forwarder + // Register events forwarder if err := s.sdksEventsForwardInit(server); err != nil { - s.Log.Errorf("XDS Server %v - sdk event forwarding error: %v", server.ID, err) + s.Log.Errorf("XDS Server %v - sdk events forwarding error: %v", server.ID, err) } // Load projects @@ -163,3 +165,17 @@ func (s *APIService) DelXdsServer(id string) error { s.xdsServers[id].Close() return nil } + +// UpdateXdsServer Update XDS Server configuration settings +func (s *APIService) UpdateXdsServer(cfg xaapiv1.ServerCfg) error { + if _, exist := s.xdsServers[cfg.ID]; !exist { + return fmt.Errorf("Unknown Server ID %s", cfg.ID) + } + + svr := s.xdsServers[cfg.ID] + + // Update only some configurable fields + svr.ConnRetry = cfg.ConnRetry + + return nil +}