| Package | Description |
|---|---|
| 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 |
| Modifier and Type | Interface and Description |
|---|---|
interface |
LocalMember
A
DistributedGroup member representing a member of the group controlled by the
local process. |
| Modifier and Type | Method and Description |
|---|---|
GroupMember |
DistributedGroup.member(String memberId)
Gets a group member by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GroupMember> |
DistributedGroup.members()
Gets the collection of all members in the group.
|
Listener<GroupMember> |
DistributedGroup.onJoin(Consumer<GroupMember> listener)
Adds a listener for members joining the group.
|
Listener<GroupMember> |
DistributedGroup.onLeave(Consumer<GroupMember> listener)
Adds a listener for members leaving the group.
|
| Modifier and Type | Method and Description |
|---|---|
Listener<GroupMember> |
DistributedGroup.onJoin(Consumer<GroupMember> listener)
Adds a listener for members joining the group.
|
Listener<GroupMember> |
DistributedGroup.onLeave(Consumer<GroupMember> listener)
Adds a listener for members leaving the group.
|
| Modifier and Type | Method and Description |
|---|---|
GroupMember |
Term.leader()
Returns the leader for the term.
|
Copyright © 2013–2017. All rights reserved.