Package | Description |
---|---|
org.corfudb.runtime | |
org.corfudb.runtime.clients |
Modifier and Type | Field and Description |
---|---|
static BiFunction<CorfuRuntime,String,IClientRouter> |
CorfuRuntime.overrideGetRouterFunction
When set, overrides the default getRouterFunction.
|
Modifier and Type | Method and Description |
---|---|
IClientRouter |
NodeRouterPool.getRouter(NodeLocator endpoint)
Fetches a router from the pool if already present.
|
IClientRouter |
CorfuRuntime.getRouter(String address)
Get a router, given the address.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyClientRouter
A client router which multiplexes operations over the Netty transport.
|
Modifier and Type | Field and Description |
---|---|
IClientRouter |
BaseHandler.router
The router to use for the client.
|
Modifier and Type | Method and Description |
---|---|
IClientRouter |
NettyClientRouter.addClient(IClient client)
Add a new client to the router.
|
IClientRouter |
IClientRouter.addClient(IClient client)
Add a new client to the router.
|
IClientRouter |
IClient.getRouter()
Get the router used by the Netty client.
|
Modifier and Type | Method and Description |
---|---|
Object |
ClientMsgHandler.Handler.handle(T corfuMsg,
io.netty.channel.ChannelHandlerContext ctx,
IClientRouter r) |
void |
IClient.setRouter(IClientRouter router)
Set the router used by the Netty client.
|
Constructor and Description |
---|
BaseClient(IClientRouter router,
long epoch) |
LayoutClient(IClientRouter router,
long epoch) |
LogUnitClient(IClientRouter router,
long epoch) |
ManagementClient(IClientRouter router,
long epoch) |
SequencerClient(IClientRouter router,
long epoch) |
Copyright © 2019 CorfuDB. All rights reserved.