| Package | Description |
|---|---|
| io.atomix.cluster |
Atomix cluster service.
|
| io.atomix.cluster.messaging |
| Modifier and Type | Method and Description |
|---|---|
static NodeId |
NodeId.from(String id)
Creates a new cluster node identifier from the specified string.
|
NodeId |
Node.id()
Returns the instance identifier.
|
| Modifier and Type | Method and Description |
|---|---|
static Node.Builder |
Node.builder(NodeId nodeId)
Returns a new node builder.
|
static Node |
Node.client(NodeId nodeId,
io.atomix.messaging.Endpoint endpoint)
Returns a new client node.
|
int |
NodeId.compareTo(NodeId that) |
static Node |
Node.data(NodeId nodeId,
io.atomix.messaging.Endpoint endpoint)
Returns a new data node.
|
Node |
ClusterService.getNode(NodeId nodeId)
Returns the specified controller node.
|
Node.Builder |
Node.Builder.withId(NodeId id)
Sets the node identifier.
|
| Modifier and Type | Method and Description |
|---|---|
<M,R> CompletableFuture<R> |
ClusterMessagingService.send(String subject,
M message,
Function<M,byte[]> encoder,
Function<byte[],R> decoder,
NodeId toNodeId)
Sends a message and expects a reply.
|
default <M,R> CompletableFuture<R> |
ClusterMessagingService.send(String subject,
M message,
NodeId toNodeId)
Sends a message and expects a reply.
|
<M> CompletableFuture<Void> |
ClusterMessagingService.unicast(String subject,
M message,
Function<M,byte[]> encoder,
NodeId toNodeId)
Sends a message to the specified controller node.
|
default <M> CompletableFuture<Void> |
ClusterMessagingService.unicast(String subject,
M message,
NodeId toNodeId)
Sends a message to the specified controller node.
|
| Modifier and Type | Method and Description |
|---|---|
<M> void |
ClusterMessagingService.multicast(String subject,
M message,
Function<M,byte[]> encoder,
Set<NodeId> nodeIds)
Multicasts a message to a set of controller nodes.
|
default <M> void |
ClusterMessagingService.multicast(String subject,
M message,
Set<NodeId> nodeIds)
Multicasts a message to a set of controller nodes.
|
Copyright © 2013–2018. All rights reserved.