Uses of Class
org.apache.cassandra.locator.InetAddressAndPort
-
-
Uses of InetAddressAndPort in org.apache.cassandra.audit
Methods in org.apache.cassandra.audit that return InetAddressAndPort Modifier and Type Method Description InetAddressAndPortAuditLogEntry. getHost()InetAddressAndPortAuditLogEntry. getSource() -
Uses of InetAddressAndPort in org.apache.cassandra.config
Methods in org.apache.cassandra.config that return InetAddressAndPort Modifier and Type Method Description static InetAddressAndPortDatabaseDescriptor. getReplaceAddress()Methods in org.apache.cassandra.config that return types with arguments of type InetAddressAndPort Modifier and Type Method Description static java.util.Set<InetAddressAndPort>DatabaseDescriptor. getSeeds()Methods in org.apache.cassandra.config with parameters of type InetAddressAndPort Modifier and Type Method Description booleanEncryptionOptions.ServerEncryptionOptions. shouldEncrypt(InetAddressAndPort endpoint) -
Uses of InetAddressAndPort in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 with parameters of type InetAddressAndPort Modifier and Type Method Description static Future<UntypedResultSet>QueryProcessor. executeAsync(InetAddressAndPort address, java.lang.String query, java.lang.Object... values) -
Uses of InetAddressAndPort in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return InetAddressAndPort Modifier and Type Method Description static InetAddressAndPortSystemKeyspace. getPreferredIP(InetAddressAndPort ep)Get preferred IP for given endpoint if it is known.Methods in org.apache.cassandra.db that return types with arguments of type InetAddressAndPort Modifier and Type Method Description static java.util.Map<InetAddressAndPort,java.util.Set<Range<Token>>>SystemKeyspace. getTransferredRanges(java.lang.String description, java.lang.String keyspace, IPartitioner partitioner)static java.util.Map<InetAddressAndPort,java.util.Map<java.lang.String,java.lang.String>>SystemKeyspace. loadDcRackInfo()Return a map of IP addresses containing a map of dc and rack infostatic java.util.Map<InetAddressAndPort,java.util.UUID>SystemKeyspace. loadHostIds()Return a map of store host_ids to IP addressesstatic com.google.common.collect.SetMultimap<InetAddressAndPort,Token>SystemKeyspace. loadTokens()Return a map of stored tokens to IP addressesMethods in org.apache.cassandra.db with parameters of type InetAddressAndPort Modifier and Type Method Description protected voidCounterMutationVerbHandler. applyMutation(Message<CounterMutation> message, InetAddressAndPort respondToAddress)protected voidMutationVerbHandler. applyMutation(Message<Mutation> message, InetAddressAndPort respondToAddress)static InetAddressAndPortSystemKeyspace. getPreferredIP(InetAddressAndPort ep)Get preferred IP for given endpoint if it is known.static CassandraVersionSystemKeyspace. getReleaseVersion(InetAddressAndPort ep)Get release version for given endpoint.voidAbstractMutationVerbHandler. processMessage(Message<T> message, InetAddressAndPort respondTo)static voidSystemKeyspace. updateHintsDropped(InetAddressAndPort ep, TimeUUID timePeriod, int value)static voidSystemKeyspace. updatePeerInfo(InetAddressAndPort ep, java.lang.String columnName, java.lang.Object value)static voidSystemKeyspace. updatePeerNativeAddress(InetAddressAndPort ep, InetAddressAndPort address)static booleanSystemKeyspace. updatePreferredIP(InetAddressAndPort ep, InetAddressAndPort preferred_ip)static voidSystemKeyspace. updateTokens(InetAddressAndPort ep, java.util.Collection<Token> tokens)Record tokens being used by another nodestatic voidSystemKeyspace. updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, java.lang.String keyspace, java.util.Collection<Range<Token>> streamedRanges) -
Uses of InetAddressAndPort in org.apache.cassandra.db.guardrails
Fields in org.apache.cassandra.db.guardrails with type parameters of type InetAddressAndPort Modifier and Type Field Description static Predicates<InetAddressAndPort>Guardrails. replicaDiskUsageGuardrail on the data disk usage on replicas, used at write time to verify the status of the involved replicas. -
Uses of InetAddressAndPort in org.apache.cassandra.db.transform
Method parameters in org.apache.cassandra.db.transform with type arguments of type InetAddressAndPort Modifier and Type Method Description static PartitionIteratorDuplicateRowChecker. duringRead(PartitionIterator iterator, java.util.List<InetAddressAndPort> replicas) -
Uses of InetAddressAndPort in org.apache.cassandra.dht
Fields in org.apache.cassandra.dht declared as InetAddressAndPort Modifier and Type Field Description protected InetAddressAndPortBootStrapper. addressMethods in org.apache.cassandra.dht that return types with arguments of type InetAddressAndPort Modifier and Type Method Description static com.google.common.collect.Multimap<InetAddressAndPort,RangeStreamer.FetchReplica>RangeStreamer. convertPreferredEndpointsToWorkMap(EndpointsByReplica preferredEndpoints)The preferred endpoint list is the wrong format because it is keyed by Replica (this node) rather than the source endpoint we will fetch from which streaming wants.com.google.common.collect.Multimap<InetAddressAndPort,Range<Token>>RangeFetchMapCalculator. getRangeFetchMap()Methods in org.apache.cassandra.dht with parameters of type InetAddressAndPort Modifier and Type Method Description static java.util.Collection<Token>BootStrapper. getBootstrapTokens(TokenMetadata metadata, InetAddressAndPort address, long schemaTimeoutMillis, long ringTimeoutMillis)if initialtoken was specified, use that (split on comma).booleanOwnedRanges. validateRangeRequest(java.util.Collection<Range<Token>> requestedRanges, java.lang.String requestId, java.lang.String requestType, InetAddressAndPort from)Check that all ranges in a requested set are contained by those in the owned set.Method parameters in org.apache.cassandra.dht with type arguments of type InetAddressAndPort Modifier and Type Method Description static EndpointsByReplicaRangeStreamer. calculateRangesToFetchWithPreferredEndpoints(java.util.function.BiFunction<InetAddressAndPort,EndpointsForRange,EndpointsForRange> snitchGetSortedListByProximity, AbstractReplicationStrategy strat, ReplicaCollection<?> fetchRanges, boolean useStrictConsistency, TokenMetadata tmdBefore, TokenMetadata tmdAfter, java.lang.String keyspace, java.util.Collection<RangeStreamer.SourceFilter> sourceFilters)Get a map of all ranges and the source that will be cleaned up once this bootstrapped node is added for the given ranges.Constructors in org.apache.cassandra.dht with parameters of type InetAddressAndPort Constructor Description BootStrapper(InetAddressAndPort address, java.util.Collection<Token> tokens, TokenMetadata tmd)RangeStreamer(TokenMetadata metadata, java.util.Collection<Token> tokens, InetAddressAndPort address, StreamOperation streamOperation, boolean useStrictConsistency, IEndpointSnitch snitch, StreamStateStore stateStore, boolean connectSequentially, int connectionsPerHost)Constructor parameters in org.apache.cassandra.dht with type arguments of type InetAddressAndPort Constructor Description AllowedSourcesFilter(java.util.Set<InetAddressAndPort> allowedSources) -
Uses of InetAddressAndPort in org.apache.cassandra.dht.tokenallocator
Methods in org.apache.cassandra.dht.tokenallocator that return types with arguments of type InetAddressAndPort Modifier and Type Method Description static TokenAllocator<InetAddressAndPort>TokenAllocatorFactory. createTokenAllocator(java.util.NavigableMap<Token,InetAddressAndPort> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<InetAddressAndPort> strategy, IPartitioner partitioner)Methods in org.apache.cassandra.dht.tokenallocator with parameters of type InetAddressAndPort Modifier and Type Method Description static java.util.Collection<Token>TokenAllocation. allocateTokens(TokenMetadata tokenMetadata, int replicas, InetAddressAndPort endpoint, int numTokens)static java.util.Collection<Token>TokenAllocation. allocateTokens(TokenMetadata tokenMetadata, AbstractReplicationStrategy rs, InetAddressAndPort endpoint, int numTokens)Method parameters in org.apache.cassandra.dht.tokenallocator with type arguments of type InetAddressAndPort Modifier and Type Method Description static TokenAllocator<InetAddressAndPort>TokenAllocatorFactory. createTokenAllocator(java.util.NavigableMap<Token,InetAddressAndPort> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<InetAddressAndPort> strategy, IPartitioner partitioner)static TokenAllocator<InetAddressAndPort>TokenAllocatorFactory. createTokenAllocator(java.util.NavigableMap<Token,InetAddressAndPort> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<InetAddressAndPort> strategy, IPartitioner partitioner)Constructors in org.apache.cassandra.dht.tokenallocator with parameters of type InetAddressAndPort Constructor Description FakeNode(InetAddressAndPort address, java.lang.Integer rackId, java.util.Collection<Token> tokens) -
Uses of InetAddressAndPort in org.apache.cassandra.exceptions
Fields in org.apache.cassandra.exceptions with type parameters of type InetAddressAndPort Modifier and Type Field Description java.util.Map<InetAddressAndPort,RequestFailureReason>RequestFailureException. failureReasonByEndpointConstructor parameters in org.apache.cassandra.exceptions with type arguments of type InetAddressAndPort Constructor Description ReadAbortException(java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)ReadFailureException(java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)ReadFailureException(ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)ReadSizeAbortException(java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)RequestFailureException(ExceptionCode code, java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)RequestFailureException(ExceptionCode code, ConsistencyLevel consistency, int received, int blockFor, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)TombstoneAbortException(int nodes, long tombstones, java.lang.String cql, boolean dataPresent, ConsistencyLevel consistency, int received, int blockFor, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)WriteFailureException(ConsistencyLevel consistency, int received, int blockFor, WriteType writeType, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint) -
Uses of InetAddressAndPort in org.apache.cassandra.gms
Fields in org.apache.cassandra.gms with type parameters of type InetAddressAndPort Modifier and Type Field Description java.util.concurrent.ConcurrentMap<InetAddressAndPort,EndpointState>Gossiper. endpointStateMapstatic java.util.function.Predicate<InetAddressAndPort>FailureDetector. isEndpointAliveMethods in org.apache.cassandra.gms that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Map<InetAddressAndPort,EndpointState>Gossiper. doShadowRound()java.util.Map<InetAddressAndPort,EndpointState>Gossiper. doShadowRound(java.util.Set<InetAddressAndPort> peers)Do a single 'shadow' round of gossip by retrieving endpoint states that will be stored exclusively in the map return value, instead of endpointStateMap.com.google.common.collect.ImmutableSet<InetAddressAndPort>Gossiper. getEndpoints()java.util.Set<InetAddressAndPort>Gossiper. getLiveMembers()java.util.Set<InetAddressAndPort>Gossiper. getLiveTokenOwners()java.util.Set<InetAddressAndPort>Gossiper. getUnreachableMembers()java.util.Set<InetAddressAndPort>Gossiper. getUnreachableTokenOwners()java.util.Collection<InetAddressAndPort>Gossiper. unsafeClearRemoteState()Methods in org.apache.cassandra.gms with parameters of type InetAddressAndPort Modifier and Type Method Description voidGossiper. addExpireTimeForEndpoint(InetAddressAndPort endpoint, long expireTime)voidGossiper. addSavedEndpoint(InetAddressAndPort ep)Add an endpoint we knew about previously, but whose state is unknownvoidGossiper. advertiseRemoving(InetAddressAndPort endpoint, java.util.UUID hostId, java.util.UUID localHostId)This method will begin removing an existing endpoint from the cluster by spoofing its state This should never be called unless this coordinator has had 'removenode' invokedvoidGossiper. advertiseTokenRemoved(InetAddressAndPort endpoint, java.util.UUID hostId)Handles switching the endpoint's state from REMOVING_TOKEN to REMOVED_TOKEN This should only be called after advertiseRemovingdefault voidIEndpointStateChangeSubscriber. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)VersionedValueVersionedValue.VersionedValueFactory. bootReplacingWithPort(InetAddressAndPort oldNode)intGossiper. compareEndpointStartup(InetAddressAndPort addr1, InetAddressAndPort addr2)determine which endpoint started up earliervoidGossiper. convict(InetAddressAndPort endpoint, double phi)This method is part of IFailureDetectionEventListener interface.voidIFailureDetectionEventListener. convict(InetAddressAndPort ep, double phi)Convict the specified endpoint.EndpointStateGossiper. copyEndpointStateForEndpoint(InetAddressAndPort ep)voidGossiper. doOnChangeNotifications(InetAddressAndPort addr, ApplicationState state, VersionedValue value)voidFailureDetector. forceConviction(InetAddressAndPort ep)voidIFailureDetector. forceConviction(InetAddressAndPort ep)force conviction of endpoint in the failure detectorjava.lang.StringGossiper. getApplicationState(InetAddressAndPort endpoint, ApplicationState state)The value for the provided application state for the provided endpoint as currently known by this Gossip instance.intGossiper. getCurrentGenerationNumber(InetAddressAndPort endpoint)longGossiper. getEndpointDowntime(InetAddressAndPort ep)EndpointStateGossiper. getEndpointStateForEndpoint(InetAddressAndPort ep)protected longGossiper. getExpireTimeForEndpoint(InetAddressAndPort endpoint)java.lang.StringGossiper. getForEndpoint(InetAddressAndPort ep, ApplicationState state)java.util.UUIDGossiper. getHostId(InetAddressAndPort endpoint)java.util.UUIDGossiper. getHostId(InetAddressAndPort endpoint, java.util.Map<InetAddressAndPort,EndpointState> epStates)CassandraVersionGossiper. getReleaseVersion(InetAddressAndPort ep)java.util.UUIDGossiper. getSchemaVersion(InetAddressAndPort ep)voidGossiper. initializeNodeUnsafe(InetAddressAndPort addr, java.util.UUID uuid, int generationNbr)voidGossiper. initializeNodeUnsafe(InetAddressAndPort addr, java.util.UUID uuid, int netVersion, int generationNbr)voidGossiper. initializeUnreachableNodeUnsafe(InetAddressAndPort addr)Creates a new deadEndpointStatethat isempty.voidGossiper. injectApplicationState(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)booleanGossiper. inJustRemovedEndpoints(InetAddressAndPort ep)VersionedValueVersionedValue.VersionedValueFactory. internalAddressAndPort(InetAddressAndPort private_ip_and_port)voidFailureDetector. interpret(InetAddressAndPort ep)voidIFailureDetector. interpret(InetAddressAndPort ep)This method is invoked by any entity wanting to interrogate the status of an endpoint.booleanGossiper. isAdministrativelyInactiveState(InetAddressAndPort endpoint)booleanFailureDetector. isAlive(InetAddressAndPort ep)booleanGossiper. isAlive(InetAddressAndPort endpoint)booleanIFailureDetector. isAlive(InetAddressAndPort ep)Failure Detector's knowledge of whether a node is up or down.booleanGossiper. isGossipOnlyMember(InetAddressAndPort endpoint)booleanGossiper. isKnownEndpoint(InetAddressAndPort endpoint)booleanGossiper. isSafeForStartup(InetAddressAndPort endpoint, java.util.UUID localHostUUID, boolean isBootstrapping, java.util.Map<InetAddressAndPort,EndpointState> epStates)Check if this node can safely be started and join the ring.protected voidGossiper. markAsShutdown(InetAddressAndPort endpoint)This method is used to mark a node as shutdown; that is it gracefully exited on its own and told us about itvoidGossiper. markDead(InetAddressAndPort addr, EndpointState localState)protected voidGossiper. maybeFinishShadowRound(InetAddressAndPort respondent, boolean isInShadowRound, java.util.Map<InetAddressAndPort,EndpointState> epStateMap)VersionedValueVersionedValue.VersionedValueFactory. nativeaddressAndPort(InetAddressAndPort address)default voidIEndpointStateChangeSubscriber. onAlive(InetAddressAndPort endpoint, EndpointState state)default voidIEndpointStateChangeSubscriber. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)default voidIEndpointStateChangeSubscriber. onDead(InetAddressAndPort endpoint, EndpointState state)default voidIEndpointStateChangeSubscriber. onJoin(InetAddressAndPort endpoint, EndpointState epState)Use to inform interested parties about the change in the state for specified endpointdefault voidIEndpointStateChangeSubscriber. onRemove(InetAddressAndPort endpoint)default voidIEndpointStateChangeSubscriber. onRestart(InetAddressAndPort endpoint, EndpointState state)Called whenever a node is restarted.voidGossiper. realMarkAlive(InetAddressAndPort addr, EndpointState localState)voidFailureDetector. remove(InetAddressAndPort ep)voidIFailureDetector. remove(InetAddressAndPort ep)remove endpoint from failure detectorvoidGossiper. removeEndpoint(InetAddressAndPort endpoint)Removes the endpoint from Gossip but retains endpoint statevoidGossiper. replacedEndpoint(InetAddressAndPort endpoint)Remove the Endpoint and evict immediately, to avoid gossiping about this node.voidGossiper. replacementQuarantine(InetAddressAndPort endpoint)Quarantine endpoint specifically for replacement purposes.voidFailureDetector. report(InetAddressAndPort ep)voidIFailureDetector. report(InetAddressAndPort ep)This method is invoked by the receiver of the heartbeat.voidGossiper. unsafeAnnulEndpoint(InetAddressAndPort endpoint)voidGossiper. unsafeGossipWith(InetAddressAndPort ep)voidGossiper. unsafeSendLocalEndpointStateTo(InetAddressAndPort ep)voidGossiper. unsafeSendShutdown(InetAddressAndPort to)Method parameters in org.apache.cassandra.gms with type arguments of type InetAddressAndPort Modifier and Type Method Description voidGossiper. applyStateLocally(java.util.Map<InetAddressAndPort,EndpointState> epStateMap)java.util.Map<InetAddressAndPort,EndpointState>Gossiper. doShadowRound(java.util.Set<InetAddressAndPort> peers)Do a single 'shadow' round of gossip by retrieving endpoint states that will be stored exclusively in the map return value, instead of endpointStateMap.java.util.UUIDGossiper. getHostId(InetAddressAndPort endpoint, java.util.Map<InetAddressAndPort,EndpointState> epStates)booleanGossiper. isSafeForStartup(InetAddressAndPort endpoint, java.util.UUID localHostUUID, boolean isBootstrapping, java.util.Map<InetAddressAndPort,EndpointState> epStates)Check if this node can safely be started and join the ring.protected voidGossiper. maybeFinishShadowRound(InetAddressAndPort respondent, boolean isInShadowRound, java.util.Map<InetAddressAndPort,EndpointState> epStateMap)voidGossiper. notifyFailureDetector(java.util.Map<InetAddressAndPort,EndpointState> remoteEpStateMap)booleanGossiper. sufficientForStartupSafetyCheck(java.util.Map<InetAddressAndPort,EndpointState> epStateMap) -
Uses of InetAddressAndPort in org.apache.cassandra.hadoop.cql3
Fields in org.apache.cassandra.hadoop.cql3 with type parameters of type InetAddressAndPort Modifier and Type Field Description protected java.util.Set<InetAddressAndPort>CqlBulkRecordWriter. ignores -
Uses of InetAddressAndPort in org.apache.cassandra.hints
Methods in org.apache.cassandra.hints with parameters of type InetAddressAndPort Modifier and Type Method Description voidHintsService. deleteAllHintsForEndpoint(InetAddressAndPort target)Deletes all hints for the provided destination. -
Uses of InetAddressAndPort in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Map<InetAddressAndPort,java.util.Collection<Range<Token>>>SSTableLoader.Client. getEndpointToRangesMap()java.util.Set<InetAddressAndPort>SSTableLoader. getFailedHosts()Methods in org.apache.cassandra.io.sstable with parameters of type InetAddressAndPort Modifier and Type Method Description protected voidSSTableLoader.Client. addRangeForEndpoint(Range<Token> range, InetAddressAndPort endpoint)Method parameters in org.apache.cassandra.io.sstable with type arguments of type InetAddressAndPort Modifier and Type Method Description protected java.util.Collection<SSTableReader>SSTableLoader. openSSTables(java.util.Map<InetAddressAndPort,java.util.Collection<Range<Token>>> ranges)StreamResultFutureSSTableLoader. stream(java.util.Set<InetAddressAndPort> toIgnore, StreamEventHandler... listeners) -
Uses of InetAddressAndPort in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return InetAddressAndPort Modifier and Type Method Description InetAddressAndPortInetAddressAndPort.FwdFrmSerializer. deserialize(DataInputPlus in, int version)InetAddressAndPortInetAddressAndPort.Serializer. deserialize(DataInputPlus in, int version)InetAddressAndPortEndpoints. endpoint(int i)InetAddressAndPortRangesAtEndpoint. endpoint()InetAddressAndPortReplica. endpoint()InetAddressAndPortInetAddressAndPort.Serializer. extract(java.nio.ByteBuffer buf, int position)ExtractInetAddressAndPortfrom the providedByteBufferwithout altering its state.static InetAddressAndPortInetAddressAndPort. getByAddress(byte[] address)static InetAddressAndPortInetAddressAndPort. getByAddress(java.net.InetAddress address)static InetAddressAndPortInetAddressAndPort. getByAddress(java.net.InetSocketAddress address)static InetAddressAndPortInetAddressAndPort. getByAddressOverrideDefaults(java.net.InetAddress address, byte[] addressBytes, java.lang.Integer port)static InetAddressAndPortInetAddressAndPort. getByAddressOverrideDefaults(java.net.InetAddress address, java.lang.Integer port)static InetAddressAndPortInetAddressAndPort. getByName(java.lang.String name)static InetAddressAndPortInetAddressAndPort. getByNameOverrideDefaults(java.lang.String name, java.lang.Integer port)InetAddressAndPortTokenMetadata. getEndpoint(Token token)InetAddressAndPortTokenMetadata. getEndpointForHostId(java.util.UUID hostId)Return the end-point for a unique host IDstatic InetAddressAndPortInetAddressAndPort. getLocalHost()static InetAddressAndPortInetAddressAndPort. getLoopbackAddress()InetAddressAndPortInetAddressAndPort.FwdFrmSerializer. pre40DeserializeWithLength(DataInputPlus in, int version, int length)InetAddressAndPortInetAddressAndPort. withPort(int port)Methods in org.apache.cassandra.locator that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Map<InetAddressAndPort,Replica>Endpoints. byEndpoint()java.util.List<InetAddressAndPort>Endpoints. endpointList()java.util.Set<InetAddressAndPort>Endpoints. endpoints()static java.util.function.Predicate<InetAddressAndPort>InOurDc. endpoints()java.util.Set<InetAddressAndPort>RangesAtEndpoint. endpoints()java.util.Set<InetAddressAndPort>ReplicaCollection. endpoints()static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpoints(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints)static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpointsDynamic(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints, java.util.function.Predicate<InetAddressAndPort> isAlive)static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpointsRandom(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints, java.util.function.Consumer<java.util.List<?>> shuffle, java.util.function.Predicate<InetAddressAndPort> isAlive, java.util.function.Function<java.lang.Integer,java.lang.Integer> indexPicker)java.util.Set<InetAddressAndPort>TokenMetadata. getAllEndpoints()java.util.Set<InetAddressAndPort>TokenMetadata. getAllMembers()BiMultiValMap<Token,InetAddressAndPort>TokenMetadata. getBootstrapTokens()com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort>TokenMetadata.Topology. getDatacenterEndpoints()com.google.common.collect.ImmutableMap<java.lang.String,com.google.common.collect.ImmutableMultimap<java.lang.String,InetAddressAndPort>>TokenMetadata.Topology. getDatacenterRacks()com.google.common.collect.ImmutableMultimap<java.lang.String,InetAddressAndPort>TokenMetadata. getDC2AllEndpoints(IEndpointSnitch snitch)java.util.Map<InetAddressAndPort,java.util.UUID>TokenMetadata. getEndpointToHostIdMapForReading()com.google.common.collect.Multimap<InetAddressAndPort,Token>TokenMetadata. getEndpointToTokenMapForReading()java.util.Set<InetAddressAndPort>TokenMetadata. getLeavingEndpoints()caller should not modify leavingEndpointsjava.util.Set<Pair<Token,InetAddressAndPort>>TokenMetadata. getMovingEndpoints()Endpoints which are migrating to the new tokensjava.util.Map<Token,InetAddressAndPort>TokenMetadata. getNormalAndBootstrappingTokenToEndpointMap()java.util.Optional<InetAddressAndPort>TokenMetadata. getReplacementNode(InetAddressAndPort endpoint)java.util.Optional<InetAddressAndPort>TokenMetadata. getReplacingNode(InetAddressAndPort endpoint)java.util.List<InetAddressAndPort>SeedProvider. getSeeds()java.util.List<InetAddressAndPort>SimpleSeedProvider. getSeeds()static java.util.List<InetAddressAndPort>ReplicaPlans. sortByProximity(java.util.Collection<InetAddressAndPort> endpoints)Methods in org.apache.cassandra.locator with parameters of type InetAddressAndPort Modifier and Type Method Description voidTokenMetadata. addBootstrapToken(Token token, InetAddressAndPort endpoint)Deprecated.voidTokenMetadata. addBootstrapTokens(java.util.Collection<Token> tokens, InetAddressAndPort endpoint)voidTokenMetadata. addLeavingEndpoint(InetAddressAndPort endpoint)voidTokenMetadata. addMovingEndpoint(Token token, InetAddressAndPort endpoint)Add a new moving endpointvoidTokenMetadata. addReplaceTokens(java.util.Collection<Token> replacingTokens, InetAddressAndPort newNode, InetAddressAndPort oldNode)voidReconnectableSnitchHelper. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)static RangesAtEndpoint.BuilderRangesAtEndpoint. builder(InetAddressAndPort endpoint)static RangesAtEndpoint.BuilderRangesAtEndpoint. builder(InetAddressAndPort endpoint, int capacity)static java.util.stream.Collector<Replica,RangesAtEndpoint.Builder,RangesAtEndpoint>RangesAtEndpoint. collector(InetAddressAndPort endpoint)abstract intAbstractEndpointSnitch. compareEndpoints(InetAddressAndPort target, Replica r1, Replica r2)intAbstractNetworkTopologySnitch. compareEndpoints(InetAddressAndPort address, Replica r1, Replica r2)intDynamicEndpointSnitch. compareEndpoints(InetAddressAndPort target, Replica a1, Replica a2)intIEndpointSnitch. compareEndpoints(InetAddressAndPort target, Replica r1, Replica r2)compares two endpoints in relation to the target endpoint, returning as Comparator.compare wouldintSimpleSnitch. compareEndpoints(InetAddressAndPort target, Replica r1, Replica r2)intInetAddressAndPort. compareTo(InetAddressAndPort o)booleanEndpoints. contains(InetAddressAndPort endpoint)static RangesAtEndpointRangesAtEndpoint. empty(InetAddressAndPort endpoint)static ReplicaReplica. fullReplica(InetAddressAndPort endpoint, Range<Token> range)static ReplicaReplica. fullReplica(InetAddressAndPort endpoint, Token start, Token end)RangesAtEndpointRangesByEndpoint. get(InetAddressAndPort endpoint)RangesAtEndpointAbstractReplicationStrategy. getAddressReplicas(InetAddressAndPort endpoint)RangesAtEndpointAbstractReplicationStrategy. getAddressReplicas(TokenMetadata metadata, InetAddressAndPort endpoint)abstract java.lang.StringAbstractNetworkTopologySnitch. getDatacenter(InetAddressAndPort endpoint)Return the data center for which an endpoint resides injava.lang.StringAlibabaCloudSnitch. getDatacenter(InetAddressAndPort endpoint)java.lang.StringCloudstackSnitch. getDatacenter(InetAddressAndPort endpoint)java.lang.StringDynamicEndpointSnitch. getDatacenter(InetAddressAndPort endpoint)java.lang.StringEc2Snitch. getDatacenter(InetAddressAndPort endpoint)java.lang.StringGoogleCloudSnitch. getDatacenter(InetAddressAndPort endpoint)java.lang.StringGossipingPropertyFileSnitch. getDatacenter(InetAddressAndPort endpoint)Return the data center for which an endpoint resides injava.lang.StringIEndpointSnitch. getDatacenter(InetAddressAndPort endpoint)returns a String representing the datacenter the given endpoint belongs tojava.lang.StringPropertyFileSnitch. getDatacenter(InetAddressAndPort endpoint)Return the data center for which an endpoint resides injava.lang.StringRackInferringSnitch. getDatacenter(InetAddressAndPort endpoint)java.lang.StringSimpleSnitch. getDatacenter(InetAddressAndPort endpoint)static java.lang.String[]PropertyFileSnitch. getEndpointInfo(InetAddressAndPort endpoint)Get the raw information about an end pointjava.util.UUIDTokenMetadata. getHostId(InetAddressAndPort endpoint)Return the unique host ID for an end-point.Pair<java.lang.String,java.lang.String>TokenMetadata.Topology. getLocation(InetAddressAndPort addr)RangesAtEndpointAbstractReplicationStrategy. getPendingAddressRanges(TokenMetadata metadata, java.util.Collection<Token> pendingTokens, InetAddressAndPort pendingAddress)RangesAtEndpointAbstractReplicationStrategy. getPendingAddressRanges(TokenMetadata metadata, Token pendingToken, InetAddressAndPort pendingAddress)RangesAtEndpointTokenMetadata. getPendingRanges(java.lang.String keyspaceName, InetAddressAndPort endpoint)abstract java.lang.StringAbstractNetworkTopologySnitch. getRack(InetAddressAndPort endpoint)Return the rack for which an endpoint resides injava.lang.StringAlibabaCloudSnitch. getRack(InetAddressAndPort endpoint)java.lang.StringCloudstackSnitch. getRack(InetAddressAndPort endpoint)java.lang.StringDynamicEndpointSnitch. getRack(InetAddressAndPort endpoint)java.lang.StringEc2Snitch. getRack(InetAddressAndPort endpoint)java.lang.StringGoogleCloudSnitch. getRack(InetAddressAndPort endpoint)java.lang.StringGossipingPropertyFileSnitch. getRack(InetAddressAndPort endpoint)Return the rack for which an endpoint resides injava.lang.StringIEndpointSnitch. getRack(InetAddressAndPort endpoint)returns a String representing the rack the given endpoint belongs tojava.lang.StringPropertyFileSnitch. getRack(InetAddressAndPort endpoint)Return the rack for which an endpoint resides injava.lang.StringRackInferringSnitch. getRack(InetAddressAndPort endpoint)java.lang.StringSimpleSnitch. getRack(InetAddressAndPort endpoint)java.util.Optional<InetAddressAndPort>TokenMetadata. getReplacementNode(InetAddressAndPort endpoint)java.util.Optional<InetAddressAndPort>TokenMetadata. getReplacingNode(InetAddressAndPort endpoint)static ReplicaSystemReplicas. getSystemReplica(InetAddressAndPort endpoint)There are a few places where a system function borrows write path functionality, but doesn't otherwise fit into normal replication strategies (ie: hints and batchlog).TokenTokenMetadata. getToken(InetAddressAndPort endpoint)Deprecated.java.util.Collection<Token>TokenMetadata. getTokens(InetAddressAndPort endpoint)static booleanInOurDc. isInOurDc(InetAddressAndPort endpoint)booleanTokenMetadata. isLeaving(InetAddressAndPort endpoint)booleanTokenMetadata. isMember(InetAddressAndPort endpoint)booleanTokenMetadata. isMoving(InetAddressAndPort endpoint)ReplicaEndpointsForToken. lookup(InetAddressAndPort endpoint)ReplicaReplicaPlan.AbstractForRead. lookup(InetAddressAndPort endpoint)ReplicaReplicaPlan.ForWrite. lookup(InetAddressAndPort endpoint)ReplicaReplicaPlan. lookup(InetAddressAndPort endpoint)protected RangesAtEndpoint.BuilderRangesByEndpoint.Builder. newBuilder(InetAddressAndPort endpoint)voidReconnectableSnitchHelper. onAlive(InetAddressAndPort endpoint, EndpointState state)voidReconnectableSnitchHelper. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidReconnectableSnitchHelper. onDead(InetAddressAndPort endpoint, EndpointState state)voidReconnectableSnitchHelper. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidReconnectableSnitchHelper. onRemove(InetAddressAndPort endpoint)voidReconnectableSnitchHelper. onRestart(InetAddressAndPort endpoint, EndpointState state)intTokenMetadata. pendingRangeChanges(InetAddressAndPort source)voidDynamicEndpointSnitch. receiveTiming(InetAddressAndPort host, long latency, java.util.concurrent.TimeUnit unit)voidTokenMetadata. removeEndpoint(InetAddressAndPort endpoint)voidTokenMetadata. removeFromMoving(InetAddressAndPort endpoint)Remove pair of token/address from moving endpointsvoidInetAddressAndPort.FwdFrmSerializer. serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)voidInetAddressAndPort.Serializer. serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)longInetAddressAndPort.FwdFrmSerializer. serializedSize(InetAddressAndPort from, int version)longInetAddressAndPort.Serializer. serializedSize(InetAddressAndPort from, int version)<C extends ReplicaCollection<? extends C>>
CAbstractEndpointSnitch. sortedByProximity(InetAddressAndPort address, C unsortedAddress)Sorts the Collection of node addresses by proximity to the given address<C extends ReplicaCollection<? extends C>>
CDynamicEndpointSnitch. sortedByProximity(InetAddressAndPort address, C unsortedAddresses)<C extends ReplicaCollection<? extends C>>
CIEndpointSnitch. sortedByProximity(InetAddressAndPort address, C addresses)returns a new List sorted by proximity to the given endpoint<C extends ReplicaCollection<? extends C>>
CSimpleSnitch. sortedByProximity(InetAddressAndPort address, C unsortedAddress)static ReplicaReplica. transientReplica(InetAddressAndPort endpoint, Range<Token> range)static ReplicaReplica. transientReplica(InetAddressAndPort endpoint, Token start, Token end)voidTokenMetadata. updateHostId(java.util.UUID hostId, InetAddressAndPort endpoint)Store an end-point to host ID mapping.voidTokenMetadata. updateNormalToken(Token token, InetAddressAndPort endpoint)Update token map with a single token/endpoint pair in normal state.voidTokenMetadata. updateNormalTokens(java.util.Collection<Token> tokens, InetAddressAndPort endpoint)TokenMetadata.TopologyTokenMetadata. updateTopology(InetAddressAndPort endpoint)This is called when the snitch properties for this endpoint are updated, see CASSANDRA-10238.Method parameters in org.apache.cassandra.locator with type arguments of type InetAddressAndPort Modifier and Type Method Description static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpoints(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints)static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpointsDynamic(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints, java.util.function.Predicate<InetAddressAndPort> isAlive)static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpointsDynamic(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints, java.util.function.Predicate<InetAddressAndPort> isAlive)static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpointsRandom(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints, java.util.function.Consumer<java.util.List<?>> shuffle, java.util.function.Predicate<InetAddressAndPort> isAlive, java.util.function.Function<java.lang.Integer,java.lang.Integer> indexPicker)static java.util.Collection<InetAddressAndPort>ReplicaPlans. filterBatchlogEndpointsRandom(boolean preferLocalRack, java.lang.String localRack, com.google.common.collect.Multimap<java.lang.String,InetAddressAndPort> endpoints, java.util.function.Consumer<java.util.List<?>> shuffle, java.util.function.Predicate<InetAddressAndPort> isAlive, java.util.function.Function<java.lang.Integer,java.lang.Integer> indexPicker)static EndpointsForRangeSystemReplicas. getSystemReplicas(java.util.Collection<InetAddressAndPort> endpoints)EEndpoints. keep(java.util.Set<InetAddressAndPort> keep)EEndpoints. select(java.lang.Iterable<InetAddressAndPort> endpoints, boolean ignoreMissing)static java.util.List<InetAddressAndPort>ReplicaPlans. sortByProximity(java.util.Collection<InetAddressAndPort> endpoints)voidTokenMetadata. updateHostIds(java.util.Map<java.util.UUID,InetAddressAndPort> hostIdToEndpointMap)voidTokenMetadata. updateNormalTokens(com.google.common.collect.Multimap<InetAddressAndPort,Token> endpointTokens)Update token map with a set of token/endpoint pairs in normal state.EEndpoints. without(java.util.Set<InetAddressAndPort> remove)Constructors in org.apache.cassandra.locator with parameters of type InetAddressAndPort Constructor Description Builder(InetAddressAndPort endpoint)Builder(InetAddressAndPort endpoint, int capacity)Replica(InetAddressAndPort endpoint, Range<Token> range, boolean full)Replica(InetAddressAndPort endpoint, Token start, Token end, boolean full)Constructor parameters in org.apache.cassandra.locator with type arguments of type InetAddressAndPort Constructor Description RangesByEndpoint(java.util.Map<InetAddressAndPort,RangesAtEndpoint> map) -
Uses of InetAddressAndPort in org.apache.cassandra.metrics
Methods in org.apache.cassandra.metrics with parameters of type InetAddressAndPort Modifier and Type Method Description static StreamingMetricsStreamingMetrics. get(InetAddressAndPort ip)voidHintedHandoffMetrics. incrCreatedHints(InetAddressAndPort address)voidHintedHandoffMetrics. incrPastWindow(InetAddressAndPort address)MessagingMetrics.DCLatencyRecorderMessagingMetrics. internodeLatencyRecorder(InetAddressAndPort from)static voidHintsServiceMetrics. updateDelayMetrics(InetAddressAndPort endpoint, long delay)Constructors in org.apache.cassandra.metrics with parameters of type InetAddressAndPort Constructor Description DifferencingCounter(InetAddressAndPort address)InternodeInboundMetrics(InetAddressAndPort peer, InboundMessageHandlers handlers)Create metrics for given inbound message handlers.InternodeOutboundMetrics(InetAddressAndPort ip, OutboundConnections messagingPool)Create metrics for given connection pool.StreamingMetrics(InetAddressAndPort peer) -
Uses of InetAddressAndPort in org.apache.cassandra.net
Fields in org.apache.cassandra.net declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortInboundConnectionSettings. bindAddressInetAddressAndPortOutboundConnectionSettings. connectToInetAddressAndPortMessage.Header. fromInetAddressAndPortOutboundConnectionSettings. fromInetAddressAndPortOutboundConnectionSettings. toFields in org.apache.cassandra.net with type parameters of type InetAddressAndPort Modifier and Type Field Description java.util.concurrent.ConcurrentMap<InetAddressAndPort,OutboundConnections>MessagingServiceMBeanImpl. channelManagersjava.util.function.Function<InetAddressAndPort,InboundMessageHandlers>InboundConnectionSettings. handlersjava.util.concurrent.ConcurrentMap<InetAddressAndPort,InboundMessageHandlers>MessagingServiceMBeanImpl. messageHandlersMethods in org.apache.cassandra.net that return InetAddressAndPort Modifier and Type Method Description InetAddressAndPortOutboundConnectionSettings. connectTo()InetAddressAndPortMessage. from()Sender of the message.InetAddressAndPortMessagingService.FailureResponseException. from()InetAddressAndPortOutboundConnectionSettings. from()InetAddressAndPortMessage. respondTo()The originator of the request - used when forwarding and will differ fromMessage.from()Methods in org.apache.cassandra.net with parameters of type InetAddressAndPort Modifier and Type Method Description voidOutboundSink. accept(Message<?> message, InetAddressAndPort to, ConnectionType connectionType)voidOutboundSink.Sink. accept(Message<?> message, InetAddressAndPort to, ConnectionType connectionType)voidLatencySubscribers. add(InetAddressAndPort address, long latency, java.util.concurrent.TimeUnit unit)voidRequestCallbacks. addWithExpiration(RequestCallback<?> cb, Message<?> message, InetAddressAndPort to)Register the providedRequestCallback, inferring expiry and id from the providedMessage.booleanInboundConnectionSettings. authenticate(InetAddressAndPort endpoint)voidMessagingService. closeOutbound(InetAddressAndPort to)Only to be invoked once we believe the endpoint will never be contacted again.<T> Message<T>Message.Serializer. deserialize(DataInputPlus in, InetAddressAndPort peer, int version)Message.Builder<T>Message.Builder. from(InetAddressAndPort from)intEndpointMessagingVersions. get(InetAddressAndPort endpoint)Returns the messaging-version as announced by the given node but capped to the min of the version as announced by the node andMessagingService.current_version.intEndpointMessagingVersions. getRaw(InetAddressAndPort endpoint)Returns the messaging-version exactly as announced by the given endpoint.LatencyConsumerInboundMessageHandlers.GlobalMetricCallbacks. internodeLatencyRecorder(InetAddressAndPort to)voidMessagingService. interruptOutbound(InetAddressAndPort to)Closes any current open channel/connection to the endpoint, but does not cause any message loss, and we will try to re-establish connections immediatelybooleanEndpointMessagingVersions. knows(InetAddressAndPort endpoint)voidLatencySubscribers. maybeAdd(RequestCallback cb, InetAddressAndPort address, long latency, java.util.concurrent.TimeUnit unit)Track latency information for the dynamic snitchio.netty.util.concurrent.Future<java.lang.Void>MessagingService. maybeReconnectWithNewIp(InetAddressAndPort address, InetAddressAndPort preferredAddress)Reconnect to the peer using the givenaddr.voidRequestCallbacks. onDiscardOnClose(Message<?> message, InetAddressAndPort peer)voidRequestCallbacks. onExpired(Message<?> message, InetAddressAndPort peer)voidRequestCallbacks. onFailedSerialize(Message<?> message, InetAddressAndPort peer, int messagingVersion, int bytesWrittenToNetwork, java.lang.Throwable failure)default voidRequestCallback. onFailure(InetAddressAndPort from, RequestFailureReason failureReason)Called when there is an exception on the remote node or timeout happensvoidRequestCallbackWithFailure. onFailure(InetAddressAndPort from, RequestFailureReason failureReason)Called when there is an exception on the remote node or timeout happensvoidRequestCallbacks. onOverloaded(Message<?> message, InetAddressAndPort peer)voidLatencySubscribers.Subscriber. receiveTiming(InetAddressAndPort address, long latency, java.util.concurrent.TimeUnit unit)static <T> Message<T>Message. remoteResponse(InetAddressAndPort from, Verb verb, T payload)Used by theMultiRangeReadCommandto split multi-range responses from a replica into single-range responses.RequestCallbacks.CallbackInfoRequestCallbacks. remove(long id, InetAddressAndPort peer)Remove and return theRequestCallbacks.CallbackInfoassociated with given id and peer, if known.voidRequestCallbacks. removeAndRespond(long id, InetAddressAndPort peer, Message message)voidMessagingService. removeInbound(InetAddressAndPort from)Only to be invoked once we believe the connections will never be used again.voidEndpointMessagingVersions. reset(InetAddressAndPort endpoint)voidMessagingService. send(Message message, InetAddressAndPort to)Send a message to a given endpoint.voidMessagingService. send(Message message, InetAddressAndPort to, ConnectionType specifyConnection)voidMessagingService. sendWithCallback(Message message, InetAddressAndPort to, RequestCallback cb)Send a non-mutation message to a given endpoint.voidMessagingService. sendWithCallback(Message message, InetAddressAndPort to, RequestCallback cb, ConnectionType specifyConnection)<T> Future<Message<T>>MessagingService. sendWithResult(Message message, InetAddressAndPort to)intEndpointMessagingVersions. set(InetAddressAndPort endpoint, int version)static <T> Message<T>Message. synthetic(InetAddressAndPort from, Verb verb, T payload)OutboundConnectionSettingsOutboundConnectionSettings. toEndpoint(InetAddressAndPort endpoint)InboundConnectionSettingsInboundConnectionSettings. withBindAddress(InetAddressAndPort bindAddress)OutboundConnectionSettingsOutboundConnectionSettings. withConnectTo(InetAddressAndPort connectTo)OutboundConnectionSettingsOutboundConnectionSettings. withFrom(InetAddressAndPort from)Method parameters in org.apache.cassandra.net with type arguments of type InetAddressAndPort Modifier and Type Method Description voidOutboundSink. add(java.util.function.BiPredicate<Message<?>,InetAddressAndPort> allow)booleanStartupClusterConnectivityChecker. execute(java.util.Set<InetAddressAndPort> peers, java.util.function.Function<InetAddressAndPort,java.lang.String> getDatacenterSource, java.util.function.Predicate<CassandraVersion> isUpgradingFromLowerVersionThan)booleanStartupClusterConnectivityChecker. execute(java.util.Set<InetAddressAndPort> peers, java.util.function.Function<InetAddressAndPort,java.lang.String> getDatacenterSource, java.util.function.Predicate<CassandraVersion> isUpgradingFromLowerVersionThan)voidForwardingInfo. forEach(java.util.function.BiConsumer<java.lang.Long,InetAddressAndPort> biConsumer)Apply the provided consumer to all (host, message_id) pairs.voidOutboundSink. remove(java.util.function.BiPredicate<Message<?>,InetAddressAndPort> allow)InboundConnectionSettingsInboundConnectionSettings. withHandlers(java.util.function.Function<InetAddressAndPort,InboundMessageHandlers> handlers)Constructors in org.apache.cassandra.net with parameters of type InetAddressAndPort Constructor Description FailureResponseException(InetAddressAndPort from, RequestFailureReason failureReason)InboundMessageHandlers(InetAddressAndPort self, InetAddressAndPort peer, int queueCapacity, long endpointReserveCapacity, org.apache.cassandra.net.InboundMessageHandlers.GlobalResourceLimits globalResourceLimits, InboundMessageHandlers.GlobalMetricCallbacks globalMetricCallbacks, InboundMessageHandlers.MessageConsumer messageConsumer)InboundMessageHandlers(InetAddressAndPort self, InetAddressAndPort peer, int queueCapacity, long endpointReserveCapacity, org.apache.cassandra.net.InboundMessageHandlers.GlobalResourceLimits globalResourceLimits, InboundMessageHandlers.GlobalMetricCallbacks globalMetricCallbacks, InboundMessageHandlers.MessageConsumer messageConsumer, org.apache.cassandra.net.InboundMessageHandlers.HandlerProvider handlerProvider)OutboundConnectionSettings(InetAddressAndPort to)OutboundConnectionSettings(InetAddressAndPort to, InetAddressAndPort preferred)Constructor parameters in org.apache.cassandra.net with type arguments of type InetAddressAndPort Constructor Description ForwardingInfo(java.util.List<InetAddressAndPort> targets, long[] messageIds) -
Uses of InetAddressAndPort in org.apache.cassandra.repair
Fields in org.apache.cassandra.repair declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortSyncNodePair. coordinatorInetAddressAndPortTreeResponse. endpointInetAddressAndPortValidator. initiatorInetAddressAndPortSyncNodePair. peerFields in org.apache.cassandra.repair with type parameters of type InetAddressAndPort Modifier and Type Field Description com.google.common.collect.ImmutableSet<InetAddressAndPort>CommonRange. endpointsjava.util.Set<InetAddressAndPort>RepairRunnable.NeighborsAndRanges. participantscom.google.common.collect.ImmutableSet<InetAddressAndPort>CommonRange. transEndpointsMethods in org.apache.cassandra.repair that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Collection<InetAddressAndPort>RepairSession. endpoints()Methods in org.apache.cassandra.repair with parameters of type InetAddressAndPort Modifier and Type Method Description voidRepairSession. convict(InetAddressAndPort endpoint, double phi)voidRepairSession. onRemove(InetAddressAndPort endpoint)voidRepairSession. onRestart(InetAddressAndPort endpoint, EndpointState epState)voidRepairSession. validationComplete(RepairJobDesc desc, InetAddressAndPort endpoint, MerkleTrees trees)Receive merkle tree response or failed response fromendpointfor current repair job.Method parameters in org.apache.cassandra.repair with type arguments of type InetAddressAndPort Modifier and Type Method Description booleanCommonRange. matchesEndpoints(java.util.Set<InetAddressAndPort> endpoints, java.util.Set<InetAddressAndPort> transEndpoints)voidRepairSession. trackValidationCompletion(Pair<RepairJobDesc,InetAddressAndPort> key, ValidationTask task)Constructor parameters in org.apache.cassandra.repair with type arguments of type InetAddressAndPort Constructor Description CommonRange(java.util.Set<InetAddressAndPort> endpoints, java.util.Set<InetAddressAndPort> transEndpoints, java.util.Collection<Range<Token>> ranges)CommonRange(java.util.Set<InetAddressAndPort> endpoints, java.util.Set<InetAddressAndPort> transEndpoints, java.util.Collection<Range<Token>> ranges, boolean hasSkippedReplicas)NeighborsAndRanges(boolean shouldExcludeDeadParticipants, java.util.Set<InetAddressAndPort> participants, java.util.List<CommonRange> commonRanges) -
Uses of InetAddressAndPort in org.apache.cassandra.repair.asymmetric
Methods in org.apache.cassandra.repair.asymmetric that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.lang.Iterable<java.util.Set<InetAddressAndPort>>StreamFromOptions. allStreams()java.util.Set<InetAddressAndPort>PreferedNodeFilter. apply(InetAddressAndPort streamingNode, java.util.Set<InetAddressAndPort> toStream)java.util.Set<InetAddressAndPort>HostDifferences. hosts()java.util.Set<InetAddressAndPort>DifferenceHolder. keyHosts()differences only holds one 'side' of the difference - if A and B mismatch, only A will be a key in the mapstatic com.google.common.collect.ImmutableMap<InetAddressAndPort,HostDifferences>ReduceHelper. reduce(DifferenceHolder differences, PreferedNodeFilter filter)Reduces the differences provided by the merkle trees to a minimum set of differencesMethods in org.apache.cassandra.repair.asymmetric with parameters of type InetAddressAndPort Modifier and Type Method Description voidHostDifferences. add(InetAddressAndPort endpoint, java.util.Collection<Range<Token>> difference)Adds a set of differences between the node this instance is tracking and endpointvoidStreamFromOptions. add(InetAddressAndPort streamFromNode)Add new node to the stream options If we have no difference between the new node and a currently tracked on, we know they are matching over the range we are tracking, then just add it to the set with the identical remote nodes.voidIncomingRepairStreamTracker. addIncomingRangeFrom(Range<Token> range, InetAddressAndPort streamFromNode)Adds a range to be streamed from streamFromNode First the currently tracked ranges are denormalized to make sure that no ranges overlap, then the streamFromNode is added to the StreamFromOptions for the rangevoidHostDifferences. addSingleRange(InetAddressAndPort remoteNode, Range<Token> rangeToFetch)java.util.Set<InetAddressAndPort>PreferedNodeFilter. apply(InetAddressAndPort streamingNode, java.util.Set<InetAddressAndPort> toStream)HostDifferencesDifferenceHolder. get(InetAddressAndPort hostWithDifference)java.util.NavigableSet<Range<Token>>HostDifferences. get(InetAddressAndPort differingHost)booleanDifferenceHolder. hasDifferenceBetween(InetAddressAndPort node1, InetAddressAndPort node2, Range<Token> range)booleanHostDifferences. hasDifferencesFor(InetAddressAndPort node2, Range<Token> range)Does this instance have differences for range with node2?Method parameters in org.apache.cassandra.repair.asymmetric with type arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Set<InetAddressAndPort>PreferedNodeFilter. apply(InetAddressAndPort streamingNode, java.util.Set<InetAddressAndPort> toStream) -
Uses of InetAddressAndPort in org.apache.cassandra.repair.consistent
Fields in org.apache.cassandra.repair.consistent declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortConsistentSession. coordinatorFields in org.apache.cassandra.repair.consistent with type parameters of type InetAddressAndPort Modifier and Type Field Description com.google.common.collect.ImmutableSet<InetAddressAndPort>ConsistentSession. participantsMethods in org.apache.cassandra.repair.consistent that return InetAddressAndPort Modifier and Type Method Description protected InetAddressAndPortLocalSessions. getBroadcastAddressAndPort()Methods in org.apache.cassandra.repair.consistent with parameters of type InetAddressAndPort Modifier and Type Method Description voidLocalSessions. handleFailSessionMessage(InetAddressAndPort from, FailSession msg)voidLocalSessions. handleFinalizeCommitMessage(InetAddressAndPort from, FinalizeCommit commit)Finalizes the repair session, completing it as successful.voidCoordinatorSession. handleFinalizePromise(InetAddressAndPort participant, boolean success)voidLocalSessions. handleFinalizeProposeMessage(InetAddressAndPort from, FinalizePropose propose)voidLocalSessions. handlePrepareMessage(InetAddressAndPort from, PrepareConsistentRequest request)The PrepareConsistentRequest promotes the parent repair session to a consistent incremental session, and isolates the data to be repaired from the rest of the table's data No response is sent to the repair coordinator until the data preparation / isolation has completed successfully.voidCoordinatorSession. handlePrepareResponse(InetAddressAndPort participant, boolean success)voidLocalSessions. handleStatusRequest(InetAddressAndPort from, StatusRequest request)voidLocalSessions. handleStatusResponse(InetAddressAndPort from, StatusResponse response)protected booleanLocalSessions. isAlive(InetAddressAndPort address)protected voidCoordinatorSession. sendMessage(InetAddressAndPort destination, Message<RepairMessage> message)protected voidLocalSessions. sendMessage(InetAddressAndPort destination, Message<? extends RepairMessage> message)voidCoordinatorSession. setParticipantState(InetAddressAndPort participant, ConsistentSession.State state)Method parameters in org.apache.cassandra.repair.consistent with type arguments of type InetAddressAndPort Modifier and Type Method Description CoordinatorSessionCoordinatorSessions. registerSession(TimeUUID sessionId, java.util.Set<InetAddressAndPort> participants, boolean isForced) -
Uses of InetAddressAndPort in org.apache.cassandra.repair.messages
Fields in org.apache.cassandra.repair.messages declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortPrepareConsistentRequest. coordinatorInetAddressAndPortSyncRequest. dstInetAddressAndPortSyncRequest. initiatorInetAddressAndPortFinalizePromise. participantInetAddressAndPortPrepareConsistentResponse. participantInetAddressAndPortSyncRequest. srcFields in org.apache.cassandra.repair.messages with type parameters of type InetAddressAndPort Modifier and Type Field Description java.util.Set<InetAddressAndPort>PrepareConsistentRequest. participantsMethods in org.apache.cassandra.repair.messages with parameters of type InetAddressAndPort Modifier and Type Method Description static voidRepairMessage. sendMessageWithFailureCB(RepairMessage request, Verb verb, InetAddressAndPort endpoint, RepairMessage.RepairFailureCallback failureCallback)Constructors in org.apache.cassandra.repair.messages with parameters of type InetAddressAndPort Constructor Description FinalizePromise(TimeUUID sessionID, InetAddressAndPort participant, boolean promised)PrepareConsistentRequest(TimeUUID parentSession, InetAddressAndPort coordinator, java.util.Set<InetAddressAndPort> participants)PrepareConsistentResponse(TimeUUID parentSession, InetAddressAndPort participant, boolean success)SyncRequest(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, java.util.Collection<Range<Token>> ranges, PreviewKind previewKind, boolean asymmetric)SyncResponse(RepairJobDesc desc, InetAddressAndPort endpoint1, InetAddressAndPort endpoint2, boolean success, java.util.List<SessionSummary> summaries)Constructor parameters in org.apache.cassandra.repair.messages with type arguments of type InetAddressAndPort Constructor Description PrepareConsistentRequest(TimeUUID parentSession, InetAddressAndPort coordinator, java.util.Set<InetAddressAndPort> participants) -
Uses of InetAddressAndPort in org.apache.cassandra.repair.state
Fields in org.apache.cassandra.repair.state declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortParticipateState. initiatorInetAddressAndPortValidationState. initiatorMethods in org.apache.cassandra.repair.state that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Set<InetAddressAndPort>CoordinatorState. getParticipants()java.util.Set<InetAddressAndPort>JobState. getParticipants()java.util.Set<InetAddressAndPort>SessionState. getParticipants()Constructors in org.apache.cassandra.repair.state with parameters of type InetAddressAndPort Constructor Description ParticipateState(InetAddressAndPort initiator, PrepareMessage msg)ValidationState(RepairJobDesc desc, InetAddressAndPort initiator)Constructor parameters in org.apache.cassandra.repair.state with type arguments of type InetAddressAndPort Constructor Description JobState(RepairJobDesc desc, com.google.common.collect.ImmutableSet<InetAddressAndPort> endpoints) -
Uses of InetAddressAndPort in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Map<java.util.UUID,java.util.Set<InetAddressAndPort>>DefaultSchemaUpdateHandler. getOutstandingSchemaVersions()java.util.Map<java.util.UUID,java.util.Set<InetAddressAndPort>>Schema. getOutstandingSchemaVersions()Methods in org.apache.cassandra.schema with parameters of type InetAddressAndPort Modifier and Type Method Description voidDefaultSchemaUpdateHandler. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)voidDefaultSchemaUpdateHandler. onAlive(InetAddressAndPort endpoint, EndpointState state)voidDefaultSchemaUpdateHandler. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidDefaultSchemaUpdateHandler. onDead(InetAddressAndPort endpoint, EndpointState state)voidDefaultSchemaUpdateHandler. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidDefaultSchemaUpdateHandler. onRemove(InetAddressAndPort endpoint)voidDefaultSchemaUpdateHandler. onRestart(InetAddressAndPort endpoint, EndpointState state) -
Uses of InetAddressAndPort in org.apache.cassandra.service
Fields in org.apache.cassandra.service declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortActiveRepairService.ParentRepairSession. coordinatorInetAddressAndPortTokenRange.EndpointDetails. hostMethods in org.apache.cassandra.service that return InetAddressAndPort Modifier and Type Method Description InetAddressAndPortStorageService. getEndpointForHostId(java.util.UUID hostId)InetAddressAndPortFailureRecordingCallback.FailureResponses. getKey()Methods in org.apache.cassandra.service that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.util.Set<java.util.Map.Entry<InetAddressAndPort,RequestFailureReason>>FailureRecordingCallback.AsMap. entrySet()java.util.Set<InetAddressAndPort>StorageService. getLiveRingMembers()java.util.Set<InetAddressAndPort>StorageService. getLiveRingMembers(boolean excludeDeadStates)java.util.Map<InetAddressAndPort,java.lang.Double>LoadBroadcaster. getLoadInfo()java.util.Collection<InetAddressAndPort>StorageService. prepareForBootstrap(long schemaTimeoutMillis, long ringTimeoutMillis)Methods in org.apache.cassandra.service with parameters of type InetAddressAndPort Modifier and Type Method Description protected voidStorageService. addExpireTimeIfFound(InetAddressAndPort endpoint, long expireTime)voidActiveRepairService. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)voidStorageService. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)voidStorageService. confirmReplication(InetAddressAndPort node)voidActiveRepairService. convict(InetAddressAndPort ep, double phi)Something has happened to a remote node - if that node is a coordinator, we mark the parent repair session id as failed.java.util.UUIDStorageService. getHostIdForEndpoint(InetAddressAndPort address)java.util.Collection<Range<Token>>StorageService. getLocalPrimaryRangeForEndpoint(InetAddressAndPort referenceEndpoint)java.lang.StringStorageService. getNativeaddress(InetAddressAndPort endpoint, boolean withPort)Return the native address associated with an endpoint as a string.java.util.Collection<Range<Token>>StorageService. getPrimaryRangeForEndpointWithinDC(java.lang.String keyspace, InetAddressAndPort referenceEndpoint)Get the "primary ranges" within local DC for the specified keyspace and endpoint.java.util.Collection<Range<Token>>StorageService. getPrimaryRangesForEndpoint(java.lang.String keyspace, InetAddressAndPort ep)Get the "primary ranges" for the specified keyspace and endpoint.java.util.Collection<Token>StorageService. getTokensFor(InetAddressAndPort endpoint)booleanStorageService. isRpcReady(InetAddressAndPort endpoint)voidActiveRepairService. onAlive(InetAddressAndPort endpoint, EndpointState state)voidStorageService. onAlive(InetAddressAndPort endpoint, EndpointState state)voidActiveRepairService. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidLoadBroadcaster. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidStorageService. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidActiveRepairService. onDead(InetAddressAndPort endpoint, EndpointState state)voidStorageService. onDead(InetAddressAndPort endpoint, EndpointState state)voidIEndpointLifecycleSubscriber. onDown(InetAddressAndPort endpoint)Called when a node is marked DOWN.voidAbstractWriteResponseHandler. onFailure(InetAddressAndPort from, RequestFailureReason failureReason)voidBatchlogResponseHandler. onFailure(InetAddressAndPort from, RequestFailureReason failureReason)voidFailureRecordingCallback. onFailure(InetAddressAndPort from, RequestFailureReason failureReason)voidTruncateResponseHandler. onFailure(InetAddressAndPort from, RequestFailureReason failureReason)protected voidFailureRecordingCallback. onFailureWithMutex(InetAddressAndPort from, RequestFailureReason failureReason)voidActiveRepairService. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidLoadBroadcaster. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidStorageService. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidIEndpointLifecycleSubscriber. onJoinCluster(InetAddressAndPort endpoint)Called when a new node joins the cluster, i.e.voidIEndpointLifecycleSubscriber. onLeaveCluster(InetAddressAndPort endpoint)Called when a new node leave the cluster (decommission or removeToken).voidIEndpointLifecycleSubscriber. onMove(InetAddressAndPort endpoint)Called when a node has moved (to a new token).voidActiveRepairService. onRemove(InetAddressAndPort endpoint)voidLoadBroadcaster. onRemove(InetAddressAndPort endpoint)voidStorageService. onRemove(InetAddressAndPort endpoint)voidActiveRepairService. onRestart(InetAddressAndPort endpoint, EndpointState state)voidStorageService. onRestart(InetAddressAndPort endpoint, EndpointState state)voidIEndpointLifecycleSubscriber. onUp(InetAddressAndPort endpoint)Called when a node is marked UP.TimeUUIDActiveRepairService. prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, java.util.List<ColumnFamilyStore> columnFamilyStores)static <O> voidFailureRecordingCallback.FailureResponses. push(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)static <O> voidFailureRecordingCallback.FailureResponses. pushExclusive(java.util.concurrent.atomic.AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)static FailureRecordingCallback.FailureResponsesFailureRecordingCallback.FailureResponses. pushExclusive(FailureRecordingCallback.FailureResponses head, InetAddressAndPort from, RequestFailureReason reason)voidActiveRepairService. registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)voidStorageService. updateTopology(InetAddressAndPort endpoint)protected booleanAbstractWriteResponseHandler. waitingFor(InetAddressAndPort from)protected booleanBatchlogResponseHandler. waitingFor(InetAddressAndPort from)protected booleanDatacenterWriteResponseHandler. waitingFor(InetAddressAndPort from)Method parameters in org.apache.cassandra.service with type arguments of type InetAddressAndPort Modifier and Type Method Description voidStorageService. checkForEndpointCollision(java.util.UUID localHostId, java.util.Set<InetAddressAndPort> peers)voidActiveRepairService. cleanUp(TimeUUID parentRepairSession, java.util.Set<InetAddressAndPort> endpoints)Send Verb.CLEANUP_MSG to the given endpoints.static TokenRangeTokenRange. create(Token.TokenFactory tokenFactory, Range<Token> range, java.util.List<InetAddressAndPort> endpoints, boolean withPorts)TimeUUIDActiveRepairService. prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, java.util.List<ColumnFamilyStore> columnFamilyStores)Constructors in org.apache.cassandra.service with parameters of type InetAddressAndPort Constructor Description FailureResponses(InetAddressAndPort from, RequestFailureReason reason)ParentRepairSession(InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind) -
Uses of InetAddressAndPort in org.apache.cassandra.service.disk.usage
Methods in org.apache.cassandra.service.disk.usage with parameters of type InetAddressAndPort Modifier and Type Method Description voidDiskUsageBroadcaster. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)booleanDiskUsageBroadcaster. isFull(InetAddressAndPort endpoint)booleanDiskUsageBroadcaster. isStuffed(InetAddressAndPort endpoint)voidDiskUsageBroadcaster. onAlive(InetAddressAndPort endpoint, EndpointState state)voidDiskUsageBroadcaster. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidDiskUsageBroadcaster. onDead(InetAddressAndPort endpoint, EndpointState state)voidDiskUsageBroadcaster. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidDiskUsageBroadcaster. onRemove(InetAddressAndPort endpoint)voidDiskUsageBroadcaster. onRestart(InetAddressAndPort endpoint, EndpointState state)DiskUsageStateDiskUsageBroadcaster. state(InetAddressAndPort endpoint) -
Uses of InetAddressAndPort in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos with parameters of type InetAddressAndPort Modifier and Type Method Description static org.apache.cassandra.service.paxos.PaxosPrepareRefresh.ResponsePaxosPrepareRefresh.RequestHandler. execute(org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Request request, InetAddressAndPort from)static org.apache.cassandra.service.paxos.PaxosPropose.ResponsePaxosPropose.RequestHandler. execute(Commit.Proposal proposal, InetAddressAndPort from)static booleanPaxos. isInRangeAndShouldProcess(InetAddressAndPort from, DecoratedKey key, TableMetadata table, boolean includesRead)voidPaxosCommit. onFailure(InetAddressAndPort from, RequestFailureReason reason)Record a failure or timeout, and maybe submit a hint tofromvoidPaxosPrepare. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosPrepareRefresh. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosPropose. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosPrepare. onRefreshFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosPrepare. onRefreshSuccess(Ballot isSupersededBy, InetAddressAndPort from)voidPaxosCommit. onResponse(NoPayload response, InetAddressAndPort from)voidPaxosPrepare. onResponse(org.apache.cassandra.service.paxos.PaxosPrepare.Response response, InetAddressAndPort from)voidPaxosPropose. onResponse(org.apache.cassandra.service.paxos.PaxosPropose.Response response, InetAddressAndPort from)protected abstract voidPaxosRequestCallback. onResponse(T response, InetAddressAndPort from)Method parameters in org.apache.cassandra.service.paxos with type arguments of type InetAddressAndPort Modifier and Type Method Description protected <I> voidPaxosRequestCallback. executeOnSelf(I parameter, java.util.function.BiFunction<I,InetAddressAndPort,T> execute)static booleanPaxosRepair. hasSufficientLiveNodesForTopologyChange(Keyspace keyspace, Range<Token> range, java.util.Collection<InetAddressAndPort> liveEndpoints)checks if we have enough live nodes to perform a paxos repair for topology repair. -
Uses of InetAddressAndPort in org.apache.cassandra.service.paxos.cleanup
Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type InetAddressAndPort Modifier and Type Method Description voidPaxosCleanupSession. beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)voidPaxosCleanupSession. convict(InetAddressAndPort ep, double phi)static voidPaxosCleanupSession. finishSession(InetAddressAndPort from, PaxosCleanupResponse response)voidPaxosCleanupSession. onAlive(InetAddressAndPort endpoint, EndpointState state)voidPaxosCleanupSession. onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)voidPaxosCleanupSession. onDead(InetAddressAndPort endpoint, EndpointState state)voidPaxosCleanupComplete. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosCleanupSession. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosFinishPrepareCleanup. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosStartPrepareCleanup. onFailure(InetAddressAndPort from, RequestFailureReason reason)voidPaxosCleanupSession. onJoin(InetAddressAndPort endpoint, EndpointState epState)voidPaxosCleanupSession. onRemove(InetAddressAndPort endpoint)voidPaxosCleanupSession. onRestart(InetAddressAndPort endpoint, EndpointState state)Method parameters in org.apache.cassandra.service.paxos.cleanup with type arguments of type InetAddressAndPort Modifier and Type Method Description static PaxosCleanupPaxosCleanup. cleanup(java.util.Collection<InetAddressAndPort> endpoints, TableMetadata table, java.util.Collection<Range<Token>> ranges, boolean skippedReplicas, java.util.concurrent.Executor executor)static PaxosFinishPrepareCleanupPaxosFinishPrepareCleanup. finish(java.util.Collection<InetAddressAndPort> endpoints, PaxosCleanupHistory result)static PaxosStartPrepareCleanupPaxosStartPrepareCleanup. prepare(TableId tableId, java.util.Collection<InetAddressAndPort> endpoints, EndpointState localEpState, java.util.Collection<Range<Token>> ranges)We run paxos repair as part of topology changes, so we include the local endpoint state in the paxos repair prepare message to prevent racing with gossip dissemination and guarantee that every repair participant is aware of the pending ring change during repair.Constructor parameters in org.apache.cassandra.service.paxos.cleanup with type arguments of type InetAddressAndPort Constructor Description PaxosCleanup(java.util.Collection<InetAddressAndPort> endpoints, TableMetadata table, java.util.Collection<Range<Token>> ranges, boolean skippedReplicas, java.util.concurrent.Executor executor) -
Uses of InetAddressAndPort in org.apache.cassandra.service.paxos.v1
Methods in org.apache.cassandra.service.paxos.v1 that return types with arguments of type InetAddressAndPort Modifier and Type Method Description java.lang.Iterable<InetAddressAndPort>PrepareCallback. replicasMissingMostRecentCommit(TableMetadata metadata)Methods in org.apache.cassandra.service.paxos.v1 with parameters of type InetAddressAndPort Modifier and Type Method Description voidAbstractPaxosCallback. onFailure(InetAddressAndPort from, RequestFailureReason failureReason) -
Uses of InetAddressAndPort in org.apache.cassandra.service.reads
Fields in org.apache.cassandra.service.reads declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortDigestResolver.DigestResolverDebugResult. fromMethods in org.apache.cassandra.service.reads with parameters of type InetAddressAndPort Modifier and Type Method Description voidReadCallback. onFailure(InetAddressAndPort from, RequestFailureReason failureReason) -
Uses of InetAddressAndPort in org.apache.cassandra.service.reads.repair
Fields in org.apache.cassandra.service.reads.repair with type parameters of type InetAddressAndPort Modifier and Type Field Description com.google.common.collect.Multimap<java.nio.ByteBuffer,InetAddressAndPort>RepairedDataTracker. digestsjava.util.Set<InetAddressAndPort>RepairedDataTracker. inconclusiveDigestsMethods in org.apache.cassandra.service.reads.repair with parameters of type InetAddressAndPort Modifier and Type Method Description static MutationBlockingReadRepairs. createRepairMutation(PartitionUpdate update, ConsistencyLevel consistency, InetAddressAndPort destination, boolean suppressException)Create a read repair mutation from the given update, if the mutation is not larger than the maximum mutation size, otherwise return null.voidRepairedDataTracker. recordDigest(InetAddressAndPort source, java.nio.ByteBuffer digest, boolean isConclusive)protected voidBlockingPartitionRepair. sendRR(Message<Mutation> message, InetAddressAndPort endpoint) -
Uses of InetAddressAndPort in org.apache.cassandra.service.reads.thresholds
Fields in org.apache.cassandra.service.reads.thresholds with type parameters of type InetAddressAndPort Modifier and Type Field Description com.google.common.collect.ImmutableSet<InetAddressAndPort>WarningsSnapshot.Counter. instancesMethods in org.apache.cassandra.service.reads.thresholds with parameters of type InetAddressAndPort Modifier and Type Method Description RequestFailureReasonWarningContext. updateCounters(java.util.Map<ParamType,java.lang.Object> params, InetAddressAndPort from)Method parameters in org.apache.cassandra.service.reads.thresholds with type arguments of type InetAddressAndPort Modifier and Type Method Description static WarningsSnapshot.CounterWarningsSnapshot.Counter. create(java.util.Set<InetAddressAndPort> instances, java.util.concurrent.atomic.AtomicLong maxValue)WarningsSnapshot.BuilderWarningsSnapshot.Builder. localReadSizeAbort(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue)WarningsSnapshot.BuilderWarningsSnapshot.Builder. localReadSizeWarning(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue)voidWarningsSnapshot. maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)WarningsSnapshot.BuilderWarningsSnapshot.Builder. tombstonesAbort(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue)WarningsSnapshot.BuilderWarningsSnapshot.Builder. tombstonesWarning(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue) -
Uses of InetAddressAndPort in org.apache.cassandra.streaming
Fields in org.apache.cassandra.streaming declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortProgressInfo. peerInetAddressAndPortStreamEvent.SessionCompleteEvent. peerInetAddressAndPortStreamSession. peerStreaming endpoint.Methods in org.apache.cassandra.streaming with parameters of type InetAddressAndPort Modifier and Type Method Description static StreamResultFutureStreamResultFuture. createFollower(int sessionIndex, TimeUUID planId, StreamOperation streamOperation, InetAddressAndPort from, StreamingChannel channel, int messagingVersion, TimeUUID pendingRepair, PreviewKind previewKind)StreamSessionStreamManager. findSession(InetAddressAndPort peer, TimeUUID planId, int sessionIndex, boolean searchInitiatorSessions)static StreamManager.StreamRateLimiterStreamManager. getEntireSSTableRateLimiter(InetAddressAndPort peer)Get streaming rate limiter for entire SSTable operations.StreamSessionStreamCoordinator. getOrCreateInboundSession(InetAddressAndPort from, StreamingChannel channel, int messagingVersion, int id)StreamSessionStreamCoordinator. getOrCreateOutboundSession(InetAddressAndPort peer)static StreamManager.StreamRateLimiterStreamManager. getRateLimiter(InetAddressAndPort peer)Gets streaming rate limiter.StreamSessionStreamResultFuture. getSession(InetAddressAndPort peer, int sessionIndex)StreamSessionStreamCoordinator. getSessionById(InetAddressAndPort peer, int id)voidStreamSession.MessageStateSink. onClose(InetAddressAndPort from)voidStreamSession. onRemove(InetAddressAndPort endpoint)voidStreamSession. onRestart(InetAddressAndPort endpoint, EndpointState epState)voidStreamSession.MessageStateSink. recordMessage(InetAddressAndPort from, StreamMessage.Type message)voidStreamSession.MessageStateSink. recordState(InetAddressAndPort from, StreamSession.State state)StreamPlanStreamPlan. requestRanges(InetAddressAndPort from, java.lang.String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges)Request data inkeyspaceandrangesfrom specific node.StreamPlanStreamPlan. requestRanges(InetAddressAndPort from, java.lang.String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges, java.lang.String... columnFamilies)Request data incolumnFamiliesunderkeyspaceandrangesfrom specific node.StreamPlanStreamPlan. transferRanges(InetAddressAndPort to, java.lang.String keyspace, RangesAtEndpoint replicas, java.lang.String... columnFamilies)Add transfer task to send data of specificcolumnFamiliesunderkeyspaceandranges.voidStreamCoordinator. transferStreams(InetAddressAndPort to, java.util.Collection<OutgoingStream> streams)StreamPlanStreamPlan. transferStreams(InetAddressAndPort to, java.util.Collection<OutgoingStream> streams)Add transfer task to send given streamsConstructors in org.apache.cassandra.streaming with parameters of type InetAddressAndPort Constructor Description ProgressInfo(InetAddressAndPort peer, int sessionIndex, java.lang.String fileName, ProgressInfo.Direction direction, long currentBytes, long deltaBytes, long totalBytes)StreamSession(StreamOperation streamOperation, InetAddressAndPort peer, StreamingChannel.Factory factory, StreamingChannel controlChannel, int messagingVersion, boolean isFollower, int index, TimeUUID pendingRepair, PreviewKind previewKind)Create new streaming session with the peer. -
Uses of InetAddressAndPort in org.apache.cassandra.streaming.async
Methods in org.apache.cassandra.streaming.async that return InetAddressAndPort Modifier and Type Method Description InetAddressAndPortStreamingMultiplexedChannel. peer()Constructors in org.apache.cassandra.streaming.async with parameters of type InetAddressAndPort Constructor Description StreamingMultiplexedChannel(StreamSession session, StreamingChannel.Factory factory, InetAddressAndPort to, StreamingChannel controlChannel, int messagingVersion) -
Uses of InetAddressAndPort in org.apache.cassandra.streaming.messages
Fields in org.apache.cassandra.streaming.messages declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortStreamInitMessage. fromInetAddressAndPortStreamMessageHeader. senderConstructors in org.apache.cassandra.streaming.messages with parameters of type InetAddressAndPort Constructor Description StreamInitMessage(InetAddressAndPort from, int sessionIndex, TimeUUID planId, StreamOperation streamOperation, TimeUUID pendingRepair, PreviewKind previewKind)StreamMessageHeader(TableId tableId, InetAddressAndPort sender, TimeUUID planId, boolean sendByFollower, int sessionIndex, int sequenceNumber, long repairedAt, TimeUUID pendingRepair) -
Uses of InetAddressAndPort in org.apache.cassandra.tools
Fields in org.apache.cassandra.tools with type parameters of type InetAddressAndPort Modifier and Type Field Description java.util.Set<InetAddressAndPort>LoaderOptions. ignores -
Uses of InetAddressAndPort in org.apache.cassandra.tools.nodetool
Fields in org.apache.cassandra.tools.nodetool declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortHostStatWithPort. endpointWithPortConstructors in org.apache.cassandra.tools.nodetool with parameters of type InetAddressAndPort Constructor Description HostStatWithPort(java.lang.String token, InetAddressAndPort endpoint, boolean resolveIp, java.lang.Float owns) -
Uses of InetAddressAndPort in org.apache.cassandra.tracing
Fields in org.apache.cassandra.tracing declared as InetAddressAndPort Modifier and Type Field Description InetAddressAndPortTraceState. coordinatorMethods in org.apache.cassandra.tracing with parameters of type InetAddressAndPort Modifier and Type Method Description protected abstract TraceStateTracing. newTraceState(InetAddressAndPort coordinator, TimeUUID sessionId, Tracing.TraceType traceType)voidTracing. traceOutgoingMessage(Message<?> message, int serializedSize, InetAddressAndPort sendTo)Record any tracing data, if enabled on this message.Constructors in org.apache.cassandra.tracing with parameters of type InetAddressAndPort Constructor Description TraceState(InetAddressAndPort coordinator, TimeUUID sessionId, Tracing.TraceType traceType)TraceStateImpl(InetAddressAndPort coordinator, TimeUUID sessionId, Tracing.TraceType traceType) -
Uses of InetAddressAndPort in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport that return InetAddressAndPort Modifier and Type Method Description InetAddressAndPortEvent.NodeEvent. nodeAddressAndPort()Methods in org.apache.cassandra.transport with parameters of type InetAddressAndPort Modifier and Type Method Description static Event.TopologyChangeEvent.TopologyChange. movedNode(InetAddressAndPort address)static Event.TopologyChangeEvent.TopologyChange. newNode(InetAddressAndPort address)static Event.StatusChangeEvent.StatusChange. nodeDown(InetAddressAndPort address)static Event.StatusChangeEvent.StatusChange. nodeUp(InetAddressAndPort address)voidServer.EventNotifier. onDown(InetAddressAndPort endpoint)voidServer.EventNotifier. onJoinCluster(InetAddressAndPort endpoint)voidServer.EventNotifier. onLeaveCluster(InetAddressAndPort endpoint)voidServer.EventNotifier. onMove(InetAddressAndPort endpoint)voidServer.EventNotifier. onUp(InetAddressAndPort endpoint)static Event.TopologyChangeEvent.TopologyChange. removedNode(InetAddressAndPort address) -
Uses of InetAddressAndPort in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils that return InetAddressAndPort Modifier and Type Method Description static InetAddressAndPortFBUtilities. getBroadcastAddressAndPort()Get the broadcast address and port for intra-cluster storage traffic.static InetAddressAndPortFBUtilities. getBroadcastNativeAddressAndPort()This returns the address that is bound to for the native protocol for communicating with clients.static InetAddressAndPortFBUtilities. getLocalAddressAndPort()The address and port to listen on for intra-cluster storage traffic (not client).Methods in org.apache.cassandra.utils that return types with arguments of type InetAddressAndPort Modifier and Type Method Description static java.util.Collection<InetAddressAndPort>TimeUUID.Generator. getAllLocalAddresses()Helper function used exclusively by UUIDGen to createMethods in org.apache.cassandra.utils with parameters of type InetAddressAndPort Modifier and Type Method Description static voidFBUtilities. setBroadcastInetAddressAndPort(InetAddressAndPort addr)THIS IS FOR TESTING ONLY!!static voidDiagnosticSnapshotService. snapshot(SnapshotCommand command, InetAddressAndPort initiator)Method parameters in org.apache.cassandra.utils with type arguments of type InetAddressAndPort Modifier and Type Method Description static voidDiagnosticSnapshotService. duplicateRows(TableMetadata metadata, java.lang.Iterable<InetAddressAndPort> replicas)static voidDiagnosticSnapshotService. repairedDataMismatch(TableMetadata metadata, java.lang.Iterable<InetAddressAndPort> replicas)
-