本文整理了Java中org.neo4j.kernel.impl.util.Dependencies.provideDependency()
方法的一些代码示例,展示了Dependencies.provideDependency()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Dependencies.provideDependency()
方法的具体详情如下:
包路径:org.neo4j.kernel.impl.util.Dependencies
类名称:Dependencies
方法名:provideDependency
暂无
代码示例来源:origin: org.neo4j/neo4j-causal-clustering
replicationModule.getSessionTracker(), lastFlushedStorage );
final Supplier<DatabaseHealth> databaseHealthSupplier = platformModule.dependencies.provideDependency( DatabaseHealth.class );
commandApplicationProcess = new CommandApplicationProcess(
consensusModule.raftLog(),
new CheckPointerService( new CheckpointerSupplier( platformModule.dependencies ), jobScheduler, JobScheduler.Groups.checkPoint );
CatchupServerHandler catchupServerHandler = new RegularCatchupServerHandler( platformModule.monitors,
logProvider, localDatabase::storeId, platformModule.dependencies.provideDependency( TransactionIdStore.class ),
platformModule.dependencies.provideDependency( LogicalTransactionStore.class ), localDatabase::dataSource, localDatabase::isAvailable,
fileSystem, platformModule.pageCache, platformModule.storeCopyCheckPointMutex, snapshotService,
checkPointerService );
代码示例来源:origin: org.neo4j/neo4j-causal-clustering
CatchUpClient catchUpClient = life.add( new CatchUpClient( logProvider, Clocks.systemClock(), inactivityTimeoutMillis, channelInitializer ) );
final Supplier<DatabaseHealth> databaseHealthSupplier = dependencies.provideDependency( DatabaseHealth.class );
int maxBatchSize = config.get( CausalClusteringSettings.read_replica_transaction_applier_batch_size );
BatchingTxApplier batchingTxApplier = new BatchingTxApplier(
maxBatchSize, dependencies.provideDependency( TransactionIdStore.class ), writableCommitProcess,
platformModule.monitors, platformModule.tracers.pageCursorTracerSupplier,
platformModule.versionContextSupplier, logProvider );
platformModule.dependencies.provideDependency( TransactionIdStore.class ),
platformModule.dependencies.provideDependency( LogicalTransactionStore.class ), localDatabase::dataSource, localDatabase::isAvailable,
fileSystem, platformModule.pageCache, platformModule.storeCopyCheckPointMutex, null,
new CheckPointerService( new CheckpointerSupplier( platformModule.dependencies ),
代码示例来源:origin: org.neo4j/neo4j-core-edge
LogProvider userLogProvider = logging.getUserLogProvider();
final Supplier<DatabaseHealth> databaseHealthSupplier = dependencies.provideDependency( DatabaseHealth.class );
platformModule.dependencies.provideDependency( TransactionIdStore.class ),
platformModule.dependencies.provideDependency( LogicalTransactionStore.class ),
localDatabase::dataSource, localDatabase::isAvailable, coreState, config,
platformModule.monitors, new CheckpointerSupplier( platformModule.dependencies ) );
代码示例来源:origin: org.neo4j/neo4j-causal-clustering
final Supplier<DatabaseHealth> databaseHealthSupplier = dependencies.provideDependency( DatabaseHealth.class );
代码示例来源:origin: org.neo4j/neo4j-core-edge
final Supplier<DatabaseHealth> databaseHealthSupplier = dependencies.provideDependency( DatabaseHealth.class );
代码示例来源:origin: org.neo4j/neo4j-core-edge
inactivityTimeoutMillis, monitors ) );
final Supplier<DatabaseHealth> databaseHealthSupplier = dependencies.provideDependency( DatabaseHealth.class );
int maxBatchSize = config.get( CoreEdgeClusterSettings.edge_transaction_applier_batch_size );
BatchingTxApplier batchingTxApplier = new BatchingTxApplier( maxBatchSize,
dependencies.provideDependency( TransactionIdStore.class ),
writableCommitProcess, databaseHealthSupplier, platformModule.monitors, logProvider );
ContinuousJob txApplyJob = new ContinuousJob( platformModule.jobScheduler, new JobScheduler.Group(
内容来源于网络,如有侵权,请联系作者删除!