Uses of Interface
io.gravitee.gateway.api.buffer.Buffer

Packages that use Buffer

Package	Description
io.gravitee.gateway.api
io.gravitee.gateway.api.buffer
io.gravitee.gateway.api.http.stream
io.gravitee.gateway.api.http2
io.gravitee.gateway.api.stream
io.gravitee.gateway.api.ws
io.gravitee.gateway.reactive.api.context.http
io.gravitee.gateway.reactive.api.context.tcp
io.gravitee.gateway.reactive.api.message
io.gravitee.gateway.reactive.api.message.kafka
io.gravitee.gateway.reactive.api.ws

Uses of Buffer in io.gravitee.gateway.api

Methods in io.gravitee.gateway.api that return types with arguments of type Buffer

Modifier and Type	Method	Description
ReadStream<Buffer>	RequestWrapper.bodyHandler(Handler<Buffer> bodyHandler)
ReadStream<Buffer>	RequestWrapper.endHandler(Handler<Void> endHandler)
ReadStream<Buffer>	RequestWrapper.pause()
ReadStream<Buffer>	RequestWrapper.resume()

Method parameters in io.gravitee.gateway.api with type arguments of type Buffer

Modifier and Type	Method	Description
ReadStream<Buffer>	RequestWrapper.bodyHandler(Handler<Buffer> bodyHandler)
void	Invoker.invoke(ExecutionContext context, ReadStream<Buffer> stream, Handler<ProxyConnection> connectionHandler)

Uses of Buffer in io.gravitee.gateway.api.buffer

Methods in io.gravitee.gateway.api.buffer that return Buffer

Modifier and Type	Method	Description
@NonNull Buffer	Buffer.appendBuffer(Buffer buff)	Appends the specified Buffer to the current one.
Buffer	Buffer.appendBuffer(Buffer buff, int length)	Appends the first length bytes of the specified Buffer to the current one.
Buffer	Buffer.appendString(String str)	Appends the specified String to the current one.
Buffer	Buffer.appendString(String str, String charset)	Appends the specified String with the given charset to the current one.
static Buffer	Buffer.buffer()	Creates an empty buffer.
static Buffer	Buffer.buffer(byte[] bytes)	Creates a buffer from the specified byte array.
static Buffer	Buffer.buffer(int initialSizeHint)	Creates an empty buffer with reserved space.
static Buffer	Buffer.buffer(io.netty.buffer.ByteBuf nativeBuffer)	Creates a buffer from a netty ByteBuf.
static Buffer	Buffer.buffer(io.vertx.core.buffer.Buffer vertxBuffer)	Creates a buffer from a vertx Buffer.
static Buffer	Buffer.buffer(io.vertx.rxjava3.core.buffer.Buffer vertxBuffer)	Creates a buffer from a vertx Buffer.
static Buffer	Buffer.buffer(String string)	Creates a buffer from the specified String.
static Buffer	Buffer.buffer(String string, String charset)	Same as buffer(String) but with the given charset.
Buffer	BufferFactory.buffer()
Buffer	BufferFactory.buffer(byte[] bytes)
Buffer	BufferFactory.buffer(int initialSizeHint)
Buffer	BufferFactory.buffer(io.netty.buffer.ByteBuf nativeBuffer)
Buffer	BufferFactory.buffer(io.vertx.core.buffer.Buffer vertxBuffer)
Buffer	BufferFactory.buffer(io.vertx.rxjava3.core.buffer.Buffer vertxBuffer)
Buffer	BufferFactory.buffer(String str)
Buffer	BufferFactory.buffer(String str, String enc)

Methods in io.gravitee.gateway.api.buffer with parameters of type Buffer

Modifier and Type	Method	Description
@NonNull Buffer	Buffer.appendBuffer(Buffer buff)	Appends the specified Buffer to the current one.
Buffer	Buffer.appendBuffer(Buffer buff, int length)	Appends the first length bytes of the specified Buffer to the current one.

Uses of Buffer in io.gravitee.gateway.api.http.stream

Fields in io.gravitee.gateway.api.http.stream with type parameters of type Buffer

Modifier and Type	Field	Description
protected Function<Buffer,Buffer>	TransformableStreamBuilder.transform
protected Function<Buffer,Buffer>	TransformableStreamBuilder.transform

Method parameters in io.gravitee.gateway.api.http.stream with type arguments of type Buffer

Modifier and Type	Method	Description
TransformableStreamBuilder	TransformableStreamBuilder.transform(Function<Buffer,Buffer> function)
TransformableStreamBuilder	TransformableStreamBuilder.transform(Function<Buffer,Buffer> function)

