| 13 | ) |
| 14 | |
| 15 | type Client interface { |
| 16 | Create(path string, data []byte) error |
| 17 | Update(path string, data []byte) error |
| 18 | Delete(path string) error |
| 19 | |
| 20 | Read(path string, must bool) ([]byte, error) |
| 21 | List(path string, must bool) ([]string, error) |
| 22 | |
| 23 | Close() error |
| 24 | |
| 25 | WatchInOrder(path string) (<-chan struct{}, []string, error) |
| 26 | |
| 27 | CreateEphemeral(path string, data []byte) (<-chan struct{}, error) |
| 28 | CreateEphemeralInOrder(path string, data []byte) (<-chan struct{}, string, error) |
| 29 | } |
| 30 | |
| 31 | func NewClient(coordinator string, addrlist string, auth string, timeout time.Duration) (Client, error) { |
| 32 | switch coordinator { |
no outgoing calls
no test coverage detected