Uses of Class
org.apache.cassandra.net.OutboundConnectionSettings
Packages that use OutboundConnectionSettings
Package
Description
Non-blocking streaming with netty
-
Uses of OutboundConnectionSettings in org.apache.cassandra.net
Methods in org.apache.cassandra.net that return OutboundConnectionSettingsModifier and TypeMethodDescriptionOutboundConnectionSettings.toEndpoint(InetAddressAndPort endpoint) 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) 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 in org.apache.cassandra.net with parameters of type OutboundConnectionSettingsModifier and TypeMethodDescriptionstatic io.netty.util.concurrent.Future<OutboundConnectionInitiator.Result<OutboundConnectionInitiator.Result.StreamingSuccess>>OutboundConnectionInitiator.initiateStreaming(io.netty.channel.EventLoop eventLoop, OutboundConnectionSettings settings, OutboundConnectionInitiator.SslFallbackConnectionType sslConnectionType) Initiate a connection with the requested messaging version. -
Uses of OutboundConnectionSettings in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming with parameters of type OutboundConnectionSettingsModifier and TypeMethodDescriptionio.netty.channel.ChannelStreamConnectionFactory.createConnection(OutboundConnectionSettings template, int messagingVersion) -
Uses of OutboundConnectionSettings in org.apache.cassandra.streaming.async
Methods in org.apache.cassandra.streaming.async with parameters of type OutboundConnectionSettingsModifier and TypeMethodDescriptionstatic NettyStreamingChannelNettyStreamingConnectionFactory.connect(OutboundConnectionSettings template, int messagingVersion, StreamingChannel.Kind kind)