Uses of Buffer in io.gravitee.gateway.api.http2

Methods in io.gravitee.gateway.api.http2 that return Buffer

Modifier and Type	Method	Description
Buffer	HttpFrame.payload()

Methods in io.gravitee.gateway.api.http2 with parameters of type Buffer

Modifier and Type	Method	Description
static HttpFrame	HttpFrame.create(int type, int flags, Buffer payload)

Uses of Buffer in io.gravitee.gateway.api.stream

Fields in io.gravitee.gateway.api.stream declared as Buffer

Modifier and Type	Field	Description
protected final Buffer	TransformableStream.buffer

Fields in io.gravitee.gateway.api.stream with type parameters of type Buffer

Modifier and Type	Field	Description
protected Function<Buffer,Buffer>	TransformableStream.transform
protected Function<Buffer,Buffer>	TransformableStream.transform

Methods in io.gravitee.gateway.api.stream that return types with arguments of type Buffer

Modifier and Type	Method	Description
Function<Buffer,Buffer>	TransformableStream.transform()
Function<Buffer,Buffer>	TransformableStream.transform()

Methods in io.gravitee.gateway.api.stream with parameters of type Buffer

Modifier and Type	Method	Description
protected TransformableStream	TransformableStream.flush(Buffer chunk)
TransformableStream	TransformableStream.write(Buffer chunk)

Uses of Buffer in io.gravitee.gateway.api.ws

Methods in io.gravitee.gateway.api.ws that return Buffer

Modifier and Type	Method	Description
Buffer	WebSocketFrame.data()	This one is only valid in case of a TEXT or BINARY frame type.

Uses of Buffer in io.gravitee.gateway.reactive.api.context.http

Methods in io.gravitee.gateway.reactive.api.context.http that return types with arguments of type Buffer

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Maybe<Buffer>	HttpPlainRequest.body()	Get the current body request as a Maybe.
io.reactivex.rxjava3.core.Maybe<Buffer>	HttpPlainResponse.body()	Get the current body response as a Maybe.
io.reactivex.rxjava3.core.Single<Buffer>	HttpPlainRequest.bodyOrEmpty()	Same as HttpPlainRequest.body() but returns a Single of Buffer instead.
io.reactivex.rxjava3.core.Single<Buffer>	HttpPlainResponse.bodyOrEmpty()	Same as HttpPlainResponse.body() but returns a Single of Buffer instead.
io.reactivex.rxjava3.core.Flowable<Buffer>	HttpPlainRequest.chunks()	Get the current request body chunks as Flowable of Buffer.
io.reactivex.rxjava3.core.Flowable<Buffer>	HttpPlainResponse.chunks()	Get the current response body chunks as Flowable of Buffer.
io.reactivex.rxjava3.core.Maybe<Buffer>	HttpPlainExecutionContext.interruptBody()	Interrupts the current execution while indicating that the response can be sent "as is" to the downstream.
io.reactivex.rxjava3.core.Maybe<Buffer>	HttpPlainExecutionContext.interruptBodyWith(ExecutionFailure failure)	Same as HttpPlainExecutionContext.interruptBody() but with an ExecutionFailure object that indicates that the execution has failed.

Methods in io.gravitee.gateway.reactive.api.context.http with parameters of type Buffer

Modifier and Type	Method	Description
void	HttpPlainRequest.body(Buffer buffer)	Set the current body request as a Buffer.
void	HttpPlainResponse.body(Buffer buffer)	Set the current body response as a Buffer.

Method parameters in io.gravitee.gateway.reactive.api.context.http with type arguments of type Buffer

