🐛 broadcast cache invalidation

[linkdd]

Decision Record

PR #1030 introduced a bug in the clustering.

Consider the following scenario:

• Node 0 & 1 & 2: logs are received, pipelines are built and cached
• Node 0: a user makes a change on the pipeline, cache on that node is invalidated
• Node 1 & 2 : receive new data due to replication
• Node 0: logs are received, new pipeline is used
• Node 1 & 2: logs are received, old pipeline is used (cache was not invalidated on those nodes)

We need to broadcast whether other nodes need to invalidate their cache as well.

License Agreement

• I guarantee that I have the rights on the code submitted in this PR
• I accept that this contribution will be released under the terms of the MIT License

[sonarqubecloud]

Quality Gate passed

Issues
0 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
12.2% Duplication on New Code

See analysis details on SonarQube Cloud

[github-actions]

	Tests	Passed ☑️	Skipped	Failed ❌️
API End-To-End Test Report	21 ran	3 passed	0 skipped	18 failed

• View API End-To-End Test Report

[github-actions]

	Tests	Passed ✅	Skipped	Failed
Consul End-To-End Test Report	1 ran	1 passed	0 skipped	0 failed

• View Consul End-To-End Test Report

[github-actions]

Robot Results

✅ Passed	❌ Failed	⏭️ Skipped	Total	Pass %	⏱️ Duration
10	7	5	17	58.82	1m12.486763s

Passed Tests

Name	⏱️ Duration	Suite
Create and Delete Personal Access Token	17.386 s	Account
Change Password	5.464 s	Account
Restore Password	4.642 s	Account
Create test role	5.020 s	Admin
Create test user	5.004 s	Admin
Log as test user	3.712 s	Admin
Login With Valid Credentials	3.790 s	Auth
Login With Invalid Credentials	3.398 s	Auth
Logout	4.245 s	Auth
Create new forwarder	4.920 s	Forwarders

Failed Tests

Name	Message	⏱️ Duration	Suite
Configure forwarder	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.397 s	Forwarders
Create new stream	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.014 s	Storage
View logs sent on default pipeline	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.116 s	Stream-Viewer
View logs sent via Syslog (RFC 5424)	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.110 s	Stream-Viewer
View logs sent via Syslog (RFC 3164)	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.078 s	Stream-Viewer
Watch logs	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.141 s	Stream-Viewer
Create new transformer	WebDriverException: Message: Reached error page: about:neterror?e=connectionFailure&u=http%3A//localhost%3A5080/&c=UTF-8&d=Firefox%20can%E2%80%99t%20establish%20a%20connection%20to%20the%20server%20at%20localhost%3A5080. Stacktrace: RemoteError@chrome://remote/content/shared/RemoteError.sys.mjs:8:8 WebDriverError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:202:5 UnknownError@chrome://remote/content/shared/webdriver/Errors.sys.mjs:961:5 checkReadyState@chrome://remote/content/marionette/navigate.sys.mjs:59:24 onNavigation@chrome://remote/content/marionette/navigate.sys.mjs:348:39 emit@resource://gre/modules/EventEmitter.sys.mjs:156:19 receiveMessage@chrome://remote/content/marionette/actors/MarionetteEventsParent.sys.mjs:33:25	2.036 s	Transformers