Uses of Class
org.apache.cassandra.locator.InetAddressAndPort

Packages that use InetAddressAndPort

Package	Description
org.apache.cassandra.audit
org.apache.cassandra.config
org.apache.cassandra.cql3
org.apache.cassandra.db
org.apache.cassandra.db.guardrails
org.apache.cassandra.db.transform
org.apache.cassandra.dht
org.apache.cassandra.dht.tokenallocator
org.apache.cassandra.exceptions
org.apache.cassandra.gms
org.apache.cassandra.hints	Hints subsystem consists of several components.
org.apache.cassandra.index
org.apache.cassandra.io.sstable
org.apache.cassandra.locator
org.apache.cassandra.metrics
org.apache.cassandra.net
org.apache.cassandra.repair
org.apache.cassandra.repair.asymmetric
org.apache.cassandra.repair.autorepair
org.apache.cassandra.repair.consistent
org.apache.cassandra.repair.messages
org.apache.cassandra.repair.state
org.apache.cassandra.schema
org.apache.cassandra.service
org.apache.cassandra.service.disk.usage
org.apache.cassandra.service.paxos
org.apache.cassandra.service.paxos.cleanup
org.apache.cassandra.service.paxos.v1
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.repair
org.apache.cassandra.service.reads.thresholds
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.apache.cassandra.streaming.messages
org.apache.cassandra.tools
org.apache.cassandra.tools.nodetool
org.apache.cassandra.tracing
org.apache.cassandra.transport
org.apache.cassandra.utils

Uses of InetAddressAndPort in org.apache.cassandra.audit

Methods in org.apache.cassandra.audit that return InetAddressAndPort

Modifier and Type	Method	Description
InetAddressAndPort	AuditLogEntry.getHost()
InetAddressAndPort	AuditLogEntry.getSource()

Uses of InetAddressAndPort in org.apache.cassandra.config

Methods in org.apache.cassandra.config that return InetAddressAndPort

Modifier and Type	Method	Description
static InetAddressAndPort	DatabaseDescriptor.getReplaceAddress()

Methods in org.apache.cassandra.config that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
static Set<InetAddressAndPort>	DatabaseDescriptor.getSeeds()

Methods in org.apache.cassandra.config with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
boolean	EncryptionOptions.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, String query, 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 InetAddressAndPort	SystemKeyspace.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 Map<InetAddressAndPort,Set<Range<Token>>>	SystemKeyspace.getTransferredRanges(String description, String keyspace, IPartitioner partitioner)
static Map<InetAddressAndPort,Map<String,String>>	SystemKeyspace.loadDcRackInfo()	Return a map of IP addresses containing a map of dc and rack info
static Map<InetAddressAndPort,UUID>	SystemKeyspace.loadHostIds()	Return a map of store host_ids to IP addresses
static com.google.common.collect.SetMultimap<InetAddressAndPort,Token>	SystemKeyspace.loadTokens()	Return a map of stored tokens to IP addresses

