Package | Description |
---|---|
org.apache.cassandra.transport |
Modifier and Type | Method and Description |
---|---|
Envelope |
Envelope.clone() |
Envelope |
Compressor.compress(Envelope uncompressed) |
Envelope |
Compressor.SnappyCompressor.compress(Envelope uncompressed) |
Envelope |
Compressor.LZ4Compressor.compress(Envelope uncompressed) |
static Envelope |
Envelope.create(Message.Type type,
int streamId,
ProtocolVersion version,
java.util.EnumSet<Envelope.Header.Flag> flags,
io.netty.buffer.ByteBuf body) |
Envelope |
Compressor.decompress(Envelope compressed) |
Envelope |
Compressor.SnappyCompressor.decompress(Envelope compressed) |
Envelope |
Compressor.LZ4Compressor.decompress(Envelope compressed) |
Envelope |
Message.encode(ProtocolVersion version) |
Envelope |
Message.getSource() |
Envelope |
Envelope.with(io.netty.buffer.ByteBuf newBody) |
Modifier and Type | Method and Description |
---|---|
Envelope |
Compressor.compress(Envelope uncompressed) |
Envelope |
Compressor.SnappyCompressor.compress(Envelope uncompressed) |
Envelope |
Compressor.LZ4Compressor.compress(Envelope uncompressed) |
void |
PreV5Handlers.ProtocolDecoder.decode(io.netty.channel.ChannelHandlerContext ctx,
Envelope source,
java.util.List results) |
void |
Envelope.Decompressor.decode(io.netty.channel.ChannelHandlerContext ctx,
Envelope source,
java.util.List<java.lang.Object> results) |
Envelope |
Compressor.decompress(Envelope compressed) |
Envelope |
Compressor.SnappyCompressor.decompress(Envelope compressed) |
Envelope |
Compressor.LZ4Compressor.decompress(Envelope compressed) |
void |
Envelope.Encoder.encode(io.netty.channel.ChannelHandlerContext ctx,
Envelope source,
java.util.List<java.lang.Object> results) |
void |
Envelope.Compressor.encode(io.netty.channel.ChannelHandlerContext ctx,
Envelope source,
java.util.List<java.lang.Object> results) |
void |
SimpleClient.SimpleFlusher.enqueue(Envelope message) |
protected boolean |
CQLMessageHandler.processRequest(Envelope request) |
void |
Message.setSource(Envelope source) |
Copyright © 2009-2022 The Apache Software Foundation