Package org.infinispan.server.hotrod.streaming

Class StreamingManager

java.lang.Object

org.infinispan.server.hotrod.streaming.StreamingManager

public class StreamingManager
extends Object

Constructor Summary

Constructors

Constructor	Description
StreamingManager(TimeService timeService)

Method Summary

Modifier and Type	Method	Description
void	closeGetStream(Integer iterationId)
void	closePutStream(Integer streamId)
GetStreamResponse	nextGetStream(Integer streamId)
StreamingState	nextPutStream(Integer streamId, boolean lastChunk, io.netty.buffer.ByteBuf buf)
GetStreamResponse	startGetStream(byte[] key, byte[] value, io.netty.channel.Channel channel, int batchSize)
int	startPutStream(byte[] key, io.netty.channel.Channel channel, Metadata.Builder metadata, long version)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingManager

public StreamingManager(TimeService timeService)

Method Details

startGetStream

public GetStreamResponse startGetStream(byte[] key,
 byte[] value,
 io.netty.channel.Channel channel,
 int batchSize)

nextGetStream

public GetStreamResponse nextGetStream(Integer streamId)

closeGetStream

public void closeGetStream(Integer iterationId)

startPutStream

public int startPutStream(byte[] key,
 io.netty.channel.Channel channel,
 Metadata.Builder metadata,
 long version)

nextPutStream

public StreamingState nextPutStream(Integer streamId,
 boolean lastChunk,
 io.netty.buffer.ByteBuf buf)

closePutStream

public void closePutStream(Integer streamId)