Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Akka.cluster.sharding Classes and Interfaces - 105 results found.
NameDescriptionTypePackageFramework
ClusterShardingClassakka.cluster.shardingAkka
ClusterSharding$This extension provides sharding functionality of actors in a cluster.Classakka.cluster.shardingAkka
ClusterShardingGuardianINTERNAL API.Classakka.cluster.shardingAkka
ClusterShardingGuardian$Classakka.cluster.shardingAkka
ClusterShardingGuardian .StartClassakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .Start$Classakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .StartedClassakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .Started$Classakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .StartProxyClassakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingGuardian .StartProxy$Classakka.cluster.sharding.ClusterShardingGuardianAkka
ClusterShardingMessagesClassakka.cluster.sharding.protobuf.msgAkka
ClusterShardingMessages .ActorRefMessageProtobuf type ActorRefMessageSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ActorRefMessage .BuilderProtobuf type ActorRefMessageConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ActorRefMessageAkka
ClusterShardingMessages .ActorRefMessageOrBuilderrequired string ref = 1;ByteStringgetRefBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .CoordinatorStateProtobuf type CoordinatorStateSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .CoordinatorState .BuilderProtobuf type CoordinatorStaterepeated string regionProxies = 3;Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateAkka
ClusterShardingMessages .CoordinatorState .ShardEntryProtobuf type CoordinatorState.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateAkka
ClusterShardingMessages .CoordinatorState .ShardEntry .BuilderProtobuf type CoordinatorState.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorState.ShardEntryAkka
ClusterShardingMessages .CoordinatorState .ShardEntryOrBuilderrequired string regionRef = 2;ByteStringgetRegionRefBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.CoordinatorStateAkka
ClusterShardingMessages .CoordinatorStateOrBuilderInterfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStartedProtobuf type EntityStartedSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStarted .BuilderProtobuf type EntityStartedConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStartedAkka
ClusterShardingMessages .EntityStartedOrBuilderrequired string entityId = 1;ByteStringgetEntityIdBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStateProtobuf type EntityStateSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityState .BuilderProtobuf type EntityStaterepeated string entities = 1;Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStateAkka
ClusterShardingMessages .EntityStateOrBuilderInterfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStoppedProtobuf type EntityStoppedSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .EntityStopped .BuilderProtobuf type EntityStoppedConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.EntityStoppedAkka
ClusterShardingMessages .EntityStoppedOrBuilderrequired string entityId = 1;ByteStringgetEntityIdBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHomeProtobuf type ShardHomeSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHome .BuilderProtobuf type ShardHomeConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAkka
ClusterShardingMessages .ShardHomeAllocatedProtobuf type ShardHomeAllocatedSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHomeAllocated .BuilderProtobuf type ShardHomeAllocatedConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardHomeAllocatedAkka
ClusterShardingMessages .ShardHomeAllocatedOrBuilderrequired string region = 2;ByteStringgetRegionBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardHomeOrBuilderrequired string region = 2;ByteStringgetRegionBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardIdMessageProtobuf type ShardIdMessageSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardIdMessage .BuilderProtobuf type ShardIdMessageConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardIdMessageAkka
ClusterShardingMessages .ShardIdMessageOrBuilderrequired string shard = 1;ByteStringgetShardBytes()Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardStatsProtobuf type ShardStatsSee Also:Serialized FormClassakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessages .ShardStats .BuilderProtobuf type ShardStatsConstructs the message based on the state of the Builder.Classakka.cluster.sharding.protobuf.msg.ClusterShardingMessages.ShardStatsAkka
ClusterShardingMessages .ShardStatsOrBuilderrequired int32 entityCount = 2;java.Interfaceakka.cluster.sharding.protobuf.msg.ClusterShardingMessagesAkka
ClusterShardingMessageSerializerINTERNAL API: Protobuf serializer of ClusterSharding messages.Classakka.cluster.sharding.protobufAkka
ClusterShardingSettingsparam: role specifies that this entity type requires cluster nodes with a specific role.Classakka.cluster.shardingAkka
ClusterShardingSettings$Classakka.cluster.shardingAkka
ClusterShardingSettings .TuningParametersClassakka.cluster.sharding.ClusterShardingSettingsAkka
DDataShardCoordinatorSingleton coordinator (with state based on ddata) that decides where to allocate shards.Classakka.cluster.shardingAkka
PersistentShard This actor creates children entity actors on demand that it is told to be responsible for.Classakka.cluster.shardingAkka
PersistentShardCoordinatorSingleton coordinator that decides where to allocate shards.Classakka.cluster.shardingAkka
RemoveInternalClusterShardingDataClassakka.cluster.shardingAkka
RemoveInternalClusterShardingData$Utility program that removes the internal data stored with Akka Persistence by the Cluster Sharding coordinator.Classakka.cluster.shardingAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceIdINTERNAL API: Remove all events and snapshots for one specific persistenceId.Classakka.cluster.sharding.RemoveInternalClusterShardingDataAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId$Classakka.cluster.sharding.RemoveInternalClusterShardingDataAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .RemovalsClassakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Removals$Classakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .ResultClassakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
RemoveInternalClusterShardingData .RemoveOnePersistenceId .Result$Classakka.cluster.sharding.RemoveInternalClusterShardingData.RemoveOnePersistenceIdAkka
Shard This actor creates children entity actors on demand that it is told to beSee Also:ClusterSharding extensionClassakka.cluster.shardingAkka
Shard$Classakka.cluster.shardingAkka
Shard .CurrentShardStateClassakka.cluster.sharding.ShardAkka
Shard .CurrentShardState$Classakka.cluster.sharding.ShardAkka
Shard .EntityStartedState change for starting an entity in this ShardSee Also:Serialized FormClassakka.cluster.sharding.ShardAkka
Shard .EntityStarted$Classakka.cluster.sharding.ShardAkka
Shard .EntityStoppedState change for an entity which has terminated.Classakka.cluster.sharding.ShardAkka
Shard .EntityStopped$Classakka.cluster.sharding.ShardAkka
Shard .GetCurrentShardState$Classakka.cluster.sharding.ShardAkka
Shard .GetShardStats$Classakka.cluster.sharding.ShardAkka
Shard .RestartEntityWhen an remembering entities and the entity stops without issuing a Passivate, we restart it after a back off using this message.Classakka.cluster.sharding.ShardAkka
Shard .RestartEntity$Classakka.cluster.sharding.ShardAkka
Shard .ShardStatsClassakka.cluster.sharding.ShardAkka
Shard .ShardStats$Classakka.cluster.sharding.ShardAkka
Shard .StateClassakka.cluster.sharding.ShardAkka
Shard .State$Classakka.cluster.sharding.ShardAkka
Shard .StateChangeA case class which represents a state change for the Shardjava.Interfaceakka.cluster.sharding.ShardAkka
ShardCoordinatorSingleton coordinator that decides where to allocate shards.Classakka.cluster.shardingAkka
ShardCoordinator$Classakka.cluster.shardingAkka
ShardCoordinator .AbstractShardAllocationStrategyJava API: Java implementations of custom shard allocation and rebalancing logic used by the ShardCoordinator should extend this abstract class and implement the two methods.Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .Internal$Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .LeastShardAllocationStrategyThe default implementation of ShardCoordinator.Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .RebalanceWorkerINTERNAL API.Classakka.cluster.sharding.ShardCoordinatorAkka
ShardCoordinator .ShardAllocationStrategy Java implementations should extend ShardCoordinator.Interfaceakka.cluster.sharding.ShardCoordinatorAkka
ShardRegionThis actor creates children entity actors on demand for the shards that it is told to be responsible for.Classakka.cluster.shardingAkka
ShardRegion$Classakka.cluster.shardingAkka
ShardRegion .ClusterShardingStatsReply to ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ClusterShardingStats$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentRegionsReply to GetCurrentRegionsSee Also:Serialized FormClassakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentRegions$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentShardRegionStateReply to ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .CurrentShardRegionState$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetClusterShardingStatsSend this message to the ShardRegion actor to request for ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetClusterShardingStats$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetCurrentRegions$Send this message to the ShardRegion actor to request for ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetShardRegionState$Send this message to a ShardRegion actor instance to request a ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GetShardRegionStats$Send this message to the ShardRegion actor to request for ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .GracefulShutdown$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .HandOffStopperINTERNAL API.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .HashCodeMessageExtractorConvenience implementation of ShardRegion.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .MessageExtractorJava API: Interface of functions to extract entity id, shard id, and the message to send to the entity from anInterfaceakka.cluster.sharding.ShardRegionAkka
ShardRegion .PassivateIf the state of the entities are persistent you may stop entities that are not used to reduce memory consumption.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .Passivate$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardInitializedWe must be sure that a shard is initialized before to start send messages to it.Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardInitialized$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardRegionStatsClassakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardRegionStats$Classakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardStateClassakka.cluster.sharding.ShardRegionAkka
ShardRegion .ShardState$Classakka.cluster.sharding.ShardRegionAkka