type Config struct {
MySQLConfig common.MySQLConfig `json:"mysql"`
Policy Policy `json:"policy"`
- Nodes []Node `json:"nodes"`
+ Nodes []Node `json:"bootstrap_nodes"`
API API `json:"api"`
}
}
func (m *monitor) Run() {
- if err := s.updateNodesHostPort(); err != nil {
+ if err := m.updateBootstrapNodes(); err != nil {
log.Fatal(err)
}
for ; true; <-ticker.C {
// TODO: use goroutine?
// TODO: lock?
- go s.monitorRountine()
+ go m.monitorRountine()
}
}
-func (m *monitor) updateNodesHostPort() error {
+func (m *monitor) updateBootstrapNodes() error {
return nil
}