| 9 | ) |
| 10 | |
| 11 | type watcher struct { |
| 12 | e encoder.Encoder |
| 13 | name string |
| 14 | bucket string |
| 15 | key string |
| 16 | |
| 17 | ch chan *source.ChangeSet |
| 18 | exit chan bool |
| 19 | } |
| 20 | |
| 21 | func newWatcher(kv natsgo.KeyValue, bucket, key, name string, e encoder.Encoder) (source.Watcher, error) { |
| 22 | w := &watcher{ |
nothing calls this directly
no outgoing calls
no test coverage detected