(comp component.Component, opts []component.Option)
| 120 | } |
| 121 | |
| 122 | func (h *LocalHandler) register(comp component.Component, opts []component.Option) error { |
| 123 | s := component.NewService(comp, opts) |
| 124 | |
| 125 | if _, ok := h.localServices[s.Name]; ok { |
| 126 | return fmt.Errorf("handler: service already defined: %s", s.Name) |
| 127 | } |
| 128 | |
| 129 | if err := s.ExtractHandler(); err != nil { |
| 130 | return err |
| 131 | } |
| 132 | |
| 133 | // register all localHandlers |
| 134 | h.localServices[s.Name] = s |
| 135 | for name, handler := range s.Handlers { |
| 136 | n := fmt.Sprintf("%s.%s", s.Name, name) |
| 137 | log.Println("Register local handler", n) |
| 138 | h.localHandlers[n] = handler |
| 139 | } |
| 140 | return nil |
| 141 | } |
| 142 | |
| 143 | func (h *LocalHandler) initRemoteService(members []*clusterpb.MemberInfo) { |
| 144 | for _, m := range members { |
no test coverage detected