A C D E F G I J L M O P R S T V W

A

ack() - Method in interface io.atomix.group.messaging.Message

Acknowledges completion of the message.

C

close() - Method in interface io.atomix.group.messaging.MessageConsumer

Closes the consumer.

close() - Method in interface io.atomix.group.messaging.MessageProducer

Closes the producer.

Config() - Constructor for class io.atomix.group.DistributedGroup.Config

Config(Properties) - Constructor for class io.atomix.group.DistributedGroup.Config

consumer(String) - Method in interface io.atomix.group.messaging.MessageService

Creates a new named message consumer.

consumer(String, MessageConsumer.Options) - Method in interface io.atomix.group.messaging.MessageService

Creates a new named message consumer.

createInstance(CopycatClient, Properties) - Method in class io.atomix.group.DistributedGroupFactory

createSerializableTypeResolver() - Method in class io.atomix.group.DistributedGroupFactory

createStateMachine(Properties) - Method in class io.atomix.group.DistributedGroupFactory

D

DistributedGroup - Interface in io.atomix.group

Generic group abstraction for managing group membership, service discovery, leader election, and remote scheduling and execution.

DistributedGroup.Config - Class in io.atomix.group

Configuration for cluster-wide DistributedGroups.

DistributedGroup.Options - Class in io.atomix.group

Distributed group options.

DistributedGroupFactory - Class in io.atomix.group

Distributed group factory.

DistributedGroupFactory() - Constructor for class io.atomix.group.DistributedGroupFactory

E

election() - Method in interface io.atomix.group.DistributedGroup

Returns the group election.

Election - Interface in io.atomix.group.election

Election context for DistributedGroup.

F

fail() - Method in interface io.atomix.group.messaging.Message

Fails processing of the message.

G

getDelivery() - Method in class io.atomix.group.messaging.MessageProducer.Options

Returns the producer delivery policy.

getExecution() - Method in class io.atomix.group.messaging.MessageProducer.Options

Returns the producer execution policy.

GroupMember - Interface in io.atomix.group

A DistributedGroup member representing a member of the group controlled by a local or remote process.

GroupMember.Status - Enum in io.atomix.group

Status constants for indicating whether a member is currently connected to the group.

I

id() - Method in interface io.atomix.group.GroupMember

Returns the member ID.

id() - Method in interface io.atomix.group.messaging.Message

Returns the message ID.

io.atomix.group - package io.atomix.group

Provides distributed group operations tools via DistributedGroup including leader election, direct messaging, tasks queues, partitioning, and remote execution.

io.atomix.group.election - package io.atomix.group.election

io.atomix.group.messaging - package io.atomix.group.messaging

J

join() - Method in interface io.atomix.group.DistributedGroup

Joins the instance to the membership group.

join(String) - Method in interface io.atomix.group.DistributedGroup

Joins the instance to the membership group with a user-provided member ID.

join(Object) - Method in interface io.atomix.group.DistributedGroup

Joins the instance to the membership group with a user-provided member ID.

join(String, Object) - Method in interface io.atomix.group.DistributedGroup

Joins the instance to the membership group with a user-provided member ID.

L

leader() - Method in interface io.atomix.group.election.Term

Returns the leader for the term.

leave() - Method in interface io.atomix.group.LocalMember

Leaves the membership group.

LocalMember - Interface in io.atomix.group

A DistributedGroup member representing a member of the group controlled by the local process.

M

member(String) - Method in interface io.atomix.group.DistributedGroup

Gets a group member by ID.

members() - Method in interface io.atomix.group.DistributedGroup

Gets the collection of all members in the group.

Message<T> - Interface in io.atomix.group.messaging

Represents a reliable message received by a member to be processed and acknowledged.

message() - Method in interface io.atomix.group.messaging.Message

Returns the message value.

MessageClient - Interface in io.atomix.group.messaging

Provides an interface for producing messages to a group or a member of a group.

MessageConsumer<T> - Interface in io.atomix.group.messaging

Consumes messages from a named message queue.

MessageConsumer.Options - Class in io.atomix.group.messaging

Message consumer options.

MessageFailedException - Exception in io.atomix.group.messaging

Exception thrown when a Message fails to be delivered or is explicitly failed by a consumer.

MessageFailedException() - Constructor for exception io.atomix.group.messaging.MessageFailedException

