kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-10 12:25:42 +03:00
Code Issues Packages Projects Releases Wiki Activity
Files
a69eb82cfc8a9f435f2134ef32c7bc7e0c278494
nomad/nomad/stream
History
Drew Bailey 6e9ecf2c87 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_test.go
Event sink manager improvements (#9206)
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_buffer_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
ndjson_test.go
filter on additional filter keys, remove switch statement duplication
2020-10-14 14:14:33 -04:00
ndjson.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_test.go
Update subscription filter func (#9232)
2020-10-30 10:07:38 -07:00
subscription.go
Update subscription filter func (#9232)
2020-10-30 10:07:38 -07:00
webhook_sink_test.go
Send events to EventSinks (#9171)
2020-10-26 17:27:54 -04:00
webhook_sink.go
Send events to EventSinks (#9171)
2020-10-26 17:27:54 -04:00