CombineOutbounds takes multiple outbound builders and combines them.

ContextWithResponseInfo will create a child context that has ResponseInfo set as value.

ListenIP returns the IP to bind to in Listen.

NewFactory builds a new rpc.Factory.

NewMockFactory creates a new mock instance.

NewMockOutboundsBuilder creates a new mock instance.

NewMockPeerChooser creates a new mock instance.

NewMockPeerChooserFactory creates a new mock instance.

NewMockPeerLister creates a new mock instance.

NewParams creates parameters for rpc.Factory from the given config.

ComparatorYarpcKey is the const for yarpc key.

OutboundPublicClient is the name of configured public client outbound.

ClientPartitionConfigMiddleware stores the partition config and isolation group of the request into the context It reads a header from client request and uses it as the isolation group.

Factory is an implementation of rpc.Factory interface.

ForwardPartitionConfigMiddleware forwards the partition config to remote cluster The middleware should always be applied after any other middleware that inject partition config into the context so that it can overwrites the partition config into the context The purpose of this middleware is to make sure the partition config doesn't change when a request is forwarded from passive cluster to the active cluster.

HeaderForwardingMiddleware forwards headers from current inbound RPC call that is being handled to new outbound calls being made.

InboundMetricsMiddleware tags context with additional metric tags from incoming request.

MockFactory is a mock of Factory interface.

MockFactoryMockRecorder is the mock recorder for MockFactory.

MockOutboundsBuilder is a mock of OutboundsBuilder interface.

MockOutboundsBuilderMockRecorder is the mock recorder for MockOutboundsBuilder.

MockPeerChooser is a mock of PeerChooser interface.

MockPeerChooserFactory is a mock of PeerChooserFactory interface.

MockPeerChooserFactoryMockRecorder is the mock recorder for MockPeerChooserFactory.

MockPeerChooserMockRecorder is the mock recorder for MockPeerChooser.

MockPeerLister is a mock of PeerLister interface.

MockPeerListerMockRecorder is the mock recorder for MockPeerLister.

Params allows to configure rpc.Factory.

PinotComparatorMiddleware checks the header of a grpc request, and then override the context accordingly note: for Pinot Migration only (Jan.

ResponseInfo structure is filled with data after the RPC call.

ResponseInfoMiddleware populates context with ResponseInfo structure which contains info about response that was received.

Factory Creates a dispatcher that knows how to transport requests.

OutboundsBuilder allows defining outbounds for the dispatcher.