Uses of Interface
com.loomcache.server.cluster.PartitionMigrationPipeline.MigrationDataSender
Packages that use PartitionMigrationPipeline.MigrationDataSender
-
Uses of PartitionMigrationPipeline.MigrationDataSender in com.loomcache.server.cluster
Classes in com.loomcache.server.cluster that implement PartitionMigrationPipeline.MigrationDataSenderModifier and TypeClassDescriptionfinal classPartitionMigrationPipeline.MigrationDataSenderthat ships partition data to a target node over TCP with per-chunk ACK + retry (Session 10 ESC-12).Constructors in com.loomcache.server.cluster with parameters of type PartitionMigrationPipeline.MigrationDataSenderModifierConstructorDescriptionPartitionMigrationPipeline(int instanceNumber, DataStructureRegistry registry, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries) PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries) Session 10 ESC-12.3: sharded-aware constructor for the historical one-registry-per-slot mode.PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, IntFunction<Collection<DataStructureRegistry>> registriesForSlot, Function<String, DataStructureRegistry> registryForKey, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)