Package org.apache.cassandra.net

Class OutboundConnectionSettings

java.lang.Object

org.apache.cassandra.net.OutboundConnectionSettings

public class OutboundConnectionSettings
extends Object

A collection of settings to be passed around for outbound connections.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	OutboundConnectionSettings.Framing

Field Summary

Fields

Modifier and Type	Field	Description
final org.apache.cassandra.net.AcceptVersions	acceptVersions
final Integer	applicationSendQueueCapacityInBytes
final Integer	applicationSendQueueReserveEndpointCapacityInBytes
final ResourceLimits.Limit	applicationSendQueueReserveGlobalCapacityInBytes
final IInternodeAuthenticator	authenticator
final org.apache.cassandra.net.OutboundMessageCallbacks	callbacks
final InetAddressAndPort	connectTo
final org.apache.cassandra.net.OutboundDebugCallbacks	debug
final EncryptionOptions.ServerEncryptionOptions	encryption
final EndpointMessagingVersions	endpointToVersion
final int	flushHighWaterMark
final int	flushLowWaterMark
final OutboundConnectionSettings.Framing	framing
final InetAddressAndPort	from
final SocketFactory	socketFactory
final Integer	socketSendBufferSizeInBytes
final Integer	tcpConnectTimeoutInMS
final Boolean	tcpNoDelay
final Integer	tcpUserTimeoutInMS
final InetAddressAndPort	to

Constructor Summary

Constructors

Constructor	Description
OutboundConnectionSettings(InetAddressAndPort to)
OutboundConnectionSettings(InetAddressAndPort to, InetAddressAndPort preferred)

Method Summary

Modifier and Type	Method	Description
org.apache.cassandra.net.AcceptVersions	acceptVersions(ConnectionCategory category)
int	applicationSendQueueCapacityInBytes()
int	applicationSendQueueReserveEndpointCapacityInBytes()
ResourceLimits.Limit	applicationSendQueueReserveGlobalCapacityInBytes()
IInternodeAuthenticator	authenticator()
org.apache.cassandra.net.OutboundMessageCallbacks	callbacks()
InetAddressAndPort	connectTo()
String	connectToId()
org.apache.cassandra.net.OutboundDebugCallbacks	debug()
EncryptionOptions.ServerEncryptionOptions	encryption()
EndpointMessagingVersions	endpointToVersion()
OutboundConnectionSettings.Framing	framing(ConnectionCategory category)
InetAddressAndPort	from()
SocketFactory	socketFactory()
int	socketSendBufferSizeInBytes()
int	tcpConnectTimeoutInMS()
boolean	tcpNoDelay()
int	tcpUserTimeoutInMS(ConnectionCategory category)
OutboundConnectionSettings	toEndpoint(InetAddressAndPort endpoint)
String	toString()
OutboundConnectionSettings	withAcceptVersions(org.apache.cassandra.net.AcceptVersions acceptVersions)
OutboundConnectionSettings	withApplicationReserveSendQueueCapacityInBytes(Integer applicationReserveSendQueueEndpointCapacityInBytes, ResourceLimits.Limit applicationReserveSendQueueGlobalCapacityInBytes)
OutboundConnectionSettings	withApplicationSendQueueCapacityInBytes(int applicationSendQueueCapacityInBytes)
OutboundConnectionSettings	withAuthenticator(IInternodeAuthenticator authenticator)
OutboundConnectionSettings	withCallbacks(org.apache.cassandra.net.OutboundMessageCallbacks callbacks)
OutboundConnectionSettings	withConnectTo(InetAddressAndPort connectTo)
OutboundConnectionSettings	withDebugCallbacks(org.apache.cassandra.net.OutboundDebugCallbacks debug)
OutboundConnectionSettings	withDefaultReserveLimits()
OutboundConnectionSettings	withDefaults(ConnectionCategory category)
boolean	withEncryption()
OutboundConnectionSettings	withEncryption(EncryptionOptions.ServerEncryptionOptions encryption)
OutboundConnectionSettings	withFraming(OutboundConnectionSettings.Framing framing)
OutboundConnectionSettings	withFrom(InetAddressAndPort from)
OutboundConnectionSettings	withNettyBufferBounds(io.netty.channel.WriteBufferWaterMark nettyBufferBounds)
OutboundConnectionSettings	withSocketFactory(SocketFactory socketFactory)
OutboundConnectionSettings	withSocketSendBufferSizeInBytes(int socketSendBufferSizeInBytes)
OutboundConnectionSettings	withTcpConnectTimeoutInMS(int tcpConnectTimeoutInMS)
OutboundConnectionSettings	withTcpNoDelay(boolean tcpNoDelay)
OutboundConnectionSettings	withTcpUserTimeoutInMS(int tcpUserTimeoutInMS)

Methods inherited from class java.lang.Object

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

Field Details

authenticator

public final IInternodeAuthenticator authenticator

to

public final InetAddressAndPort to

connectTo

public final InetAddressAndPort connectTo

encryption

public final EncryptionOptions.ServerEncryptionOptions encryption

framing

public final OutboundConnectionSettings.Framing framing

socketSendBufferSizeInBytes

public final Integer socketSendBufferSizeInBytes

applicationSendQueueCapacityInBytes

public final Integer applicationSendQueueCapacityInBytes

applicationSendQueueReserveEndpointCapacityInBytes

