Drew Bailey 9adca240f8 Event Stream: Track ACL changes, unsubscribe on invalidating changes (#9447) ... * upsertaclpolicies * delete acl policies msgtype * upsert acl policies msgtype * delete acl tokens msgtype * acl bootstrap msgtype wip unsubscribe on token delete test that subscriptions are closed after an ACL token has been deleted Start writing policyupdated test * update test to use before/after policy * add SubscribeWithACLCheck to run acl checks on subscribe * update rpc endpoint to use broker acl check * Add and use subscriptions.closeSubscriptionFunc This fixes the issue of not being able to defer unlocking the mutex on the event broker in the for loop. handle acl policy updates * rpc endpoint test for terminating acl change * add comments Co-authored-by: Kris Hicks <khicks@hashicorp.com>		2020-12-01 11:11:34 -05:00
..
acl.go	Event Stream: Track ACL changes, unsubscribe on invalidating changes (#9447)	2020-12-01 11:11:34 -05:00
mock.go	Remove Managed Sinks from Nomad (#9470)	2020-11-30 14:00:31 -05:00