diff options
Diffstat (limited to 'store/local_cache_supplier.go')
| -rw-r--r-- | store/local_cache_supplier.go | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/store/local_cache_supplier.go b/store/local_cache_supplier.go index 91aa94768..3627c5b39 100644 --- a/store/local_cache_supplier.go +++ b/store/local_cache_supplier.go @@ -32,15 +32,11 @@ func NewLocalCacheSupplier(metrics einterfaces.MetricsInterface, cluster einterf cluster: cluster, } - registerClusterHandlers(supplier) - - return supplier -} - -func registerClusterHandlers(supplier *LocalCacheSupplier) { - if cluster := einterfaces.GetClusterInterface(); cluster != nil { + if cluster != nil { cluster.RegisterClusterMessageHandler(model.CLUSTER_EVENT_INVALIDATE_CACHE_FOR_REACTIONS, supplier.handleClusterInvalidateReaction) } + + return supplier } func (s *LocalCacheSupplier) SetChainNext(next LayeredStoreSupplier) { |