Package io.bytestreams.exchange.core

Class PipelinedChannel.Builder<REQ,RESP>

java.lang.Object

io.bytestreams.exchange.core.PipelinedChannel.Builder<REQ,RESP>

Enclosing class:

PipelinedChannel<REQ,RESP>

public static final class PipelinedChannel.Builder<REQ,RESP>
extends Object

Method Summary

Modifier and Type	Method	Description
PipelinedChannel<REQ,RESP>	build()
PipelinedChannel.Builder<REQ,RESP>	defaultTimeout(Duration defaultTimeout)
PipelinedChannel.Builder<REQ,RESP>	errorBackoff(Duration errorBackoff)
PipelinedChannel.Builder<REQ,RESP>	errorHandler(ErrorHandler<REQ,RESP> errorHandler)
PipelinedChannel.Builder<REQ,RESP>	maxConcurrency(int maxConcurrency)
PipelinedChannel.Builder<REQ,RESP>	meter(io.opentelemetry.api.metrics.Meter meter)
PipelinedChannel.Builder<REQ,RESP>	requestWriter(MessageWriter<REQ> requestWriter)
PipelinedChannel.Builder<REQ,RESP>	responseReader(MessageReader<RESP> responseReader)
PipelinedChannel.Builder<REQ,RESP>	tracer(io.opentelemetry.api.trace.Tracer tracer)
PipelinedChannel.Builder<REQ,RESP>	transport(Transport transport)
PipelinedChannel.Builder<REQ,RESP>	writeBufferSize(int writeBufferSize)

Methods inherited from class java.lang.Object

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

Method Details

transport

public PipelinedChannel.Builder<REQ,RESP> transport(Transport transport)

writeBufferSize

public PipelinedChannel.Builder<REQ,RESP> writeBufferSize(int writeBufferSize)

requestWriter

public PipelinedChannel.Builder<REQ,RESP> requestWriter(MessageWriter<REQ> requestWriter)

responseReader

public PipelinedChannel.Builder<REQ,RESP> responseReader(MessageReader<RESP> responseReader)

maxConcurrency

public PipelinedChannel.Builder<REQ,RESP> maxConcurrency(int maxConcurrency)

errorHandler

public PipelinedChannel.Builder<REQ,RESP> errorHandler(ErrorHandler<REQ,RESP> errorHandler)

defaultTimeout

public PipelinedChannel.Builder<REQ,RESP> defaultTimeout(Duration defaultTimeout)

errorBackoff

public PipelinedChannel.Builder<REQ,RESP> errorBackoff(Duration errorBackoff)

meter

public PipelinedChannel.Builder<REQ,RESP> meter(io.opentelemetry.api.metrics.Meter meter)

tracer

public PipelinedChannel.Builder<REQ,RESP> tracer(io.opentelemetry.api.trace.Tracer tracer)

build

public PipelinedChannel<REQ,RESP> build()