Package io.bytestreams.exchange.core

Class ServerChannel.Builder<REQ,RESP>

java.lang.Object

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

Enclosing class:

ServerChannel<REQ,RESP>

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

Builder for ServerChannel.

Method Summary

Modifier and Type	Method	Description
ServerChannel<REQ,RESP>	build()
ServerChannel.Builder<REQ,RESP>	defaultTimeout(Duration defaultTimeout)
ServerChannel.Builder<REQ,RESP>	errorBackoff(Duration errorBackoff)
ServerChannel.Builder<REQ,RESP>	errorHandler(ErrorHandler<REQ,RESP> errorHandler)
ServerChannel.Builder<REQ,RESP>	meter(io.opentelemetry.api.metrics.Meter meter)
ServerChannel.Builder<REQ,RESP>	requestHandler(RequestHandler<REQ,RESP> requestHandler)
ServerChannel.Builder<REQ,RESP>	requestReader(MessageReader<REQ> requestReader)
ServerChannel.Builder<REQ,RESP>	responseWriter(MessageWriter<RESP> responseWriter)
ServerChannel.Builder<REQ,RESP>	tracer(io.opentelemetry.api.trace.Tracer tracer)
ServerChannel.Builder<REQ,RESP>	transport(Transport transport)
ServerChannel.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 ServerChannel.Builder<REQ,RESP> transport(Transport transport)

writeBufferSize

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

requestReader

public ServerChannel.Builder<REQ,RESP> requestReader(MessageReader<REQ> requestReader)

responseWriter

public ServerChannel.Builder<REQ,RESP> responseWriter(MessageWriter<RESP> responseWriter)

requestHandler

public ServerChannel.Builder<REQ,RESP> requestHandler(RequestHandler<REQ,RESP> requestHandler)

errorHandler

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

defaultTimeout

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

errorBackoff

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

meter

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

tracer

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

build

public ServerChannel<REQ,RESP> build()