Modifier and Type	Method	Description
void	HttpPlainRequest.chunks(io.reactivex.rxjava3.core.Flowable<Buffer> chunks)	Set the current request body chunks from a Flowable of Buffer.
void	HttpPlainResponse.chunks(io.reactivex.rxjava3.core.Flowable<Buffer> chunks)	Set the current response body chunks from a Flowable of Buffer.
io.reactivex.rxjava3.core.Completable	HttpPlainRequest.onBody(io.reactivex.rxjava3.core.MaybeTransformer<Buffer,Buffer> onBody)	Applies a transformation on the complete body given as a single Buffer.
io.reactivex.rxjava3.core.Completable	HttpPlainRequest.onBody(io.reactivex.rxjava3.core.MaybeTransformer<Buffer,Buffer> onBody)	Applies a transformation on the complete body given as a single Buffer.
io.reactivex.rxjava3.core.Completable	HttpPlainResponse.onBody(io.reactivex.rxjava3.core.MaybeTransformer<Buffer,Buffer> onBody)	Applies a transformation on the complete body given as a single Buffer.
io.reactivex.rxjava3.core.Completable	HttpPlainResponse.onBody(io.reactivex.rxjava3.core.MaybeTransformer<Buffer,Buffer> onBody)	Applies a transformation on the complete body given as a single Buffer.
io.reactivex.rxjava3.core.Completable	HttpPlainRequest.onChunks(io.reactivex.rxjava3.core.FlowableTransformer<Buffer,Buffer> onChunks)	Applies a transformation on each body chunks and completes when all the chunks have been processed.
io.reactivex.rxjava3.core.Completable	HttpPlainRequest.onChunks(io.reactivex.rxjava3.core.FlowableTransformer<Buffer,Buffer> onChunks)	Applies a transformation on each body chunks and completes when all the chunks have been processed.
io.reactivex.rxjava3.core.Completable	HttpPlainResponse.onChunks(io.reactivex.rxjava3.core.FlowableTransformer<Buffer,Buffer> onChunks)	Applies a transformation on each body chunks and completes when all the chunks have been processed.
io.reactivex.rxjava3.core.Completable	HttpPlainResponse.onChunks(io.reactivex.rxjava3.core.FlowableTransformer<Buffer,Buffer> onChunks)	Applies a transformation on each body chunks and completes when all the chunks have been processed.

Uses of Buffer in io.gravitee.gateway.reactive.api.context.tcp

Methods in io.gravitee.gateway.reactive.api.context.tcp that return types with arguments of type Buffer

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<Buffer>	TcpRequest.chunks()	Get the current request body chunks as Flowable of Buffer.
io.reactivex.rxjava3.core.Flowable<Buffer>	TcpResponse.chunks()	Get the current response body chunks as Flowable of Buffer.

Method parameters in io.gravitee.gateway.reactive.api.context.tcp with type arguments of type Buffer

Modifier and Type	Method	Description
void	TcpRequest.chunks(io.reactivex.rxjava3.core.Flowable<Buffer> chunks)	Set the current request body chunks from a Flowable of Buffer.
void	TcpResponse.chunks(io.reactivex.rxjava3.core.Flowable<Buffer> chunks)	Set the current response body chunks from a Flowable of Buffer.

Uses of Buffer in io.gravitee.gateway.reactive.api.message

Methods in io.gravitee.gateway.reactive.api.message that return Buffer

Modifier and Type	Method	Description
@Nullable Buffer	Message.content()	The current content of the message.

Methods in io.gravitee.gateway.reactive.api.message with parameters of type Buffer

Modifier and Type	Method	Description
DefaultMessage	DefaultMessage.content(Buffer content)
DefaultMessage.DefaultMessageBuilder	DefaultMessage.DefaultMessageBuilder.content(Buffer content)
Message	Message.content(Buffer content)	Set the content of the message.

Uses of Buffer in io.gravitee.gateway.reactive.api.message.kafka

Methods in io.gravitee.gateway.reactive.api.message.kafka that return Buffer

Modifier and Type	Method	Description
Buffer	KafkaMessage.key()	Get the Kafka record key associated to the message.

Methods in io.gravitee.gateway.reactive.api.message.kafka that return types with arguments of type Buffer

Modifier and Type	Method	Description
Map<String,Buffer>	KafkaMessage.recordHeaders()	FIXME: Refactor/remove this method when Message.headers() are http agnostic Get the Kafka record headers associated to the message.

Methods in io.gravitee.gateway.reactive.api.message.kafka with parameters of type Buffer

Modifier and Type	Method	Description
KafkaMessage	KafkaMessage.key(Buffer key)	Set the Kafka record key associated with the message.
KafkaMessage	KafkaMessage.putRecordHeader(String key, Buffer value)	FIXME: Refactor/remove this method when Message.headers(HttpHeaders) are http agnostic Put a Kafka record header to the message.

Uses of Buffer in io.gravitee.gateway.reactive.api.ws

Methods in io.gravitee.gateway.reactive.api.ws that return types with arguments of type Buffer

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Flowable<Buffer>	WebSocket.read()	Returns the websocket incoming Flowable of Buffer.

Methods in io.gravitee.gateway.reactive.api.ws with parameters of type Buffer

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Completable	WebSocket.write(Buffer buffer)	Writes the buffer to the websocket as a binary frame.