open-nomad/nomad/stream
Drew Bailey d62d8a8587
Event sink manager improvements (#9206)
* Improve managed sink run loop and reloading

resetCh no longer needed

length of buffer equal to count of items, not count of events in each item

update equality fn name, pr feedback

clean up sink manager sink creation

* update test to reflect changes

* bad editor find and replace

* pr feedback
2020-11-02 09:21:32 -05:00
..
event_broker.go Event sink manager improvements (#9206) 2020-11-02 09:21:32 -05:00
event_broker_test.go Event sink manager improvements (#9206) 2020-11-02 09:21:32 -05:00
event_buffer.go Event sink manager improvements (#9206) 2020-11-02 09:21:32 -05:00
event_buffer_test.go Event sink manager improvements (#9206) 2020-11-02 09:21:32 -05:00
ndjson.go filter on additional filter keys, remove switch statement duplication 2020-10-14 14:14:33 -04:00
ndjson_test.go filter on additional filter keys, remove switch statement duplication 2020-10-14 14:14:33 -04:00
sink.go Send events to EventSinks (#9171) 2020-10-26 17:27:54 -04:00
subscription.go Update subscription filter func (#9232) 2020-10-30 10:07:38 -07:00
subscription_test.go Update subscription filter func (#9232) 2020-10-30 10:07:38 -07:00
webhook_sink.go Send events to EventSinks (#9171) 2020-10-26 17:27:54 -04:00
webhook_sink_test.go Send events to EventSinks (#9171) 2020-10-26 17:27:54 -04:00