org.neo4j.kernel.impl.util.Dependencies.provideDependency()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(3.6k)|赞(0)|评价(0)|浏览(113)

本文整理了Java中org.neo4j.kernel.impl.util.Dependencies.provideDependency()方法的一些代码示例,展示了Dependencies.provideDependency()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Dependencies.provideDependency()方法的具体详情如下:
包路径:org.neo4j.kernel.impl.util.Dependencies
类名称:Dependencies
方法名:provideDependency

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(

相关文章