Codebase list golang-github-go-kit-kit / 4503115
registrar errors are now package level vars like the rest and higher tolerance for integration test for skewy CI containers Bas van Beek 7 years ago
2 changed file(s) with 6 addition(s) and 4 deletion(s). Raw diff Collapse all Expand all
+4
-2
sd/zk/client.go less more
1515 DefaultACL = zk.WorldACL(zk.PermAll)
1616 ErrInvalidCredentials = errors.New("invalid credentials provided")
1717 ErrClientClosed = errors.New("client service closed")
18 ErrNotRegistered = errors.New("not registered")
19 ErrNodeNotFound = errors.New("node not found")
1820 )
1921
2022 const (
246248 // Deregister implements the ZooKeeper Client interface.
247249 func (c *client) Deregister(s *Service) error {
248250 if s.node == "" {
249 return errors.New("not registered")
251 return ErrNotRegistered
250252 }
251253 path := s.Path + s.Name
252254 found, stat, err := c.Exists(path)
254256 return err
255257 }
256258 if !found {
257 return errors.New("node not found")
259 return ErrNodeNotFound
258260 }
259261 if err := c.Delete(path, stat.Version); err != nil {
260262 return err
+2
-2
sd/zk/integration_test.go less more
189189 if want, have := stdzk.EventNodeChildrenChanged.String(), event.Type.String(); want != have {
190190 t.Errorf("want %s, have %s", want, have)
191191 }
192 case <-time.After(20 * time.Millisecond):
192 case <-time.After(100 * time.Millisecond):
193193 t.Errorf("expected incoming watch event, timeout occurred")
194194 }
195195
204204 if want, have := stdzk.EventNodeChildrenChanged.String(), event.Type.String(); want != have {
205205 t.Errorf("want %s, have %s", want, have)
206206 }
207 case <-time.After(20 * time.Millisecond):
207 case <-time.After(100 * time.Millisecond):
208208 t.Errorf("expected incoming watch event, timeout occurred")
209209 }
210210