diff options
| author |  John Belamaric <jbelamaric@infoblox.com>
| 2018-06-27 07:45:32 -0700 |
|---|---|---|
| committer |  GitHub <noreply@github.com>
| 2018-06-27 07:45:32 -0700 |
| commit | 99287d091c2db4028e54782fd4de43f63ca4b040 (patch) | |
| tree | 5e9908031dbf3256a0ad3e2a54c0a90251e88757 /plugin/kubernetes/handler_test.go | |
| parent | b7480d5d1216aa87d80d240a31de750079eba904 (diff) | |
| download | coredns-99287d091c2db4028e54782fd4de43f63ca4b040.tar.gz coredns-99287d091c2db4028e54782fd4de43f63ca4b040.tar.zst coredns-99287d091c2db4028e54782fd4de43f63ca4b040.zip | |
Watch feature (#1527)
* Add part 1 watch functionality. (squashed)
* add funcs for service/endpoint fqdns
* add endpoints watch
* document exposed funcs
* only send subset deltas
* locking for watch map
* tests and docs
* add pod watch
* remove debugs prints
* feedback part 1
* add error reporting to proto
* inform clients of server stop+errors
* add grpc options param
* use proper context
* Review feedback:
* Removed client (will move to another repo)
* Use new log functions
* Change watchChan to be for string not []string
* Rework how k8s plugin stores watch tracking info to simplify
* Normalize the qname on watch request
* Add blank line back
* Revert another spurious change
* Fix tests
* Add stop channel.
Fix tests.
Better docs for plugin interface.
* fmt.Printf -> log.Warningf
* Move from dnsserver to plugin/pkg/watch
* gofmt
* remove dead client watches
* sate linter
* linter omg
Diffstat (limited to 'plugin/kubernetes/handler_test.go')
| -rw-r--r-- | plugin/kubernetes/handler_test.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/plugin/kubernetes/handler_test.go b/plugin/kubernetes/handler_test.go index 388903137..2edeb8e8e 100644 --- a/plugin/kubernetes/handler_test.go +++ b/plugin/kubernetes/handler_test.go @@ -6,6 +6,7 @@ import ( "time" "github.com/coredns/coredns/plugin/pkg/dnstest" + "github.com/coredns/coredns/plugin/pkg/watch" "github.com/coredns/coredns/plugin/test" "github.com/miekg/dns" @@ -332,6 +333,9 @@ func (APIConnServeTest) Stop() error { return nil } func (APIConnServeTest) EpIndexReverse(string) []*api.Endpoints { return nil } func (APIConnServeTest) SvcIndexReverse(string) []*api.Service { return nil } func (APIConnServeTest) Modified() int64 { return time.Now().Unix() } +func (APIConnServeTest) SetWatchChan(watch.Chan) {} +func (APIConnServeTest) Watch(string) error { return nil } +func (APIConnServeTest) StopWatching(string) {} func (APIConnServeTest) PodIndex(string) []*api.Pod { a := []*api.Pod{{ |