Skip to content

Commit

Permalink
lower default refresh timings
Browse files Browse the repository at this point in the history
  • Loading branch information
martinfurmanski committed Feb 28, 2017
1 parent 66ca3ad commit c867aff
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -314,25 +314,25 @@ public class CausalClusteringSettings implements LoadableConfig

@Description( "Time between scanning the cluster to refresh current server's view of topology" )
public static final Setting<Long> cluster_topology_refresh =
setting( "causal_clustering.cluster_topology_refresh", DURATION, "1m", min( 1_000L ) );
setting( "causal_clustering.cluster_topology_refresh", DURATION, "5s", min( 1_000L ) );

@Description( "An ordered list in descending preference of the strategy which read replicas use to choose " +
"upstream database server from which to pull transactional updates." )
public static final Setting<List<String>> upstream_selection_strategy =
setting( "causal_clustering.upstream_selection_strategy", list( ",", STRING ), "default" );

@Description( "Tags for the server used when configuring load balancing and replication policies." )
public static Setting<List<String>> server_tags =
public static final Setting<List<String>> server_tags =
setting( "causal_clustering.server_tags", list( ",", STRING ), "" );

@Description( "The load balancing plugin to use." )
public static Setting<String> load_balancing_plugin =
public static final Setting<String> load_balancing_plugin =
setting( "causal_clustering.load_balancing.plugin", STRING, "server_policies" );

@Description( "The configuration must be valid for the configured plugin and usually exists" +
"under matching subkeys, e.g. ..config.server_policies.*" +
"This is just a top-level placeholder for the plugin-specific configuration." )
public static Setting<String> load_balancing_config =
public static final Setting<String> load_balancing_config =
setting( "causal_clustering.load_balancing.config", STRING, "" );

@Description( "Enables shuffling of the returned load balancing result." )
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,9 @@
import org.neo4j.kernel.configuration.BoltConnector;
import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.configuration.HttpConnector;
import org.neo4j.kernel.configuration.HttpConnector.Encryption;
import org.neo4j.kernel.configuration.Settings;
import org.neo4j.logging.Level;
import org.neo4j.kernel.configuration.HttpConnector.Encryption;

import static java.lang.String.format;
import static java.util.stream.Collectors.joining;
Expand Down Expand Up @@ -86,6 +86,7 @@ public CoreClusterMember( int serverId, int clusterSize,
config.put( CausalClusteringSettings.discovery_listen_address.name(), "127.0.0.1:" + hazelcastPort );
config.put( CausalClusteringSettings.transaction_listen_address.name(), "127.0.0.1:" + txPort );
config.put( CausalClusteringSettings.raft_listen_address.name(), "127.0.0.1:" + raftPort );
config.put( CausalClusteringSettings.cluster_topology_refresh.name(), "1000ms" );
config.put( CausalClusteringSettings.expected_core_cluster_size.name(), String.valueOf( clusterSize ) );
config.put( CausalClusteringSettings.leader_election_timeout.name(), "500ms" );
config.put( CausalClusteringSettings.raft_messages_log_enable.name(), Settings.TRUE );
Expand Down Expand Up @@ -118,6 +119,7 @@ public CoreClusterMember( int serverId, int clusterSize,
clusterStateDir = ClusterStateDirectory.withoutInitializing( dataDir ).get();
raftLogDir = new File( clusterStateDir, RAFT_LOG_DIRECTORY_NAME );
storeDir = new File( new File( dataDir, "databases" ), "graph.db" );
//noinspection ResultOfMethodCallIgnored
storeDir.mkdirs();
}

Expand Down

0 comments on commit c867aff

Please sign in to comment.