Package org.apache.cassandra.net

Class InboundConnectionSettings

java.lang.Object

org.apache.cassandra.net.InboundConnectionSettings

public class InboundConnectionSettings
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
org.apache.cassandra.net.AcceptVersions	acceptMessaging
org.apache.cassandra.net.AcceptVersions	acceptStreaming
java.lang.Integer	applicationReceiveQueueCapacityInBytes
IInternodeAuthenticator	authenticator
InetAddressAndPort	bindAddress
EncryptionOptions.ServerEncryptionOptions	encryption
java.util.function.Function<InetAddressAndPort,InboundMessageHandlers>	handlers
SocketFactory	socketFactory
java.lang.Integer	socketReceiveBufferSizeInBytes

Constructor Summary

Constructors

Constructor	Description
InboundConnectionSettings()

Method Summary

Modifier and Type	Method	Description
boolean	authenticate(java.net.InetAddress address, int port)
boolean	authenticate(InetAddressAndPort endpoint)
java.lang.String	toString()
InboundConnectionSettings	withAcceptMessaging(org.apache.cassandra.net.AcceptVersions acceptMessaging)
InboundConnectionSettings	withAcceptStreaming(org.apache.cassandra.net.AcceptVersions acceptMessaging)
InboundConnectionSettings	withApplicationReceiveQueueCapacityInBytes(int applicationReceiveQueueCapacityInBytes)
InboundConnectionSettings	withAuthenticator(IInternodeAuthenticator authenticator)
InboundConnectionSettings	withBindAddress(InetAddressAndPort bindAddress)
InboundConnectionSettings	withDefaults()
InboundConnectionSettings	withEncryption(EncryptionOptions.ServerEncryptionOptions encryption)
InboundConnectionSettings	withHandlers(java.util.function.Function<InetAddressAndPort,InboundMessageHandlers> handlers)
InboundConnectionSettings	withLegacySslStoragePortDefaults()
InboundConnectionSettings	withSocketFactory(SocketFactory socketFactory)
InboundConnectionSettings	withSocketReceiveBufferSizeInBytes(int socketReceiveBufferSizeInBytes)

Methods inherited from class java.lang.Object

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

Field Detail

authenticator

public final IInternodeAuthenticator authenticator

bindAddress

public final InetAddressAndPort bindAddress

encryption

public final EncryptionOptions.ServerEncryptionOptions encryption

socketReceiveBufferSizeInBytes

public final java.lang.Integer socketReceiveBufferSizeInBytes

applicationReceiveQueueCapacityInBytes

public final java.lang.Integer applicationReceiveQueueCapacityInBytes

acceptMessaging

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

acceptStreaming

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

socketFactory

public final SocketFactory socketFactory

handlers

public final java.util.function.Function<InetAddressAndPort,InboundMessageHandlers> handlers

Constructor Detail

InboundConnectionSettings

public InboundConnectionSettings()

Method Detail

authenticate

public boolean authenticate(InetAddressAndPort endpoint)

authenticate

public boolean authenticate(java.net.InetAddress address,
                            int port)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

withAuthenticator

public InboundConnectionSettings withAuthenticator(IInternodeAuthenticator authenticator)

withBindAddress

public InboundConnectionSettings withBindAddress(InetAddressAndPort bindAddress)

withEncryption

public InboundConnectionSettings withEncryption(EncryptionOptions.ServerEncryptionOptions encryption)

withSocketReceiveBufferSizeInBytes

public InboundConnectionSettings withSocketReceiveBufferSizeInBytes(int socketReceiveBufferSizeInBytes)

withApplicationReceiveQueueCapacityInBytes

public InboundConnectionSettings withApplicationReceiveQueueCapacityInBytes(int applicationReceiveQueueCapacityInBytes)

withAcceptMessaging

public InboundConnectionSettings withAcceptMessaging(org.apache.cassandra.net.AcceptVersions acceptMessaging)

withAcceptStreaming

public InboundConnectionSettings withAcceptStreaming(org.apache.cassandra.net.AcceptVersions acceptMessaging)

withSocketFactory

public InboundConnectionSettings withSocketFactory(SocketFactory socketFactory)

withHandlers

public InboundConnectionSettings withHandlers(java.util.function.Function<InetAddressAndPort,InboundMessageHandlers> handlers)

withLegacySslStoragePortDefaults

public InboundConnectionSettings withLegacySslStoragePortDefaults()

withDefaults

public InboundConnectionSettings withDefaults()