Methods in org.apache.cassandra.db with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
protected void	CounterMutationVerbHandler.applyMutation(Message<CounterMutation> message, InetAddressAndPort respondToAddress)
protected void	MutationVerbHandler.applyMutation(Message<Mutation> message, InetAddressAndPort respondToAddress)
static InetAddressAndPort	SystemKeyspace.getPreferredIP(InetAddressAndPort ep)	Get preferred IP for given endpoint if it is known.
static CassandraVersion	SystemKeyspace.getReleaseVersion(InetAddressAndPort ep)	Get release version for given endpoint.
void	AbstractMutationVerbHandler.processMessage(Message<T> message, InetAddressAndPort respondTo)
static void	SystemKeyspace.updateHintsDropped(InetAddressAndPort ep, TimeUUID timePeriod, int value)
static void	SystemKeyspace.updatePeerInfo(InetAddressAndPort ep, String columnName, Object value)
static void	SystemKeyspace.updatePeerNativeAddress(InetAddressAndPort ep, InetAddressAndPort address)
static boolean	SystemKeyspace.updatePreferredIP(InetAddressAndPort ep, InetAddressAndPort preferred_ip)
static void	SystemKeyspace.updateTokens(InetAddressAndPort ep, Collection<Token> tokens)	Record tokens being used by another node
static void	SystemKeyspace.updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, String keyspace, 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 final Predicates<InetAddressAndPort>	Guardrails.replicaDiskUsage	Guardrail 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 PartitionIterator	DuplicateRowChecker.duringRead(PartitionIterator iterator, 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 final InetAddressAndPort	BootStrapper.address

Methods 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 Collection<Token>	BootStrapper.getBootstrapTokens(TokenMetadata metadata, InetAddressAndPort address, long schemaTimeoutMillis, long ringTimeoutMillis)	if initialtoken was specified, use that (split on comma).
boolean	OwnedRanges.validateRangeRequest(Collection<Range<Token>> requestedRanges, String requestId, 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 EndpointsByReplica	RangeStreamer.calculateRangesToFetchWithPreferredEndpoints(BiFunction<InetAddressAndPort,EndpointsForRange,EndpointsForRange> snitchGetSortedListByProximity, AbstractReplicationStrategy strat, ReplicaCollection<?> fetchRanges, boolean useStrictConsistency, TokenMetadata tmdBefore, TokenMetadata tmdAfter, String keyspace, 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

Modifier	Constructor	Description
	BootStrapper(InetAddressAndPort address, Collection<Token> tokens, TokenMetadata tmd)
	RangeStreamer(TokenMetadata metadata, 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

Modifier	Constructor	Description
	AllowedSourcesFilter(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(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 Collection<Token>	TokenAllocation.allocateTokens(TokenMetadata tokenMetadata, int replicas, InetAddressAndPort endpoint, int numTokens)
static 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(NavigableMap<Token,InetAddressAndPort> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<InetAddressAndPort> strategy, IPartitioner partitioner)
static TokenAllocator<InetAddressAndPort>	TokenAllocatorFactory.createTokenAllocator(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

Modifier	Constructor	Description
	FakeNode(InetAddressAndPort address, Integer rackId, 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
final Map<InetAddressAndPort,RequestFailureReason>	RequestFailureException.failureReasonByEndpoint

Constructor parameters in org.apache.cassandra.exceptions with type arguments of type InetAddressAndPort

Modifier	Constructor	Description
	QueryReferencesTooManyIndexesAbortException(String msg, int nodes, long maxValue, boolean dataPresent, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
protected	ReadAbortException(String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
protected	ReadFailureException(String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
	ReadFailureException(ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
	ReadSizeAbortException(String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
	RequestFailureException(ExceptionCode code, String msg, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
protected	RequestFailureException(ExceptionCode code, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
	TombstoneAbortException(String message, int nodes, long tombstones, boolean dataPresent, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
	WriteFailureException(ConsistencyLevel consistency, int received, int blockFor, WriteType writeType, 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
final ConcurrentMap<InetAddressAndPort,EndpointState>	Gossiper.endpointStateMap
static final Predicate<InetAddressAndPort>	FailureDetector.isEndpointAlive
final Set<InetAddressAndPort>	Gossiper.liveEndpoints

Methods in org.apache.cassandra.gms that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
Map<InetAddressAndPort,EndpointState>	Gossiper.doShadowRound()
Map<InetAddressAndPort,EndpointState>	Gossiper.doShadowRound(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()
Set<InetAddressAndPort>	Gossiper.getLiveMembers()
Set<InetAddressAndPort>	Gossiper.getLiveTokenOwners()
Set<InetAddressAndPort>	Gossiper.getUnreachableMembers()
Set<InetAddressAndPort>	Gossiper.getUnreachableTokenOwners()
Collection<InetAddressAndPort>	Gossiper.unsafeClearRemoteState()

Methods in org.apache.cassandra.gms with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	Gossiper.addExpireTimeForEndpoint(InetAddressAndPort endpoint, long expireTime)
void	Gossiper.addSavedEndpoint(InetAddressAndPort ep)	Add an endpoint we knew about previously, but whose state is unknown
void	Gossiper.advertiseRemoving(InetAddressAndPort endpoint, UUID hostId, 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' invoked
void	Gossiper.advertiseTokenRemoved(InetAddressAndPort endpoint, UUID hostId)	Handles switching the endpoint's state from REMOVING_TOKEN to REMOVED_TOKEN This should only be called after advertiseRemoving
default void	IEndpointStateChangeSubscriber.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
VersionedValue	VersionedValue.VersionedValueFactory.bootReplacingWithPort(InetAddressAndPort oldNode)
int	Gossiper.compareEndpointStartup(InetAddressAndPort addr1, InetAddressAndPort addr2)	determine which endpoint started up earlier
void	Gossiper.convict(InetAddressAndPort endpoint, double phi)	This method is part of IFailureDetectionEventListener interface.
void	IFailureDetectionEventListener.convict(InetAddressAndPort ep, double phi)	Convict the specified endpoint.
EndpointState	Gossiper.copyEndpointStateForEndpoint(InetAddressAndPort ep)
void	Gossiper.doOnChangeNotifications(InetAddressAndPort addr, ApplicationState state, VersionedValue value)
void	FailureDetector.forceConviction(InetAddressAndPort ep)
void	IFailureDetector.forceConviction(InetAddressAndPort ep)	force conviction of endpoint in the failure detector
String	Gossiper.getApplicationState(InetAddressAndPort endpoint, ApplicationState state)	The value for the provided application state for the provided endpoint as currently known by this Gossip instance.
int	Gossiper.getCurrentGenerationNumber(InetAddressAndPort endpoint)
long	Gossiper.getEndpointDowntime(InetAddressAndPort ep)
EndpointState	Gossiper.getEndpointStateForEndpoint(InetAddressAndPort ep)
EndpointState	IGossiper.getEndpointStateForEndpoint(InetAddressAndPort ep)
protected long	Gossiper.getExpireTimeForEndpoint(InetAddressAndPort endpoint)
String	Gossiper.getForEndpoint(InetAddressAndPort ep, ApplicationState state)
UUID	Gossiper.getHostId(InetAddressAndPort endpoint)
UUID	Gossiper.getHostId(InetAddressAndPort endpoint, Map<InetAddressAndPort,EndpointState> epStates)
default CassandraVersion	IGossiper.getReleaseVersion(InetAddressAndPort ep)
UUID	Gossiper.getSchemaVersion(InetAddressAndPort ep)
void	Gossiper.initializeNodeUnsafe(InetAddressAndPort addr, UUID uuid, int generationNbr)
void	Gossiper.initializeNodeUnsafe(InetAddressAndPort addr, UUID uuid, int netVersion, int generationNbr)
void	Gossiper.initializeUnreachableNodeUnsafe(InetAddressAndPort addr)	Creates a new dead EndpointState that is empty.
void	Gossiper.injectApplicationState(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
boolean	Gossiper.inJustRemovedEndpoints(InetAddressAndPort ep)
VersionedValue	VersionedValue.VersionedValueFactory.internalAddressAndPort(InetAddressAndPort private_ip_and_port)
void	FailureDetector.interpret(InetAddressAndPort ep)
void	IFailureDetector.interpret(InetAddressAndPort ep)	This method is invoked by any entity wanting to interrogate the status of an endpoint.
boolean	Gossiper.isAdministrativelyInactiveState(InetAddressAndPort endpoint)
boolean	FailureDetector.isAlive(InetAddressAndPort ep)
boolean	Gossiper.isAlive(InetAddressAndPort endpoint)
boolean	IFailureDetector.isAlive(InetAddressAndPort ep)	Failure Detector's knowledge of whether a node is up or down.
boolean	Gossiper.isGossipOnlyMember(InetAddressAndPort endpoint)
boolean	Gossiper.isKnownEndpoint(InetAddressAndPort endpoint)
boolean	Gossiper.isSafeForStartup(InetAddressAndPort endpoint, UUID localHostUUID, boolean isBootstrapping, Map<InetAddressAndPort,EndpointState> epStates)	Check if this node can safely be started and join the ring.
protected void	Gossiper.markAsShutdown(InetAddressAndPort endpoint)	Deprecated. see CASSANDRA-18913
protected void	Gossiper.markAsShutdown(InetAddressAndPort endpoint, EndpointState remoteState)	This method is used to mark a node as shutdown; that is it gracefully exited on its own and told us about it
void	Gossiper.markDead(InetAddressAndPort addr, EndpointState localState)
protected void	Gossiper.maybeFinishShadowRound(InetAddressAndPort respondent, boolean isInShadowRound, Map<InetAddressAndPort,EndpointState> epStateMap)
VersionedValue	VersionedValue.VersionedValueFactory.nativeaddressAndPort(InetAddressAndPort address)
default void	IEndpointStateChangeSubscriber.onAlive(InetAddressAndPort endpoint, EndpointState state)
default void	IEndpointStateChangeSubscriber.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
default void	IEndpointStateChangeSubscriber.onDead(InetAddressAndPort endpoint, EndpointState state)
default void	IEndpointStateChangeSubscriber.onJoin(InetAddressAndPort endpoint, EndpointState epState)	Use to inform interested parties about the change in the state for specified endpoint
default void	IEndpointStateChangeSubscriber.onRemove(InetAddressAndPort endpoint)
default void	IEndpointStateChangeSubscriber.onRestart(InetAddressAndPort endpoint, EndpointState state)	Called whenever a node is restarted.
void	Gossiper.realMarkAlive(InetAddressAndPort addr, EndpointState localState)
void	FailureDetector.remove(InetAddressAndPort ep)
void	IFailureDetector.remove(InetAddressAndPort ep)	remove endpoint from failure detector
void	Gossiper.removeEndpoint(InetAddressAndPort endpoint)	Removes the endpoint from Gossip but retains endpoint state
void	Gossiper.replacedEndpoint(InetAddressAndPort endpoint)	Remove the Endpoint and evict immediately, to avoid gossiping about this node.
void	Gossiper.replacementQuarantine(InetAddressAndPort endpoint)	Quarantine endpoint specifically for replacement purposes.
void	FailureDetector.report(InetAddressAndPort ep)
void	IFailureDetector.report(InetAddressAndPort ep)	This method is invoked by the receiver of the heartbeat.
void	Gossiper.unsafeAnnulEndpoint(InetAddressAndPort endpoint)
void	Gossiper.unsafeGossipWith(InetAddressAndPort ep)
void	Gossiper.unsafeSendLocalEndpointStateTo(InetAddressAndPort ep)
void	Gossiper.unsafeSendShutdown(InetAddressAndPort to)

Method parameters in org.apache.cassandra.gms with type arguments of type InetAddressAndPort

Modifier and Type	Method	Description
void	Gossiper.applyStateLocally(Map<InetAddressAndPort,EndpointState> epStateMap)
void	IGossiper.applyStateLocally(Map<InetAddressAndPort,EndpointState> epStateMap)
Map<InetAddressAndPort,EndpointState>	Gossiper.doShadowRound(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.
UUID	Gossiper.getHostId(InetAddressAndPort endpoint, Map<InetAddressAndPort,EndpointState> epStates)
boolean	Gossiper.isSafeForStartup(InetAddressAndPort endpoint, UUID localHostUUID, boolean isBootstrapping, Map<InetAddressAndPort,EndpointState> epStates)	Check if this node can safely be started and join the ring.
protected void	Gossiper.maybeFinishShadowRound(InetAddressAndPort respondent, boolean isInShadowRound, Map<InetAddressAndPort,EndpointState> epStateMap)
void	Gossiper.notifyFailureDetector(Map<InetAddressAndPort,EndpointState> remoteEpStateMap)
void	IGossiper.notifyFailureDetector(Map<InetAddressAndPort,EndpointState> remoteEpStateMap)
boolean	Gossiper.sufficientForStartupSafetyCheck(Map<InetAddressAndPort,EndpointState> epStateMap)

Uses of InetAddressAndPort in org.apache.cassandra.hints

Methods in org.apache.cassandra.hints with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	HintsService.deleteAllHintsForEndpoint(InetAddressAndPort target)	Deletes all hints for the provided destination.

Uses of InetAddressAndPort in org.apache.cassandra.index

Fields in org.apache.cassandra.index with type parameters of type InetAddressAndPort

Modifier and Type	Field	Description
final Map<InetAddressAndPort,Map<String,Index.Status>>	IndexStatusManager.peerIndexStatus	A map of per-endpoint index statuses: the key of inner map is the identifier "keyspace.index"

Methods in org.apache.cassandra.index with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
Index.Status	IndexStatusManager.getIndexStatus(InetAddressAndPort peer, String keyspace, String index)
void	IndexStatusManager.receivePeerIndexStatus(InetAddressAndPort endpoint, VersionedValue versionedValue)	Recieve a new index status map from a peer.

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
Map<InetAddressAndPort,Collection<Range<Token>>>	SSTableLoader.Client.getEndpointToRangesMap()
Set<InetAddressAndPort>	SSTableLoader.getFailedHosts()

Methods in org.apache.cassandra.io.sstable with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
protected void	SSTableLoader.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
StreamResultFuture	SSTableLoader.stream(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
InetAddressAndPort	InetAddressAndPort.FwdFrmSerializer.deserialize(DataInputPlus in, int version)
InetAddressAndPort	InetAddressAndPort.Serializer.deserialize(DataInputPlus in, int version)
InetAddressAndPort	Endpoints.endpoint(int i)
InetAddressAndPort	RangesAtEndpoint.endpoint()
final InetAddressAndPort	Replica.endpoint()
InetAddressAndPort	InetAddressAndPort.Serializer.extract(ByteBuffer buf, int position)	Extract InetAddressAndPort from the provided ByteBuffer without altering its state.
static InetAddressAndPort	InetAddressAndPort.getByAddress(byte[] address)
static InetAddressAndPort	InetAddressAndPort.getByAddress(InetAddress address)
static InetAddressAndPort	InetAddressAndPort.getByAddress(InetSocketAddress address)
static InetAddressAndPort	InetAddressAndPort.getByAddressOverrideDefaults(InetAddress address, byte[] addressBytes, Integer port)
static InetAddressAndPort	InetAddressAndPort.getByAddressOverrideDefaults(InetAddress address, Integer port)
static InetAddressAndPort	InetAddressAndPort.getByName(String name)
static InetAddressAndPort	InetAddressAndPort.getByNameOverrideDefaults(String name, Integer port)
InetAddressAndPort	TokenMetadata.getEndpoint(Token token)
InetAddressAndPort	TokenMetadata.getEndpointForHostId(UUID hostId)	Return the end-point for a unique host ID
static InetAddressAndPort	InetAddressAndPort.getLocalHost()
static InetAddressAndPort	InetAddressAndPort.getLoopbackAddress()
InetAddressAndPort	InetAddressAndPort.withPort(int port)

Methods in org.apache.cassandra.locator that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
Map<InetAddressAndPort,Replica>	Endpoints.byEndpoint()
List<InetAddressAndPort>	Endpoints.endpointList()
Set<InetAddressAndPort>	Endpoints.endpoints()
static Predicate<InetAddressAndPort>	InOurDc.endpoints()
Set<InetAddressAndPort>	RangesAtEndpoint.endpoints()
Set<InetAddressAndPort>	ReplicaCollection.endpoints()
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpoints(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints)
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpointsDynamic(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints, Predicate<InetAddressAndPort> isAlive)
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpointsRandom(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints, Consumer<List<?>> shuffle, Predicate<InetAddressAndPort> isAlive, Function<Integer,Integer> indexPicker)
static List<InetAddressAndPort>	InetAddressAndPort.getAllByName(String name)
static List<InetAddressAndPort>	InetAddressAndPort.getAllByNameOverrideDefaults(String name, Integer port)
Set<InetAddressAndPort>	TokenMetadata.getAllEndpoints()
Set<InetAddressAndPort>	TokenMetadata.getAllMembers()
BiMultiValMap<Token,InetAddressAndPort>	TokenMetadata.getBootstrapTokens()
com.google.common.collect.Multimap<String,InetAddressAndPort>	TokenMetadata.Topology.getDatacenterEndpoints()
com.google.common.collect.ImmutableMap<String,com.google.common.collect.ImmutableMultimap<String,InetAddressAndPort>>	TokenMetadata.Topology.getDatacenterRacks()
com.google.common.collect.ImmutableMultimap<String,InetAddressAndPort>	TokenMetadata.getDC2AllEndpoints(IEndpointSnitch snitch)
Map<InetAddressAndPort,UUID>	TokenMetadata.getEndpointToHostIdMapForReading()
com.google.common.collect.Multimap<InetAddressAndPort,Token>	TokenMetadata.getEndpointToTokenMapForReading()
Set<InetAddressAndPort>	TokenMetadata.getLeavingEndpoints()	caller should not modify leavingEndpoints
Set<Pair<Token,InetAddressAndPort>>	TokenMetadata.getMovingEndpoints()	Endpoints which are migrating to the new tokens
Map<Token,InetAddressAndPort>	TokenMetadata.getNormalAndBootstrappingTokenToEndpointMap()
Optional<InetAddressAndPort>	TokenMetadata.getReplacementNode(InetAddressAndPort endpoint)
Optional<InetAddressAndPort>	TokenMetadata.getReplacingNode(InetAddressAndPort endpoint)
List<InetAddressAndPort>	SeedProvider.getSeeds()
List<InetAddressAndPort>	SimpleSeedProvider.getSeeds()
static Set<InetAddressAndPort>	InetAddressAndPort.parseHosts(String value, boolean failOnError)	Parses a comma-separated list of hosts to a set of InetAddressAndPort
static List<InetAddressAndPort>	ReplicaPlans.sortByProximity(Collection<InetAddressAndPort> endpoints)

Methods in org.apache.cassandra.locator with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	TokenMetadata.addBootstrapTokens(Collection<Token> tokens, InetAddressAndPort endpoint)
void	TokenMetadata.addLeavingEndpoint(InetAddressAndPort endpoint)
void	TokenMetadata.addMovingEndpoint(Token token, InetAddressAndPort endpoint)	Add a new moving endpoint
void	TokenMetadata.addReplaceTokens(Collection<Token> replacingTokens, InetAddressAndPort newNode, InetAddressAndPort oldNode)
void	ReconnectableSnitchHelper.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
static RangesAtEndpoint.Builder	RangesAtEndpoint.builder(InetAddressAndPort endpoint)
static RangesAtEndpoint.Builder	RangesAtEndpoint.builder(InetAddressAndPort endpoint, int capacity)
static Collector<Replica,RangesAtEndpoint.Builder,RangesAtEndpoint>	RangesAtEndpoint.collector(InetAddressAndPort endpoint)
abstract int	AbstractEndpointSnitch.compareEndpoints(InetAddressAndPort target, Replica r1, Replica r2)
int	AbstractNetworkTopologySnitch.compareEndpoints(InetAddressAndPort address, Replica r1, Replica r2)
int	DynamicEndpointSnitch.compareEndpoints(InetAddressAndPort target, Replica a1, Replica a2)
int	IEndpointSnitch.compareEndpoints(InetAddressAndPort target, Replica r1, Replica r2)	compares two endpoints in relation to the target endpoint, returning as Comparator.compare would
int	SimpleSnitch.compareEndpoints(InetAddressAndPort target, Replica r1, Replica r2)
int	InetAddressAndPort.compareTo(InetAddressAndPort o)
boolean	Endpoints.contains(InetAddressAndPort endpoint)
static RangesAtEndpoint	RangesAtEndpoint.empty(InetAddressAndPort endpoint)
static Replica	Replica.fullReplica(InetAddressAndPort endpoint, Range<Token> range)
static Replica	Replica.fullReplica(InetAddressAndPort endpoint, Token start, Token end)
RangesAtEndpoint	RangesByEndpoint.get(InetAddressAndPort endpoint)
RangesAtEndpoint	AbstractReplicationStrategy.getAddressReplicas(InetAddressAndPort endpoint)
RangesAtEndpoint	AbstractReplicationStrategy.getAddressReplicas(TokenMetadata metadata, InetAddressAndPort endpoint)
abstract String	AbstractNetworkTopologySnitch.getDatacenter(InetAddressAndPort endpoint)	Return the data center for which an endpoint resides in
String	DynamicEndpointSnitch.getDatacenter(InetAddressAndPort endpoint)
String	GossipingPropertyFileSnitch.getDatacenter(InetAddressAndPort endpoint)	Return the data center for which an endpoint resides in
String	IEndpointSnitch.getDatacenter(InetAddressAndPort endpoint)	returns a String representing the datacenter the given endpoint belongs to
String	PropertyFileSnitch.getDatacenter(InetAddressAndPort endpoint)	Return the data center for which an endpoint resides in
String	RackInferringSnitch.getDatacenter(InetAddressAndPort endpoint)
String	SimpleSnitch.getDatacenter(InetAddressAndPort endpoint)
static String[]	PropertyFileSnitch.getEndpointInfo(InetAddressAndPort endpoint)	Get the raw information about an end point
UUID	TokenMetadata.getHostId(InetAddressAndPort endpoint)	Return the unique host ID for an end-point.
Pair<String,String>	TokenMetadata.Topology.getLocation(InetAddressAndPort addr)
RangesAtEndpoint	AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata, Collection<Token> pendingTokens, InetAddressAndPort pendingAddress)
RangesAtEndpoint	AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata, Token pendingToken, InetAddressAndPort pendingAddress)
RangesAtEndpoint	TokenMetadata.getPendingRanges(String keyspaceName, InetAddressAndPort endpoint)
abstract String	AbstractNetworkTopologySnitch.getRack(InetAddressAndPort endpoint)	Return the rack for which an endpoint resides in
String	DynamicEndpointSnitch.getRack(InetAddressAndPort endpoint)
String	GossipingPropertyFileSnitch.getRack(InetAddressAndPort endpoint)	Return the rack for which an endpoint resides in
String	IEndpointSnitch.getRack(InetAddressAndPort endpoint)	returns a String representing the rack the given endpoint belongs to
String	PropertyFileSnitch.getRack(InetAddressAndPort endpoint)	Return the rack for which an endpoint resides in
String	RackInferringSnitch.getRack(InetAddressAndPort endpoint)
String	SimpleSnitch.getRack(InetAddressAndPort endpoint)
Optional<InetAddressAndPort>	TokenMetadata.getReplacementNode(InetAddressAndPort endpoint)
Optional<InetAddressAndPort>	TokenMetadata.getReplacingNode(InetAddressAndPort endpoint)
static double	DynamicEndpointSnitch.getSeverity(InetAddressAndPort endpoint)
static Replica	SystemReplicas.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).
Collection<Token>	TokenMetadata.getTokens(InetAddressAndPort endpoint)
static boolean	InOurDc.isInOurDc(InetAddressAndPort endpoint)
boolean	TokenMetadata.isLeaving(InetAddressAndPort endpoint)
boolean	TokenMetadata.isMember(InetAddressAndPort endpoint)
boolean	TokenMetadata.isMoving(InetAddressAndPort endpoint)
Replica	EndpointsForToken.lookup(InetAddressAndPort endpoint)
Replica	ReplicaPlan.AbstractForRead.lookup(InetAddressAndPort endpoint)
Replica	ReplicaPlan.ForWrite.lookup(InetAddressAndPort endpoint)
Replica	ReplicaPlan.lookup(InetAddressAndPort endpoint)
protected RangesAtEndpoint.Builder	RangesByEndpoint.Builder.newBuilder(InetAddressAndPort endpoint)
void	ReconnectableSnitchHelper.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	ReconnectableSnitchHelper.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	ReconnectableSnitchHelper.onDead(InetAddressAndPort endpoint, EndpointState state)
void	ReconnectableSnitchHelper.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	ReconnectableSnitchHelper.onRemove(InetAddressAndPort endpoint)
void	ReconnectableSnitchHelper.onRestart(InetAddressAndPort endpoint, EndpointState state)
int	TokenMetadata.pendingRangeChanges(InetAddressAndPort source)
void	DynamicEndpointSnitch.receiveTiming(InetAddressAndPort host, long latency, TimeUnit unit)
void	TokenMetadata.removeEndpoint(InetAddressAndPort endpoint)
void	TokenMetadata.removeFromMoving(InetAddressAndPort endpoint)	Remove pair of token/address from moving endpoints
void	InetAddressAndPort.FwdFrmSerializer.serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)
void	InetAddressAndPort.Serializer.serialize(InetAddressAndPort endpoint, DataOutputPlus out, int version)
long	InetAddressAndPort.FwdFrmSerializer.serializedSize(InetAddressAndPort from, int version)
long	InetAddressAndPort.Serializer.serializedSize(InetAddressAndPort from, int version)
<C extends ReplicaCollection<? extends C>> C	AbstractEndpointSnitch.sortedByProximity(InetAddressAndPort address, C unsortedAddress)	Sorts the Collection of node addresses by proximity to the given address
<C extends ReplicaCollection<? extends C>> C	DynamicEndpointSnitch.sortedByProximity(InetAddressAndPort address, C unsortedAddresses)
<C extends ReplicaCollection<? extends C>> C	IEndpointSnitch.sortedByProximity(InetAddressAndPort address, C addresses)	returns a new List sorted by proximity to the given endpoint
<C extends ReplicaCollection<? extends C>> C	SimpleSnitch.sortedByProximity(InetAddressAndPort address, C unsortedAddress)
static Replica	Replica.transientReplica(InetAddressAndPort endpoint, Range<Token> range)
static Replica	Replica.transientReplica(InetAddressAndPort endpoint, Token start, Token end)
void	TokenMetadata.updateHostId(UUID hostId, InetAddressAndPort endpoint)	Store an end-point to host ID mapping.
void	TokenMetadata.updateNormalToken(Token token, InetAddressAndPort endpoint)	Update token map with a single token/endpoint pair in normal state.
void	TokenMetadata.updateNormalTokens(Collection<Token> tokens, InetAddressAndPort endpoint)
TokenMetadata.Topology	TokenMetadata.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 Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpoints(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints)
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpointsDynamic(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints, Predicate<InetAddressAndPort> isAlive)
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpointsDynamic(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints, Predicate<InetAddressAndPort> isAlive)
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpointsRandom(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints, Consumer<List<?>> shuffle, Predicate<InetAddressAndPort> isAlive, Function<Integer,Integer> indexPicker)
static Collection<InetAddressAndPort>	ReplicaPlans.filterBatchlogEndpointsRandom(boolean preferLocalRack, String localRack, com.google.common.collect.Multimap<String,InetAddressAndPort> endpoints, Consumer<List<?>> shuffle, Predicate<InetAddressAndPort> isAlive, Function<Integer,Integer> indexPicker)
static ReplicaPlan.ForRangeRead	ReplicaPlans.forFullRangeRead(Keyspace keyspace, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, Set<InetAddressAndPort> endpointsToContact, int vnodeCount)	Construct a plan for reading the provided range at the provided consistency level on given endpoints.
static EndpointsForRange	SystemReplicas.getSystemReplicas(Collection<InetAddressAndPort> endpoints)
E	Endpoints.keep(Set<InetAddressAndPort> keep)
E	Endpoints.select(Iterable<InetAddressAndPort> endpoints, boolean ignoreMissing)
static List<InetAddressAndPort>	ReplicaPlans.sortByProximity(Collection<InetAddressAndPort> endpoints)
static List<String>	InetAddressAndPort.stringify(Iterable<InetAddressAndPort> endpoints)
static List<String>	InetAddressAndPort.stringify(Iterable<InetAddressAndPort> endpoints, boolean withPort)
void	TokenMetadata.updateHostIds(Map<UUID,InetAddressAndPort> hostIdToEndpointMap)
void	TokenMetadata.updateNormalTokens(com.google.common.collect.Multimap<InetAddressAndPort,Token> endpointTokens)	Update token map with a set of token/endpoint pairs in normal state.
E	Endpoints.without(Set<InetAddressAndPort> remove)

Constructors in org.apache.cassandra.locator with parameters of type InetAddressAndPort

Modifier	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

Modifier	Constructor	Description
	RangesByEndpoint(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 StreamingMetrics	StreamingMetrics.get(InetAddressAndPort ip)
void	HintedHandoffMetrics.incrCreatedHints(InetAddressAndPort address)
void	HintedHandoffMetrics.incrPastWindow(InetAddressAndPort address)
MessagingMetrics.DCLatencyRecorder	MessagingMetrics.internodeLatencyRecorder(InetAddressAndPort from)
static void	HintsServiceMetrics.updateDelayMetrics(InetAddressAndPort endpoint, long delay)

Constructors in org.apache.cassandra.metrics with parameters of type InetAddressAndPort

Modifier	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
final InetAddressAndPort	InboundConnectionSettings.bindAddress
final InetAddressAndPort	OutboundConnectionSettings.connectTo
final InetAddressAndPort	Message.Header.from
final InetAddressAndPort	OutboundConnectionSettings.from
final InetAddressAndPort	OutboundConnectionSettings.to

Fields in org.apache.cassandra.net with type parameters of type InetAddressAndPort

Modifier and Type	Field	Description
final ConcurrentMap<InetAddressAndPort,OutboundConnections>	MessagingServiceMBeanImpl.channelManagers
final Function<InetAddressAndPort,InboundMessageHandlers>	InboundConnectionSettings.handlers
final ConcurrentMap<InetAddressAndPort,InboundMessageHandlers>	MessagingServiceMBeanImpl.messageHandlers

Methods in org.apache.cassandra.net that return InetAddressAndPort

Modifier and Type	Method	Description
InetAddressAndPort	OutboundConnectionSettings.connectTo()
InetAddressAndPort	Message.from()	Sender of the message.
InetAddressAndPort	MessagingService.FailureResponseException.from()
InetAddressAndPort	OutboundConnectionSettings.from()
InetAddressAndPort	Message.respondTo()	The originator of the request - used when forwarding and will differ from Message.from()

Methods in org.apache.cassandra.net with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	OutboundSink.accept(Message<?> message, InetAddressAndPort to, ConnectionType connectionType)
void	OutboundSink.Sink.accept(Message<?> message, InetAddressAndPort to, ConnectionType connectionType)
void	LatencySubscribers.add(InetAddressAndPort address, long latency, TimeUnit unit)
void	RequestCallbacks.addWithExpiration(RequestCallback<?> cb, Message<?> message, InetAddressAndPort to)	Register the provided RequestCallback, inferring expiry and id from the provided Message.
void	MessagingService.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)
int	EndpointMessagingVersions.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 and MessagingService.current_version.
int	EndpointMessagingVersions.getRaw(InetAddressAndPort endpoint)	Returns the messaging-version exactly as announced by the given endpoint.
LatencyConsumer	InboundMessageHandlers.GlobalMetricCallbacks.internodeLatencyRecorder(InetAddressAndPort to)
void	MessagingService.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 immediately
boolean	EndpointMessagingVersions.knows(InetAddressAndPort endpoint)
void	LatencySubscribers.maybeAdd(RequestCallback cb, InetAddressAndPort address, long latency, TimeUnit unit)	Track latency information for the dynamic snitch
io.netty.util.concurrent.Future<Void>	MessagingService.maybeReconnectWithNewIp(InetAddressAndPort address, InetAddressAndPort preferredAddress)	Reconnect to the peer using the given addr.
void	RequestCallbacks.onDiscardOnClose(Message<?> message, InetAddressAndPort peer)
void	RequestCallbacks.onExpired(Message<?> message, InetAddressAndPort peer)
void	RequestCallbacks.onFailedSerialize(Message<?> message, InetAddressAndPort peer, int messagingVersion, int bytesWrittenToNetwork, Throwable failure)
default void	RequestCallback.onFailure(InetAddressAndPort from, RequestFailureReason failureReason)	Called when there is an exception on the remote node or timeout happens
void	RequestCallbackWithFailure.onFailure(InetAddressAndPort from, RequestFailureReason failureReason)	Called when there is an exception on the remote node or timeout happens
void	RequestCallbacks.onOverloaded(Message<?> message, InetAddressAndPort peer)
void	LatencySubscribers.Subscriber.receiveTiming(InetAddressAndPort address, long latency, TimeUnit unit)
static <T> Message<T>	Message.remoteResponse(InetAddressAndPort from, Verb verb, T payload)	Used by the MultiRangeReadCommand to split multi-range responses from a replica into single-range responses.
RequestCallbacks.CallbackInfo	RequestCallbacks.remove(long id, InetAddressAndPort peer)	Remove and return the RequestCallbacks.CallbackInfo associated with given id and peer, if known.
void	RequestCallbacks.removeAndRespond(long id, InetAddressAndPort peer, Message message)
void	MessagingService.removeInbound(InetAddressAndPort from)	Only to be invoked once we believe the connections will never be used again.
void	EndpointMessagingVersions.reset(InetAddressAndPort endpoint)
<REQ> void	MessageDelivery.send(Message<REQ> message, InetAddressAndPort to)
void	MessagingService.send(Message message, InetAddressAndPort to)	Send a message to a given endpoint.
void	MessagingService.send(Message message, InetAddressAndPort to, ConnectionType specifyConnection)
<REQ, RSP> void	MessageDelivery.sendWithCallback(Message<REQ> message, InetAddressAndPort to, RequestCallback<RSP> cb)
<REQ, RSP> void	MessageDelivery.sendWithCallback(Message<REQ> message, InetAddressAndPort to, RequestCallback<RSP> cb, ConnectionType specifyConnection)
void	MessagingService.sendWithCallback(Message message, InetAddressAndPort to, RequestCallback cb)	Send a non-mutation message to a given endpoint.
void	MessagingService.sendWithCallback(Message message, InetAddressAndPort to, RequestCallback cb, ConnectionType specifyConnection)
<REQ, RSP> Future<Message<RSP>>	MessageDelivery.sendWithResult(Message<REQ> message, InetAddressAndPort to)
<REQ, RSP> Future<Message<RSP>>	MessagingService.sendWithResult(Message<REQ> message, InetAddressAndPort to)
int	EndpointMessagingVersions.set(InetAddressAndPort endpoint, int version)
static <T> Message<T>	Message.synthetic(InetAddressAndPort from, Verb verb, T payload)
OutboundConnectionSettings	OutboundConnectionSettings.toEndpoint(InetAddressAndPort endpoint)
InboundConnectionSettings	InboundConnectionSettings.withBindAddress(InetAddressAndPort bindAddress)
OutboundConnectionSettings	OutboundConnectionSettings.withConnectTo(InetAddressAndPort connectTo)
Message<T>	Message.withFrom(InetAddressAndPort from)
OutboundConnectionSettings	OutboundConnectionSettings.withFrom(InetAddressAndPort from)

Method parameters in org.apache.cassandra.net with type arguments of type InetAddressAndPort

Modifier and Type	Method	Description
void	OutboundSink.add(BiPredicate<Message<?>,InetAddressAndPort> allow)
boolean	StartupClusterConnectivityChecker.execute(Set<InetAddressAndPort> peers, Function<InetAddressAndPort,String> getDatacenterSource)
boolean	StartupClusterConnectivityChecker.execute(Set<InetAddressAndPort> peers, Function<InetAddressAndPort,String> getDatacenterSource)
void	ForwardingInfo.forEach(BiConsumer<Long,InetAddressAndPort> biConsumer)	Apply the provided consumer to all (host, message_id) pairs.
static boolean	RequestCallback.isTimeout(Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
void	OutboundSink.remove(BiPredicate<Message<?>,InetAddressAndPort> allow)
InboundConnectionSettings	InboundConnectionSettings.withHandlers(Function<InetAddressAndPort,InboundMessageHandlers> handlers)

Constructors in org.apache.cassandra.net with parameters of type InetAddressAndPort

Modifier	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

Modifier	Constructor	Description
	ForwardingInfo(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
protected final InetAddressAndPort	AbstractRepairTask.broadcastAddressAndPort
final InetAddressAndPort	SyncNodePair.coordinator
final InetAddressAndPort	TreeResponse.endpoint
final InetAddressAndPort	Validator.initiator
final InetAddressAndPort	SyncNodePair.peer

Fields in org.apache.cassandra.repair with type parameters of type InetAddressAndPort

Modifier and Type	Field	Description
final com.google.common.collect.ImmutableSet<InetAddressAndPort>	CommonRange.endpoints
final Set<InetAddressAndPort>	RepairCoordinator.NeighborsAndRanges.participants
final com.google.common.collect.ImmutableSet<InetAddressAndPort>	CommonRange.transEndpoints

Methods in org.apache.cassandra.repair that return InetAddressAndPort

Modifier and Type	Method	Description
InetAddressAndPort	SharedContext.broadcastAddressAndPort()
InetAddressAndPort	SharedContext.ForwardingSharedContext.broadcastAddressAndPort()
InetAddressAndPort	SharedContext.Global.broadcastAddressAndPort()

Methods in org.apache.cassandra.repair that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
Collection<InetAddressAndPort>	RepairSession.endpoints()

Methods in org.apache.cassandra.repair with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	RepairSession.convict(InetAddressAndPort endpoint, double phi)
void	RepairSession.onRemove(InetAddressAndPort endpoint)
void	RepairSession.onRestart(InetAddressAndPort endpoint, EndpointState epState)

Method parameters in org.apache.cassandra.repair with type arguments of type InetAddressAndPort

Modifier and Type	Method	Description
boolean	CommonRange.matchesEndpoints(Set<InetAddressAndPort> endpoints, Set<InetAddressAndPort> transEndpoints)
void	RepairSession.trackValidationCompletion(Pair<RepairJobDesc,InetAddressAndPort> key, ValidationTask task)

Constructors in org.apache.cassandra.repair with parameters of type InetAddressAndPort

Modifier	Constructor	Description
	AsymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort to, InetAddressAndPort from, List<Range<Token>> differences, PreviewKind previewKind)
	LocalSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, List<Range<Token>> diff, TimeUUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)
	StreamingRepairTask(SharedContext ctx, SyncState state, RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, Collection<Range<Token>> ranges, TimeUUID pendingRepair, PreviewKind previewKind, boolean asymmetric)
	SymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort r1, InetAddressAndPort r2, List<Range<Token>> differences, PreviewKind previewKind)
	SyncNodePair(InetAddressAndPort coordinator, InetAddressAndPort peer)
protected	SyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort primaryEndpoint, InetAddressAndPort peer, List<Range<Token>> rangesToSync, PreviewKind previewKind)
	TreeResponse(InetAddressAndPort endpoint, MerkleTrees trees)
	ValidationTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort endpoint, long nowInSec, PreviewKind previewKind)

Constructor parameters in org.apache.cassandra.repair with type arguments of type InetAddressAndPort

Modifier	Constructor	Description
	CommonRange(Set<InetAddressAndPort> endpoints, Set<InetAddressAndPort> transEndpoints, Collection<Range<Token>> ranges)
	CommonRange(Set<InetAddressAndPort> endpoints, Set<InetAddressAndPort> transEndpoints, Collection<Range<Token>> ranges, boolean hasSkippedReplicas)
	NeighborsAndRanges(boolean shouldExcludeDeadParticipants, Set<InetAddressAndPort> participants, 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
Iterable<Set<InetAddressAndPort>>	StreamFromOptions.allStreams()
Set<InetAddressAndPort>	PreferedNodeFilter.apply(InetAddressAndPort streamingNode, Set<InetAddressAndPort> toStream)
Set<InetAddressAndPort>	HostDifferences.hosts()
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 map
static 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 differences

Methods in org.apache.cassandra.repair.asymmetric with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	HostDifferences.add(InetAddressAndPort endpoint, Collection<Range<Token>> difference)	Adds a set of differences between the node this instance is tracking and endpoint
void	StreamFromOptions.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.
void	IncomingRepairStreamTracker.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 range
void	HostDifferences.addSingleRange(InetAddressAndPort remoteNode, Range<Token> rangeToFetch)
Set<InetAddressAndPort>	PreferedNodeFilter.apply(InetAddressAndPort streamingNode, Set<InetAddressAndPort> toStream)
HostDifferences	DifferenceHolder.get(InetAddressAndPort hostWithDifference)
NavigableSet<Range<Token>>	HostDifferences.get(InetAddressAndPort differingHost)
boolean	DifferenceHolder.hasDifferenceBetween(InetAddressAndPort node1, InetAddressAndPort node2, Range<Token> range)
boolean	HostDifferences.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
Set<InetAddressAndPort>	PreferedNodeFilter.apply(InetAddressAndPort streamingNode, Set<InetAddressAndPort> toStream)

Uses of InetAddressAndPort in org.apache.cassandra.repair.autorepair

Methods in org.apache.cassandra.repair.autorepair that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
static Set<InetAddressAndPort>	AutoRepairUtils.getPriorityHosts(AutoRepairConfig.RepairType repairType)

Method parameters in org.apache.cassandra.repair.autorepair with type arguments of type InetAddressAndPort

Modifier and Type	Method	Description
static void	AutoRepairUtils.addPriorityHosts(AutoRepairConfig.RepairType repairType, Set<InetAddressAndPort> hosts)
protected static TreeSet<UUID>	AutoRepairUtils.getHostIdsInCurrentRing(AutoRepairConfig.RepairType repairType, Set<InetAddressAndPort> allNodesInRing)
static void	AutoRepairUtils.setForceRepair(AutoRepairConfig.RepairType repairType, Set<InetAddressAndPort> hosts)

Uses of InetAddressAndPort in org.apache.cassandra.repair.consistent

Fields in org.apache.cassandra.repair.consistent declared as InetAddressAndPort

Modifier and Type	Field	Description
final InetAddressAndPort	ConsistentSession.coordinator

Fields in org.apache.cassandra.repair.consistent with type parameters of type InetAddressAndPort

Modifier and Type	Field	Description
final com.google.common.collect.ImmutableSet<InetAddressAndPort>	ConsistentSession.participants

Methods in org.apache.cassandra.repair.consistent that return InetAddressAndPort

Modifier and Type	Method	Description
protected InetAddressAndPort	LocalSessions.getBroadcastAddressAndPort()

Methods in org.apache.cassandra.repair.consistent with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	LocalSessions.handleFailSessionMessage(InetAddressAndPort from, FailSession msg)
void	LocalSessions.handleStatusRequest(InetAddressAndPort from, StatusRequest request)
void	LocalSessions.handleStatusResponse(InetAddressAndPort from, StatusResponse response)
protected boolean	LocalSessions.isAlive(InetAddressAndPort address)
protected void	LocalSessions.sendMessage(InetAddressAndPort destination, Message<? extends RepairMessage> message)
void	CoordinatorSession.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
CoordinatorSession	CoordinatorSessions.registerSession(TimeUUID sessionId, 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
final InetAddressAndPort	PrepareConsistentRequest.coordinator
final InetAddressAndPort	SyncRequest.dst
final InetAddressAndPort	SyncRequest.initiator
final InetAddressAndPort	FinalizePromise.participant
final InetAddressAndPort	PrepareConsistentResponse.participant
final InetAddressAndPort	SyncRequest.src

Fields in org.apache.cassandra.repair.messages with type parameters of type InetAddressAndPort

Modifier and Type	Field	Description
final Set<InetAddressAndPort>	PrepareConsistentRequest.participants

Methods in org.apache.cassandra.repair.messages with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
static void	RepairMessage.sendMessageWithFailureCB(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RepairMessage.RepairFailureCallback failureCallback)
static void	RepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint)
static <T> void	RepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback)
static void	RepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint)
static <T> void	RepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback)

Constructors in org.apache.cassandra.repair.messages with parameters of type InetAddressAndPort

Modifier	Constructor	Description
	FinalizePromise(TimeUUID sessionID, InetAddressAndPort participant, boolean promised)
	PrepareConsistentRequest(TimeUUID parentSession, InetAddressAndPort coordinator, Set<InetAddressAndPort> participants)
	PrepareConsistentResponse(TimeUUID parentSession, InetAddressAndPort participant, boolean success)
	SyncRequest(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, Collection<Range<Token>> ranges, PreviewKind previewKind, boolean asymmetric)
	SyncResponse(RepairJobDesc desc, InetAddressAndPort endpoint1, InetAddressAndPort endpoint2, boolean success, List<SessionSummary> summaries)

Constructor parameters in org.apache.cassandra.repair.messages with type arguments of type InetAddressAndPort

Modifier	Constructor	Description
	PrepareConsistentRequest(TimeUUID parentSession, InetAddressAndPort coordinator, 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
final InetAddressAndPort	SyncState.Id.dst
final InetAddressAndPort	ParticipateState.initiator
final InetAddressAndPort	SyncState.Id.initiator
final InetAddressAndPort	ValidationState.initiator
final InetAddressAndPort	SyncState.Id.src

Methods in org.apache.cassandra.repair.state that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
Set<InetAddressAndPort>	CoordinatorState.getParticipants()
Set<InetAddressAndPort>	JobState.getParticipants()
Set<InetAddressAndPort>	SessionState.getParticipants()

Constructors in org.apache.cassandra.repair.state with parameters of type InetAddressAndPort

Modifier	Constructor	Description
	Id(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst)
	ParticipateState(Clock clock, InetAddressAndPort initiator, PrepareMessage msg)
	SyncState(Clock clock, RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst)
	ValidationState(Clock clock, RepairJobDesc desc, InetAddressAndPort initiator)

Constructor parameters in org.apache.cassandra.repair.state with type arguments of type InetAddressAndPort

Modifier	Constructor	Description
	JobState(Clock clock, 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
Map<UUID,Set<InetAddressAndPort>>	DefaultSchemaUpdateHandler.getOutstandingSchemaVersions()
Map<UUID,Set<InetAddressAndPort>>	Schema.getOutstandingSchemaVersions()

Methods in org.apache.cassandra.schema with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	DefaultSchemaUpdateHandler.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	DefaultSchemaUpdateHandler.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	DefaultSchemaUpdateHandler.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	DefaultSchemaUpdateHandler.onDead(InetAddressAndPort endpoint, EndpointState state)
void	DefaultSchemaUpdateHandler.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	DefaultSchemaUpdateHandler.onRemove(InetAddressAndPort endpoint)
void	DefaultSchemaUpdateHandler.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
final InetAddressAndPort	ActiveRepairService.ParentRepairSession.coordinator
final InetAddressAndPort	TokenRange.EndpointDetails.host

Methods in org.apache.cassandra.service that return InetAddressAndPort

Modifier and Type	Method	Description
InetAddressAndPort	StorageService.getEndpointForHostId(UUID hostId)
InetAddressAndPort	FailureRecordingCallback.FailureResponses.getKey()

Methods in org.apache.cassandra.service that return types with arguments of type InetAddressAndPort

Modifier and Type	Method	Description
Set<Map.Entry<InetAddressAndPort,RequestFailureReason>>	FailureRecordingCallback.AsMap.entrySet()
Set<InetAddressAndPort>	StorageService.getLiveRingMembers()
Set<InetAddressAndPort>	StorageService.getLiveRingMembers(boolean excludeDeadStates)
Map<InetAddressAndPort,Double>	LoadBroadcaster.getLoadInfo()
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 void	StorageService.addExpireTimeIfFound(InetAddressAndPort endpoint, long expireTime)
void	ActiveRepairService.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	StorageService.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	StorageService.confirmReplication(InetAddressAndPort node)
void	ActiveRepairService.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.
UUID	StorageService.getHostIdForEndpoint(InetAddressAndPort address)
Collection<Range<Token>>	StorageService.getLocalPrimaryRangeForEndpoint(InetAddressAndPort referenceEndpoint)
String	StorageService.getNativeaddress(InetAddressAndPort endpoint, boolean withPort)	Return the native address associated with an endpoint as a string.
OwnedRanges	StorageService.getNormalizedRanges(String keyspaceName, InetAddressAndPort ep)
Collection<Range<Token>>	StorageService.getPrimaryRangeForEndpointWithinDC(String keyspace, InetAddressAndPort referenceEndpoint)	Get the "primary ranges" within local DC for the specified keyspace and endpoint.
Collection<Range<Token>>	StorageService.getPrimaryRangesForEndpoint(String keyspace, InetAddressAndPort ep)	Get the "primary ranges" for the specified keyspace and endpoint.
RangesAtEndpoint	StorageService.getReplicas(String keyspaceName, InetAddressAndPort endpoint)
RangesAtEndpoint	StorageService.getReplicas(AbstractReplicationStrategy replicationStrategy, InetAddressAndPort endpoint)
Collection<Token>	StorageService.getTokensFor(InetAddressAndPort endpoint)
boolean	StorageService.isRpcReady(InetAddressAndPort endpoint)
void	ActiveRepairService.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	StorageService.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	ActiveRepairService.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	LoadBroadcaster.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	StorageService.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	ActiveRepairService.onDead(InetAddressAndPort endpoint, EndpointState state)
void	StorageService.onDead(InetAddressAndPort endpoint, EndpointState state)
void	IEndpointLifecycleSubscriber.onDown(InetAddressAndPort endpoint)	Called when a node is marked DOWN.
void	AbstractWriteResponseHandler.onFailure(InetAddressAndPort from, RequestFailureReason failureReason)
void	BatchlogResponseHandler.onFailure(InetAddressAndPort from, RequestFailureReason failureReason)
void	FailureRecordingCallback.onFailure(InetAddressAndPort from, RequestFailureReason failureReason)
void	TruncateResponseHandler.onFailure(InetAddressAndPort from, RequestFailureReason failureReason)
protected void	FailureRecordingCallback.onFailureWithMutex(InetAddressAndPort from, RequestFailureReason failureReason)
void	ActiveRepairService.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	LoadBroadcaster.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	StorageService.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	IEndpointLifecycleSubscriber.onJoinCluster(InetAddressAndPort endpoint)	Called when a new node joins the cluster, i.e.
void	IEndpointLifecycleSubscriber.onLeaveCluster(InetAddressAndPort endpoint)	Called when a new node leave the cluster (decommission or removeToken).
void	IEndpointLifecycleSubscriber.onMove(InetAddressAndPort endpoint)	Called when a node has moved (to a new token).
void	ActiveRepairService.onRemove(InetAddressAndPort endpoint)
void	LoadBroadcaster.onRemove(InetAddressAndPort endpoint)
void	StorageService.onRemove(InetAddressAndPort endpoint)
void	ActiveRepairService.onRestart(InetAddressAndPort endpoint, EndpointState state)
void	StorageService.onRestart(InetAddressAndPort endpoint, EndpointState state)
void	IEndpointLifecycleSubscriber.onUp(InetAddressAndPort endpoint)	Called when a node is marked UP.
Future<?>	ActiveRepairService.prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, List<ColumnFamilyStore> columnFamilyStores)
static <O> void	FailureRecordingCallback.FailureResponses.push(AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)
static <O> void	FailureRecordingCallback.FailureResponses.pushExclusive(AtomicReferenceFieldUpdater<O,FailureRecordingCallback.FailureResponses> headUpdater, O owner, InetAddressAndPort from, RequestFailureReason reason)
static FailureRecordingCallback.FailureResponses	FailureRecordingCallback.FailureResponses.pushExclusive(FailureRecordingCallback.FailureResponses head, InetAddressAndPort from, RequestFailureReason reason)
void	ActiveRepairService.registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
void	StorageService.updateTopology(InetAddressAndPort endpoint)
protected boolean	AbstractWriteResponseHandler.waitingFor(InetAddressAndPort from)
protected boolean	BatchlogResponseHandler.waitingFor(InetAddressAndPort from)
protected boolean	DatacenterWriteResponseHandler.waitingFor(InetAddressAndPort from)

Method parameters in org.apache.cassandra.service with type arguments of type InetAddressAndPort

Modifier and Type	Method	Description
void	StorageService.checkForEndpointCollision(UUID localHostId, Set<InetAddressAndPort> peers)
void	ActiveRepairService.cleanUp(TimeUUID parentRepairSession, Set<InetAddressAndPort> endpoints)	Send Verb.CLEANUP_MSG to the given endpoints.
static TokenRange	TokenRange.create(Token.TokenFactory tokenFactory, Range<Token> range, List<InetAddressAndPort> endpoints, boolean withPorts)
Future<?>	ActiveRepairService.prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, List<ColumnFamilyStore> columnFamilyStores)

Constructors in org.apache.cassandra.service with parameters of type InetAddressAndPort

Modifier	Constructor	Description
	FailureResponses(InetAddressAndPort from, RequestFailureReason reason)
	ParentRepairSession(InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, 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
void	DiskUsageBroadcaster.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
boolean	DiskUsageBroadcaster.isFull(InetAddressAndPort endpoint)
boolean	DiskUsageBroadcaster.isStuffed(InetAddressAndPort endpoint)
void	DiskUsageBroadcaster.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	DiskUsageBroadcaster.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	DiskUsageBroadcaster.onDead(InetAddressAndPort endpoint, EndpointState state)
void	DiskUsageBroadcaster.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	DiskUsageBroadcaster.onRemove(InetAddressAndPort endpoint)
void	DiskUsageBroadcaster.onRestart(InetAddressAndPort endpoint, EndpointState state)
DiskUsageState	DiskUsageBroadcaster.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.Response	PaxosPrepareRefresh.RequestHandler.execute(org.apache.cassandra.service.paxos.PaxosPrepareRefresh.Request request, InetAddressAndPort from)
static org.apache.cassandra.service.paxos.PaxosPropose.Response	PaxosPropose.RequestHandler.execute(Commit.Proposal proposal, InetAddressAndPort from)
static boolean	Paxos.isInRangeAndShouldProcess(InetAddressAndPort from, DecoratedKey key, TableMetadata table, boolean includesRead)
void	PaxosCommit.onFailure(InetAddressAndPort from, RequestFailureReason reason)	Record a failure or timeout, and maybe submit a hint to from
void	PaxosPrepare.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosPrepareRefresh.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosPropose.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosPrepare.onRefreshFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosPrepare.onRefreshSuccess(Ballot isSupersededBy, InetAddressAndPort from)
void	PaxosCommit.onResponse(NoPayload response, InetAddressAndPort from)
void	PaxosPrepare.onResponse(org.apache.cassandra.service.paxos.PaxosPrepare.Response response, InetAddressAndPort from)
void	PaxosPropose.onResponse(org.apache.cassandra.service.paxos.PaxosPropose.Response response, InetAddressAndPort from)
protected abstract void	PaxosRequestCallback.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> void	PaxosRequestCallback.executeOnSelf(I parameter, BiFunction<I,InetAddressAndPort,T> execute)
static boolean	PaxosRepair.hasSufficientLiveNodesForTopologyChange(Keyspace keyspace, Range<Token> range, 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
void	PaxosCleanupSession.beforeChange(InetAddressAndPort endpoint, EndpointState currentState, ApplicationState newStateKey, VersionedValue newValue)
void	PaxosCleanupSession.convict(InetAddressAndPort ep, double phi)
void	PaxosRepairState.finishSession(InetAddressAndPort from, PaxosCleanupResponse response)
void	PaxosCleanupSession.onAlive(InetAddressAndPort endpoint, EndpointState state)
void	PaxosCleanupSession.onChange(InetAddressAndPort endpoint, ApplicationState state, VersionedValue value)
void	PaxosCleanupSession.onDead(InetAddressAndPort endpoint, EndpointState state)
void	PaxosCleanupComplete.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosCleanupSession.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosFinishPrepareCleanup.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosStartPrepareCleanup.onFailure(InetAddressAndPort from, RequestFailureReason reason)
void	PaxosCleanupSession.onJoin(InetAddressAndPort endpoint, EndpointState epState)
void	PaxosCleanupSession.onRemove(InetAddressAndPort endpoint)
void	PaxosCleanupSession.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 PaxosCleanup	PaxosCleanup.cleanup(SharedContext ctx, Collection<InetAddressAndPort> endpoints, TableMetadata table, Collection<Range<Token>> ranges, boolean skippedReplicas, Executor executor)
static PaxosFinishPrepareCleanup	PaxosFinishPrepareCleanup.finish(SharedContext ctx, Collection<InetAddressAndPort> endpoints, PaxosCleanupHistory result)
static PaxosStartPrepareCleanup	PaxosStartPrepareCleanup.prepare(SharedContext ctx, TableId tableId, Collection<InetAddressAndPort> endpoints, EndpointState localEpState, 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

Modifier	Constructor	Description
	PaxosCleanup(SharedContext ctx, Collection<InetAddressAndPort> endpoints, TableMetadata table, Collection<Range<Token>> ranges, boolean skippedReplicas, 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
Iterable<InetAddressAndPort>	PrepareCallback.replicasMissingMostRecentCommit(TableMetadata metadata)

Methods in org.apache.cassandra.service.paxos.v1 with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	AbstractPaxosCallback.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
InetAddressAndPort	DigestResolver.DigestResolverDebugResult.from

Methods in org.apache.cassandra.service.reads with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
void	ReadCallback.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
final com.google.common.collect.Multimap<ByteBuffer,InetAddressAndPort>	RepairedDataTracker.digests
final Set<InetAddressAndPort>	RepairedDataTracker.inconclusiveDigests

Methods in org.apache.cassandra.service.reads.repair with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
static Mutation	BlockingReadRepairs.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.
void	RepairedDataTracker.recordDigest(InetAddressAndPort source, ByteBuffer digest, boolean isConclusive)
protected void	BlockingPartitionRepair.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
final com.google.common.collect.ImmutableSet<InetAddressAndPort>	WarningsSnapshot.Counter.instances

Methods in org.apache.cassandra.service.reads.thresholds with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
RequestFailureReason	WarningContext.updateCounters(Map<ParamType,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.Counter	WarningsSnapshot.Counter.create(Set<InetAddressAndPort> instances, AtomicLong maxValue)
WarningsSnapshot.Builder	WarningsSnapshot.Builder.localReadSizeAbort(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue)
WarningsSnapshot.Builder	WarningsSnapshot.Builder.localReadSizeWarning(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue)
void	WarningsSnapshot.maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)
WarningsSnapshot.Builder	WarningsSnapshot.Builder.tombstonesAbort(com.google.common.collect.ImmutableSet<InetAddressAndPort> instances, long maxValue)
WarningsSnapshot.Builder	WarningsSnapshot.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
final InetAddressAndPort	ProgressInfo.peer
final InetAddressAndPort	StreamEvent.SessionCompleteEvent.peer
final InetAddressAndPort	StreamSession.peer	Streaming endpoint.

Methods in org.apache.cassandra.streaming with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
static StreamResultFuture	StreamResultFuture.createFollower(int sessionIndex, TimeUUID planId, StreamOperation streamOperation, InetAddressAndPort from, StreamingChannel channel, int messagingVersion, TimeUUID pendingRepair, PreviewKind previewKind)
StreamSession	StreamManager.findSession(InetAddressAndPort peer, TimeUUID planId, int sessionIndex, boolean searchInitiatorSessions)
static StreamManager.StreamRateLimiter	StreamManager.getEntireSSTableRateLimiter(InetAddressAndPort peer)	Get streaming rate limiter for entire SSTable operations.
StreamSession	StreamCoordinator.getOrCreateInboundSession(InetAddressAndPort from, StreamingChannel channel, int messagingVersion, int id)
StreamSession	StreamCoordinator.getOrCreateOutboundSession(InetAddressAndPort peer)
static StreamManager.StreamRateLimiter	StreamManager.getRateLimiter(InetAddressAndPort peer)	Gets streaming rate limiter.
StreamSession	StreamResultFuture.getSession(InetAddressAndPort peer, int sessionIndex)
StreamSession	StreamCoordinator.getSessionById(InetAddressAndPort peer, int id)
void	StreamSession.MessageStateSink.onClose(InetAddressAndPort from)
void	StreamSession.MessageStateSink.recordMessage(InetAddressAndPort from, StreamMessage.Type message)
void	StreamSession.MessageStateSink.recordState(InetAddressAndPort from, StreamSession.State state)
StreamPlan	StreamPlan.requestRanges(InetAddressAndPort from, String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges)	Request data in keyspace and ranges from specific node.
StreamPlan	StreamPlan.requestRanges(InetAddressAndPort from, String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges, String... columnFamilies)	Request data in columnFamilies under keyspace and ranges from specific node.
StreamPlan	StreamPlan.transferRanges(InetAddressAndPort to, String keyspace, RangesAtEndpoint replicas, String... columnFamilies)	Add transfer task to send data of specific columnFamilies under keyspace and ranges.
void	StreamCoordinator.transferStreams(InetAddressAndPort to, Collection<OutgoingStream> streams)
StreamPlan	StreamPlan.transferStreams(InetAddressAndPort to, Collection<OutgoingStream> streams)	Add transfer task to send given streams

Constructors in org.apache.cassandra.streaming with parameters of type InetAddressAndPort

Modifier	Constructor	Description
	ProgressInfo(InetAddressAndPort peer, int sessionIndex, 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
InetAddressAndPort	StreamingMultiplexedChannel.peer()

Constructors in org.apache.cassandra.streaming.async with parameters of type InetAddressAndPort

Modifier	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
final InetAddressAndPort	StreamInitMessage.from
final InetAddressAndPort	StreamMessageHeader.sender

Constructors in org.apache.cassandra.streaming.messages with parameters of type InetAddressAndPort

Modifier	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
final 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
final InetAddressAndPort	HostStatWithPort.endpointWithPort

Constructors in org.apache.cassandra.tools.nodetool with parameters of type InetAddressAndPort

Modifier	Constructor	Description
	HostStatWithPort(String token, InetAddressAndPort endpoint, boolean resolveIp, Float owns)

Uses of InetAddressAndPort in org.apache.cassandra.tracing

Fields in org.apache.cassandra.tracing declared as InetAddressAndPort

Modifier and Type	Field	Description
final InetAddressAndPort	TraceState.coordinator

Methods in org.apache.cassandra.tracing with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
protected abstract TraceState	Tracing.newTraceState(InetAddressAndPort coordinator, TimeUUID sessionId, Tracing.TraceType traceType)
void	Tracing.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

Modifier	Constructor	Description
protected	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
InetAddressAndPort	Event.NodeEvent.nodeAddressAndPort()

Methods in org.apache.cassandra.transport with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
static Event.TopologyChange	Event.TopologyChange.movedNode(InetAddressAndPort address)
static Event.TopologyChange	Event.TopologyChange.newNode(InetAddressAndPort address)
static Event.StatusChange	Event.StatusChange.nodeDown(InetAddressAndPort address)
static Event.StatusChange	Event.StatusChange.nodeUp(InetAddressAndPort address)
void	Server.EventNotifier.onDown(InetAddressAndPort endpoint)
void	Server.EventNotifier.onJoinCluster(InetAddressAndPort endpoint)
void	Server.EventNotifier.onLeaveCluster(InetAddressAndPort endpoint)
void	Server.EventNotifier.onMove(InetAddressAndPort endpoint)
void	Server.EventNotifier.onUp(InetAddressAndPort endpoint)
static Event.TopologyChange	Event.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 InetAddressAndPort	FBUtilities.getBroadcastAddressAndPort()	Get the broadcast address and port for intra-cluster storage traffic.
static InetAddressAndPort	FBUtilities.getBroadcastNativeAddressAndPort()	This returns the address that is bound to for the native protocol for communicating with clients.
static InetAddressAndPort	FBUtilities.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 Collection<InetAddressAndPort>	TimeUUID.Generator.getAllLocalAddresses()	Helper function used exclusively by UUIDGen to create

Methods in org.apache.cassandra.utils with parameters of type InetAddressAndPort

Modifier and Type	Method	Description
static void	FBUtilities.setBroadcastInetAddressAndPort(InetAddressAndPort addr)	THIS IS FOR TESTING ONLY!!
static void	DiagnosticSnapshotService.snapshot(SnapshotCommand command, List<Range<Token>> ranges, InetAddressAndPort initiator)

Method parameters in org.apache.cassandra.utils with type arguments of type InetAddressAndPort

Modifier and Type	Method	Description
static void	DiagnosticSnapshotService.duplicateRows(TableMetadata metadata, Iterable<InetAddressAndPort> replicas)
static void	DiagnosticSnapshotService.repairedDataMismatch(TableMetadata metadata, Iterable<InetAddressAndPort> replicas)
static void	DiagnosticSnapshotService.repairedDataMismatch(TableMetadata metadata, Iterable<InetAddressAndPort> replicas, List<Range<Token>> ranges)