Package org.apache.cassandra.streaming
Interface StreamingChannel
-
- All Known Implementing Classes:
NettyStreamingChannel
public interface StreamingChannel
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceStreamingChannel.Factorystatic classStreamingChannel.Kindstatic interfaceStreamingChannel.Send
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamingDataOutputPlusacquireOut()until closed, cannot invokesend(Send)io.netty.util.concurrent.Future<?>close()booleanconnected()java.net.InetSocketAddressconnectedTo()java.lang.Stringdescription()java.lang.Objectid()StreamingDataInputPlusin()voidonClose(java.lang.Runnable runOnClose)java.net.InetSocketAddresspeer()io.netty.util.concurrent.Future<?>send(StreamingChannel.Send send)
-
-
-
Method Detail
-
id
java.lang.Object id()
-
description
java.lang.String description()
-
peer
java.net.InetSocketAddress peer()
-
connectedTo
java.net.InetSocketAddress connectedTo()
-
connected
boolean connected()
-
in
StreamingDataInputPlus in()
-
acquireOut
StreamingDataOutputPlus acquireOut()
until closed, cannot invokesend(Send)
-
send
io.netty.util.concurrent.Future<?> send(StreamingChannel.Send send) throws java.io.IOException
- Throws:
java.io.IOException
-
close
io.netty.util.concurrent.Future<?> close()
-
onClose
void onClose(java.lang.Runnable runOnClose)
-
-