| Package | Description |
|---|---|
| com.hazelcast.cp.internal.datastructures.countdownlatch |
Contains service classes for the Raft-based
ICountDownLatch implementation |
| com.hazelcast.cp.internal.datastructures.lock |
Contains service classes for the Raft-based
FencedLock
and FencedLock implementation |
| com.hazelcast.cp.internal.datastructures.semaphore |
Contains service classes for the Raft-based
ISemaphore implementation |
| com.hazelcast.cp.internal.datastructures.spi.blocking |
Contains the interfaces and abstractions that are implemented / extended
by blocking Raft services, such as Lock, Semaphore, and CountDownLatch
|
| com.hazelcast.internal.metrics.impl |
Contains the
MetricsRegistry implementation. |
| com.hazelcast.spi.impl.operationexecutor |
Contains the
OperationRunner code. |
| com.hazelcast.spi.impl.operationexecutor.impl |
Contains the
OperationExecutorImpl code. |
| com.hazelcast.spi.impl.operationparker.impl |
Contains the implementation code for the
OperationParker. |
| com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
com.hazelcast.spi.impl.operationservice.InternalOperationService implementation. |
| Modifier and Type | Class and Description |
|---|---|
class |
CountDownLatchRegistry
Contains
CountDownLatch resources and manages wait timeouts |
class |
CountDownLatchService
Contains Raft-based count down latch instances
|
| Modifier and Type | Class and Description |
|---|---|
class |
LockService
Contains Raft-based lock instances
|
| Modifier and Type | Class and Description |
|---|---|
class |
SemaphoreRegistry
Contains
Semaphore resources and manages wait timeouts
based on acquire / release requests |
class |
SemaphoreService
Contains Raft-based semaphore instances
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBlockingService<W extends WaitKey,R extends BlockingResource<W>,RR extends ResourceRegistry<W,R>>
Base class for services that maintain blocking resources.
|
class |
ResourceRegistry<W extends WaitKey,R extends BlockingResource<W>>
Base class for registries for blocking resources.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MetricsService
Service collecting the Metrics periodically and publishes them via
MetricsPublishers. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
OperationExecutor
The OperationExecutor is responsible for scheduling work (packets/operations)
to be executed.
|
| Modifier and Type | Class and Description |
|---|---|
class |
OperationExecutorImpl
A
OperationExecutor that schedules:
partition specific operations to a specific partition-operation-thread (using a mod on the partition ID)
non specific operations to generic-operation-threads
The OperationExecutorImpl.execute(Object, int, boolean) accepts an Object instead of a runnable to prevent needing to
create wrapper runnables around tasks. |
| Modifier and Type | Class and Description |
|---|---|
class |
OperationParkerImpl |
class |
WaitSet
The WaitSet is a effectively a set of operations waiting for some condition.
|
| Modifier and Type | Class and Description |
|---|---|
class |
OperationServiceImpl
This is the implementation of the
OperationServiceImpl. |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.