luxolus/open-consul
2
0
Fork 0
Code Issues 1 Pull requests Packages Releases Wiki Activity
open-consul/agent/consul/state
History
Matt Keeler 2a4ca71d3f
Move to using a shared EventPublisher (#12673) 
Previously we had 1 EventPublisher per state.Store. When a state store was closed/abandoned such as during a consul snapshot restore, this had the behavior of force closing subscriptions for that topic and evicting event snapshots from the cache.

The intention of this commit is to keep all that behavior. To that end, the shared EventPublisher now supports the ability to refresh a topic. That will perform the force close + eviction. The FSM upon abandoning the previous state.Store will call RefreshTopic for all the topics with events generated by the state.Store.
2022-04-12 09:47:42 -04:00
..
acl.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
acl_events.go
acl_events_test.go
acl_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
acl_oss_test.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
acl_schema.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
acl_test.go remove gogo from acl protobufs 2022-03-28 16:20:56 -04:00
autopilot.go
autopilot_test.go
catalog.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
catalog_events.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
catalog_events_oss.go catalog: compare node names case insensitively in more places (#12444) 2022-02-24 16:54:47 -06:00
catalog_events_test.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
catalog_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
catalog_oss_test.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
catalog_schema.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
catalog_test.go catalog: compare node names case insensitively in more places (#12444) 2022-02-24 16:54:47 -06:00
config_entry.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
config_entry_intention.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
config_entry_intention_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
config_entry_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
config_entry_oss_test.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
config_entry_schema.go
config_entry_test.go configentry: make a new package to hold shared config entry structs that aren't used for RPC or the FSM (#12384) 2022-02-22 10:36:36 -06:00
connect_ca.go streaming: emit events when Connect CA Roots change (#12590) 2022-03-22 19:13:59 +00:00
connect_ca_events.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
connect_ca_events_test.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
connect_ca_test.go Bump go-control-plane 2022-03-30 13:11:27 -04:00
coordinate.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
coordinate_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
coordinate_oss_test.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
coordinate_test.go
delay_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
delay_test.go
federation_state.go
graveyard.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
graveyard_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
graveyard_test.go
index_connect_test.go
indexer.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
intention.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
intention_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
intention_test.go bulk rewrite using this script 2022-01-20 10:46:23 -06:00
kvs.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
kvs_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
kvs_oss_test.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
kvs_test.go
memdb.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
operations_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
prepared_query.go
prepared_query_index.go
prepared_query_index_test.go
prepared_query_test.go [OSS] Remove remaining references to master (#11827) 2022-01-20 12:47:50 +00:00
query.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
query_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
schema.go Add a new table to query service names by kind 2021-12-03 17:28:12 -07:00
schema_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
schema_oss_test.go
schema_test.go Add a new table to query service names by kind 2021-12-03 17:28:12 -07:00
session.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
session_oss.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
session_test.go
state_store.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
state_store_oss_test.go
state_store_test.go Fixup acl.EnterpriseMeta 2022-04-05 15:11:49 -07:00
store_integration_test.go Move to using a shared EventPublisher (#12673) 2022-04-12 09:47:42 -04:00
system_metadata.go
system_metadata_test.go
tombstone_gc.go
tombstone_gc_test.go
txn.go
txn_test.go
usage.go
usage_oss.go
usage_test.go