MessageFailedException(String) - Constructor for exception io.atomix.group.messaging.MessageFailedException

MessageFailedException(String, Throwable) - Constructor for exception io.atomix.group.messaging.MessageFailedException

MessageFailedException(Throwable) - Constructor for exception io.atomix.group.messaging.MessageFailedException

MessageProducer<T> - Interface in io.atomix.group.messaging

Produces messages to a remote MessageService queue.

MessageProducer.Delivery - Enum in io.atomix.group.messaging

Delivery policy for defining how messages are delivered to consumers, particularly when producing messages to a group.

MessageProducer.Execution - Enum in io.atomix.group.messaging

Execution policy for defining the criteria for completion of a message produced by a producer.

MessageProducer.Options - Class in io.atomix.group.messaging

Message producer options.

MessageService - Interface in io.atomix.group.messaging

Provides an interface for consuming messages sent either directly or indirectly to a group member.

messaging() - Method in interface io.atomix.group.DistributedGroup

Returns the group message client.

messaging() - Method in interface io.atomix.group.GroupMember

Returns the direct message client for this member.

messaging() - Method in interface io.atomix.group.LocalMember

Returns the local member message service.

metadata() - Method in interface io.atomix.group.GroupMember

Returns the metadata associated with this member.

O

onElection(Consumer<Term>) - Method in interface io.atomix.group.election.Election

Registers an election listener callback.

onJoin(Consumer<GroupMember>) - Method in interface io.atomix.group.DistributedGroup

Adds a listener for members joining the group.

onLeave(Consumer<GroupMember>) - Method in interface io.atomix.group.DistributedGroup

Adds a listener for members leaving the group.

onMessage(Consumer<Message<T>>) - Method in interface io.atomix.group.messaging.MessageConsumer

Registers a listener for messages received by the consumer.

onStatusChange(Consumer<GroupMember.Status>) - Method in interface io.atomix.group.GroupMember

Registers a member status change listener.

Options() - Constructor for class io.atomix.group.DistributedGroup.Options

Options(Properties) - Constructor for class io.atomix.group.DistributedGroup.Options

Options() - Constructor for class io.atomix.group.messaging.MessageConsumer.Options

Options() - Constructor for class io.atomix.group.messaging.MessageProducer.Options

P

producer(String) - Method in interface io.atomix.group.messaging.MessageClient

Returns a new named message producer.

producer(String, MessageProducer.Options) - Method in interface io.atomix.group.messaging.MessageClient

Returns a new named message producer.

R

remove(String) - Method in interface io.atomix.group.DistributedGroup

Removes the member with the given member ID from the group.

reply(Object) - Method in interface io.atomix.group.messaging.Message

Replies to the message.

S

send(T) - Method in interface io.atomix.group.messaging.MessageProducer

Sends a message.

status() - Method in interface io.atomix.group.GroupMember

Returns the member's last known status.

T

term() - Method in interface io.atomix.group.election.Election

Returns the current group term.

Term - Interface in io.atomix.group.election

Represents a unique leader election term.

term() - Method in interface io.atomix.group.election.Term

Returns the term number.

V

valueOf(String) - Static method in enum io.atomix.group.GroupMember.Status

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

valueOf(String) - Static method in enum io.atomix.group.messaging.MessageProducer.Delivery

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

valueOf(String) - Static method in enum io.atomix.group.messaging.MessageProducer.Execution

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

values() - Static method in enum io.atomix.group.GroupMember.Status

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

values() - Static method in enum io.atomix.group.messaging.MessageProducer.Delivery

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

values() - Static method in enum io.atomix.group.messaging.MessageProducer.Execution

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

W

withAutoRecover(boolean) - Method in class io.atomix.group.DistributedGroup.Options

Sets whether to automatically recover sessions and client-side state.

withDelivery(MessageProducer.Delivery) - Method in class io.atomix.group.messaging.MessageProducer.Options

Sets the producer delivery policy.

withExecution(MessageProducer.Execution) - Method in class io.atomix.group.messaging.MessageProducer.Options

Sets the producer execution policy.

withMemberExpiration(Duration) - Method in class io.atomix.group.DistributedGroup.Config

Sets the duration after which to remove persistent members from the group.

A C D E F G I J L M O P R S T V W