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 interface	StreamingChannel.Factory
static enum	StreamingChannel.Kind
static interface	StreamingChannel.Send

Method Summary

Modifier and Type	Method	Description
StreamingDataOutputPlus	acquireOut()	until closed, cannot invoke send(Send)
io.netty.util.concurrent.Future<?>	close()
boolean	connected()
InetSocketAddress	connectedTo()
String	description()
Object	id()
StreamingDataInputPlus	in()
void	onClose(Runnable runOnClose)
InetSocketAddress	peer()
io.netty.util.concurrent.Future<?>	send(StreamingChannel.Send send)

Method Details

id

Object id()

description

String description()

peer

InetSocketAddress peer()

connectedTo

InetSocketAddress connectedTo()

connected

boolean connected()

in

StreamingDataInputPlus in()

acquireOut

StreamingDataOutputPlus acquireOut()

until closed, cannot invoke send(Send)

send

io.netty.util.concurrent.Future<?> send(StreamingChannel.Send send)
                                 throws IOException

Throws:

IOException

close

io.netty.util.concurrent.Future<?> close()

onClose

void onClose(Runnable runOnClose)