Package org.apache.cassandra.repair.state

Class ParticipateState

java.lang.Object

org.apache.cassandra.repair.state.AbstractCompletable<TimeUUID>

org.apache.cassandra.repair.state.ParticipateState

All Implemented Interfaces:

Completable<TimeUUID>

public class ParticipateState
extends AbstractCompletable<TimeUUID>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParticipateState.Job
class	ParticipateState.Phase
static enum	ParticipateState.RegisterStatus

Nested classes/interfaces inherited from class org.apache.cassandra.repair.state.AbstractCompletable

AbstractCompletable.BasePhase, AbstractCompletable.BaseSkipPhase, AbstractCompletable.Status

Nested classes/interfaces inherited from interface org.apache.cassandra.repair.state.Completable

Completable.Result

Field Summary

Fields

Modifier and Type	Field	Description
final boolean	global
final boolean	incremental
final InetAddressAndPort	initiator
final ConcurrentMap<RepairJobDesc,ParticipateState.Job>	jobs
final ParticipateState.Phase	phase
final PreviewKind	previewKind
final Collection<Range<Token>>	ranges
final long	repairedAt
final List<TableId>	tableIds

Fields inherited from class org.apache.cassandra.repair.state.AbstractCompletable

clock, id, lastUpdatedAtNs

Constructor Summary

Constructors

Constructor	Description
ParticipateState(Clock clock, InetAddressAndPort initiator, PrepareMessage msg)

Method Summary

Modifier and Type	Method	Description
ParticipateState.Job	getOrCreateJob(RepairJobDesc desc)
boolean	isAccepted()
ParticipateState.Job	job(RepairJobDesc desc)
ParticipateState.RegisterStatus	register(SyncState state)
ParticipateState.RegisterStatus	register(ValidationState state)
SyncState	sync(RepairJobDesc desc, SyncState.Id id)
String	toString()
ValidationState	validation(RepairJobDesc desc)
Collection<UUID>	validationIds()
Collection<ValidationState>	validations()

Methods inherited from class org.apache.cassandra.repair.state.AbstractCompletable

getCompletionStatus, getId, getInitializedAtMillis, getInitializedAtNanos, getLastUpdatedAtMillis, getLastUpdatedAtNanos, getResult, nanosToMillis, onComplete, tryResult, updated

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.cassandra.repair.state.Completable

getDurationMillis, getFailureCause, getSuccessMessage, isComplete

Field Details

initiator

public final InetAddressAndPort initiator

tableIds

public final List<TableId> tableIds

ranges

public final Collection<Range<Token>> ranges

incremental

public final boolean incremental

repairedAt

public final long repairedAt

global

public final boolean global

previewKind

public final PreviewKind previewKind

phase

public final ParticipateState.Phase phase

jobs

public final ConcurrentMap<RepairJobDesc,ParticipateState.Job> jobs

Constructor Details

ParticipateState

public ParticipateState(Clock clock,
 InetAddressAndPort initiator,
 PrepareMessage msg)

Method Details

isAccepted

public boolean isAccepted()

Specified by:

isAccepted in class AbstractCompletable<TimeUUID>

job

@Nullable
public ParticipateState.Job job(RepairJobDesc desc)

getOrCreateJob

public ParticipateState.Job getOrCreateJob(RepairJobDesc desc)

validation

@Nullable
public ValidationState validation(RepairJobDesc desc)

register

public ParticipateState.RegisterStatus register(ValidationState state)

sync

@Nullable
public SyncState sync(RepairJobDesc desc,
 SyncState.Id id)

register

public ParticipateState.RegisterStatus register(SyncState state)

validations

public Collection<ValidationState> validations()

validationIds

public Collection<UUID> validationIds()

toString

public String toString()

Overrides:

toString in class Object