Have the server periodically clear out old shards

2014-07-14 18:53:13 -04:00 · 2014-07-14 18:53:13 -04:00 · be250db19b
parent c84f24930f
commit be250db19b
1 changed files with 1 additions and 0 deletions
--- a/server/server.go
+++ b/server/server.go
@ -57,6 +57,7 @@ func NewServer(config *configuration.Configuration) (*Server, error) {
 	clusterConfig.LocalRaftName = raftServer.GetRaftName()
 	clusterConfig.SetShardCreator(raftServer)
 	clusterConfig.CreateFutureShardsAutomaticallyBeforeTimeComes()
+	clusterConfig.PeriodicallyDropShardsWithRetentionPolicies()

 	coord := coordinator.NewCoordinatorImpl(config, raftServer, clusterConfig, metaStore)
 	requestHandler := coordinator.NewProtobufRequestHandler(coord, clusterConfig)