public final Integer applicationSendQueueReserveEndpointCapacityInBytes

applicationSendQueueReserveGlobalCapacityInBytes

public final ResourceLimits.Limit applicationSendQueueReserveGlobalCapacityInBytes

tcpNoDelay

public final Boolean tcpNoDelay

flushLowWaterMark

public final int flushLowWaterMark

flushHighWaterMark

public final int flushHighWaterMark

tcpConnectTimeoutInMS

public final Integer tcpConnectTimeoutInMS

tcpUserTimeoutInMS

public final Integer tcpUserTimeoutInMS

acceptVersions

public final org.apache.cassandra.net.AcceptVersions acceptVersions

from

public final InetAddressAndPort from

socketFactory

public final SocketFactory socketFactory

callbacks

public final org.apache.cassandra.net.OutboundMessageCallbacks callbacks

debug

public final org.apache.cassandra.net.OutboundDebugCallbacks debug

endpointToVersion

public final EndpointMessagingVersions endpointToVersion

Constructor Details

OutboundConnectionSettings

public OutboundConnectionSettings(InetAddressAndPort to)

OutboundConnectionSettings

public OutboundConnectionSettings(InetAddressAndPort to,
 InetAddressAndPort preferred)

Method Details

withEncryption

public boolean withEncryption()

toString

public String toString()

Overrides:

toString in class Object

withAuthenticator

public OutboundConnectionSettings withAuthenticator(IInternodeAuthenticator authenticator)

toEndpoint

public OutboundConnectionSettings toEndpoint(InetAddressAndPort endpoint)

withConnectTo

public OutboundConnectionSettings withConnectTo(InetAddressAndPort connectTo)

withEncryption

public OutboundConnectionSettings withEncryption(EncryptionOptions.ServerEncryptionOptions encryption)

withFraming

public OutboundConnectionSettings withFraming(OutboundConnectionSettings.Framing framing)

withSocketSendBufferSizeInBytes

public OutboundConnectionSettings withSocketSendBufferSizeInBytes(int socketSendBufferSizeInBytes)

withApplicationSendQueueCapacityInBytes

public OutboundConnectionSettings withApplicationSendQueueCapacityInBytes(int applicationSendQueueCapacityInBytes)

withApplicationReserveSendQueueCapacityInBytes

public OutboundConnectionSettings withApplicationReserveSendQueueCapacityInBytes(Integer applicationReserveSendQueueEndpointCapacityInBytes,
 ResourceLimits.Limit applicationReserveSendQueueGlobalCapacityInBytes)

withTcpNoDelay

public OutboundConnectionSettings withTcpNoDelay(boolean tcpNoDelay)

withNettyBufferBounds

public OutboundConnectionSettings withNettyBufferBounds(io.netty.channel.WriteBufferWaterMark nettyBufferBounds)

withTcpConnectTimeoutInMS

public OutboundConnectionSettings withTcpConnectTimeoutInMS(int tcpConnectTimeoutInMS)

withTcpUserTimeoutInMS

public OutboundConnectionSettings withTcpUserTimeoutInMS(int tcpUserTimeoutInMS)

withAcceptVersions

public OutboundConnectionSettings withAcceptVersions(org.apache.cassandra.net.AcceptVersions acceptVersions)

withFrom

public OutboundConnectionSettings withFrom(InetAddressAndPort from)

withSocketFactory

public OutboundConnectionSettings withSocketFactory(SocketFactory socketFactory)

withCallbacks

public OutboundConnectionSettings withCallbacks(org.apache.cassandra.net.OutboundMessageCallbacks callbacks)

withDebugCallbacks

public OutboundConnectionSettings withDebugCallbacks(org.apache.cassandra.net.OutboundDebugCallbacks debug)

withDefaultReserveLimits

public OutboundConnectionSettings withDefaultReserveLimits()

authenticator

public IInternodeAuthenticator authenticator()

endpointToVersion

public EndpointMessagingVersions endpointToVersion()

from

public InetAddressAndPort from()

debug

public org.apache.cassandra.net.OutboundDebugCallbacks debug()

encryption

public EncryptionOptions.ServerEncryptionOptions encryption()

socketFactory

public SocketFactory socketFactory()

callbacks

public org.apache.cassandra.net.OutboundMessageCallbacks callbacks()

socketSendBufferSizeInBytes

public int socketSendBufferSizeInBytes()

applicationSendQueueCapacityInBytes

public int applicationSendQueueCapacityInBytes()

applicationSendQueueReserveGlobalCapacityInBytes

public ResourceLimits.Limit applicationSendQueueReserveGlobalCapacityInBytes()

applicationSendQueueReserveEndpointCapacityInBytes

public int applicationSendQueueReserveEndpointCapacityInBytes()

tcpConnectTimeoutInMS

public int tcpConnectTimeoutInMS()

tcpUserTimeoutInMS

public int tcpUserTimeoutInMS(ConnectionCategory category)

tcpNoDelay

public boolean tcpNoDelay()

acceptVersions

public org.apache.cassandra.net.AcceptVersions acceptVersions(ConnectionCategory category)

connectTo

public InetAddressAndPort connectTo()

connectToId

public String connectToId()

framing

public OutboundConnectionSettings.Framing framing(ConnectionCategory category)

withDefaults

public OutboundConnectionSettings withDefaults(ConnectionCategory category)