A B C D E F G H I M N R S T U V W

A

addNode(Node) - Method in interface io.atomix.cluster.ManagedClusterMetadataService

Adds the given node to the cluster metadata.

B

bootstrapNodes() - Method in class io.atomix.cluster.ClusterMetadata

Returns the collection of bootstrap nodes.

broadcast(String, M) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Broadcasts a message to all controller nodes.

broadcast(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Broadcasts a message to all controller nodes.

broadcast(String, M) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Broadcasts a message to all controller nodes.

broadcast(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Broadcasts a message to all controller nodes.

broadcastIncludeSelf(String, M) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Broadcasts a message to all controller nodes including self.

broadcastIncludeSelf(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Broadcasts a message to all controller nodes including self.

build() - Method in class io.atomix.cluster.ClusterMetadata.Builder

build() - Method in class io.atomix.cluster.Node.Builder

builder() - Static method in class io.atomix.cluster.ClusterMetadata

Returns a new cluster metadata builder.

Builder() - Constructor for class io.atomix.cluster.ClusterMetadata.Builder

builder() - Static method in class io.atomix.cluster.Node

Returns a new node builder with no ID.

builder(String) - Static method in class io.atomix.cluster.Node

Returns a new node builder.

builder(NodeId) - Static method in class io.atomix.cluster.Node

Returns a new node builder.

C

client(NodeId, Endpoint) - Static method in class io.atomix.cluster.Node

Returns a new client node.

close() - Method in interface io.atomix.cluster.messaging.Subscription

Closes the subscription, causing it to be unregistered.

ClusterEvent - Class in io.atomix.cluster

Describes cluster-related event.

ClusterEvent(ClusterEvent.Type, Node) - Constructor for class io.atomix.cluster.ClusterEvent

Creates an event of a given type and for the specified instance and the current time.

ClusterEvent(ClusterEvent.Type, Node, long) - Constructor for class io.atomix.cluster.ClusterEvent

Creates an event of a given type and for the specified device and time.

ClusterEvent.Type - Enum in io.atomix.cluster

Type of cluster-related events.

ClusterEventingService - Interface in io.atomix.cluster.messaging

Cluster event service.

ClusterEventListener - Interface in io.atomix.cluster

Entity capable of receiving device cluster-related events.

ClusterMessagingService - Interface in io.atomix.cluster.messaging

Service for assisting communications between controller cluster nodes.

ClusterMetadata - Class in io.atomix.cluster

Cluster metadata.

ClusterMetadata(Collection<Node>) - Constructor for class io.atomix.cluster.ClusterMetadata

ClusterMetadata.Builder - Class in io.atomix.cluster

Cluster metadata builder.

ClusterMetadataEvent - Class in io.atomix.cluster

Cluster metadata event.

ClusterMetadataEvent(ClusterMetadataEvent.Type, ClusterMetadata) - Constructor for class io.atomix.cluster.ClusterMetadataEvent

ClusterMetadataEvent(ClusterMetadataEvent.Type, ClusterMetadata, long) - Constructor for class io.atomix.cluster.ClusterMetadataEvent

ClusterMetadataEvent.Type - Enum in io.atomix.cluster

Type of cluster metadata events.

ClusterMetadataEventListener - Interface in io.atomix.cluster

Cluster metadata event listener.

ClusterMetadataService - Interface in io.atomix.cluster

Cluster metadata service.

ClusterService - Interface in io.atomix.cluster

Service for obtaining information about the individual nodes within the controller cluster.

compareTo(NodeId) - Method in class io.atomix.cluster.NodeId

D

data(NodeId, Endpoint) - Static method in class io.atomix.cluster.Node

Returns a new data node.

E

endpoint() - Method in class io.atomix.cluster.Node

Returns the node endpoint.

equals(Object) - Method in class io.atomix.cluster.ClusterEvent

equals(Object) - Method in class io.atomix.cluster.ClusterMetadataEvent

equals(Object) - Method in class io.atomix.cluster.Node

F

from(String) - Static method in class io.atomix.cluster.NodeId

Creates a new cluster node identifier from the specified string.

G

getLocalNode() - Method in interface io.atomix.cluster.ClusterService

Returns the local controller node.

getMetadata() - Method in interface io.atomix.cluster.ClusterMetadataService

Returns the current cluster metadata.

getNode(NodeId) - Method in interface io.atomix.cluster.ClusterService

Returns the specified controller node.

getNodes() - Method in interface io.atomix.cluster.ClusterService

Returns the set of current cluster members.

getState() - Method in class io.atomix.cluster.Node

Returns the node state.

getSubscriptions(String) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Returns a list of subscriptions for the given topic.

H

hashCode() - Method in class io.atomix.cluster.ClusterEvent

hashCode() - Method in class io.atomix.cluster.ClusterMetadataEvent

hashCode() - Method in class io.atomix.cluster.Node

I

id() - Method in class io.atomix.cluster.Node

Returns the instance identifier.

io.atomix.cluster - package io.atomix.cluster

Atomix cluster service.

io.atomix.cluster.messaging - package io.atomix.cluster.messaging

M

ManagedClusterEventingService - Interface in io.atomix.cluster.messaging

Managed cluster event service.

ManagedClusterMessagingService - Interface in io.atomix.cluster.messaging

Managed cluster communicator.

ManagedClusterMetadataService - Interface in io.atomix.cluster

Managed cluster metadata service.

ManagedClusterService - Interface in io.atomix.cluster

Managed cluster.

multicast(String, M, Set<NodeId>) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Multicasts a message to a set of controller nodes.

multicast(String, M, Function<M, byte[]>, Set<NodeId>) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Multicasts a message to a set of controller nodes.

N

Node - Class in io.atomix.cluster

Represents a controller instance as a member in a cluster.

Node.Builder - Class in io.atomix.cluster

Node builder.

Node.State - Enum in io.atomix.cluster

Represents the operational state of the instance.

Node.Type - Enum in io.atomix.cluster

Node type.

NodeId - Class in io.atomix.cluster

Controller cluster identity.

NodeId(String) - Constructor for class io.atomix.cluster.NodeId

Creates a new cluster node identifier from the specified string.

R

removeNode(Node) - Method in interface io.atomix.cluster.ManagedClusterMetadataService

Removes the given node from the cluster metadata.

S

send(String, M) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Sends a message and expects a reply.

send(String, M, Function<M, byte[]>, Function<byte[], R>) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Sends a message and expects a reply.

send(String, M, NodeId) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Sends a message and expects a reply.

send(String, M, Function<M, byte[]>, Function<byte[], R>, NodeId) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Sends a message and expects a reply.

subscribe(String, Function<M, R>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Adds a new subscriber for the specified message topic.

subscribe(String, Function<byte[], M>, Function<M, R>, Function<R, byte[]>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Adds a new subscriber for the specified message topic.

subscribe(String, Function<M, CompletableFuture<R>>) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Adds a new subscriber for the specified message topic.

subscribe(String, Function<byte[], M>, Function<M, CompletableFuture<R>>, Function<R, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Adds a new subscriber for the specified message topic.

subscribe(String, Consumer<M>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Adds a new subscriber for the specified message topic.

subscribe(String, Function<byte[], M>, Consumer<M>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Adds a new subscriber for the specified message topic.

subscribe(String, Function<M, R>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Adds a new subscriber for the specified message subject.

subscribe(String, Function<byte[], M>, Function<M, R>, Function<R, byte[]>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Adds a new subscriber for the specified message subject.

subscribe(String, Function<M, CompletableFuture<R>>) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Adds a new subscriber for the specified message subject.

subscribe(String, Function<byte[], M>, Function<M, CompletableFuture<R>>, Function<R, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Adds a new subscriber for the specified message subject.

subscribe(String, Consumer<M>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Adds a new subscriber for the specified message subject.

subscribe(String, Function<byte[], M>, Consumer<M>, Executor) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Adds a new subscriber for the specified message subject.

Subscription - Interface in io.atomix.cluster.messaging

Message subscription.

T

topic() - Method in interface io.atomix.cluster.messaging.Subscription

Returns the subscription topic.

toString() - Method in class io.atomix.cluster.ClusterEvent

toString() - Method in class io.atomix.cluster.ClusterMetadata

toString() - Method in class io.atomix.cluster.ClusterMetadataEvent

toString() - Method in class io.atomix.cluster.Node

type() - Method in class io.atomix.cluster.Node

Returns the node type.

U

unicast(String, M) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Sends a message to the specified controller node.

unicast(String, M, Function<M, byte[]>) - Method in interface io.atomix.cluster.messaging.ClusterEventingService

Sends a message to the specified controller node.

unicast(String, M, NodeId) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Sends a message to the specified controller node.

unicast(String, M, Function<M, byte[]>, NodeId) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Sends a message to the specified controller node.

unsubscribe(String) - Method in interface io.atomix.cluster.messaging.ClusterMessagingService

Removes a subscriber for the specified message subject.

V

valueOf(String) - Static method in enum io.atomix.cluster.ClusterEvent.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.cluster.ClusterMetadataEvent.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.cluster.Node.State

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.atomix.cluster.Node.Type

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.atomix.cluster.ClusterEvent.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.cluster.ClusterMetadataEvent.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.cluster.Node.State

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.atomix.cluster.Node.Type

Returns an array containing the constants of this enum type, in the order they are declared.

W

withBootstrapNodes(Node...) - Method in class io.atomix.cluster.ClusterMetadata.Builder

Sets the bootstrap nodes.

withBootstrapNodes(Collection<Node>) - Method in class io.atomix.cluster.ClusterMetadata.Builder

Sets the bootstrap nodes.

withEndpoint(Endpoint) - Method in class io.atomix.cluster.Node.Builder

Sets the node endpoint.

withId(NodeId) - Method in class io.atomix.cluster.Node.Builder

Sets the node identifier.

withType(Node.Type) - Method in class io.atomix.cluster.Node.Builder

Sets the node type.

A B C D E F G H I M N R S T U V W