| Package | Description |
|---|---|
| org.apache.reef.io.network.impl |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.io.network.naming |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.io.network.naming.serialization |
Contains naming serialization codecs
|
| org.apache.reef.io.network.util |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.wake.impl | |
| org.apache.reef.wake.remote | |
| org.apache.reef.wake.remote.impl |
| Modifier and Type | Method and Description |
|---|---|
IdentifierFactory |
NetworkService.getIdentifierFactory() |
| Constructor and Description |
|---|
BindNSToTask(NetworkService<?> ns,
IdentifierFactory idFac) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NSMessageCodec(Codec<T> codec,
IdentifierFactory factory)
Constructs a network service message codec
|
UnbindNSFromTask(NetworkService<?> ns,
IdentifierFactory idFac) |
| Modifier and Type | Field and Description |
|---|---|
static OptionalParameter<IdentifierFactory> |
NameServerConfiguration.NAME_SERVER_IDENTIFIER_FACTORY
Identifier factory for the name service
|
| Constructor and Description |
|---|
NameClient(String serverAddr,
int serverPort,
IdentifierFactory factory,
int retryCount,
int retryTimeout,
Cache<Identifier,InetSocketAddress> cache)
Constructs a naming client
|
NameClient(String serverAddr,
int serverPort,
long timeout,
IdentifierFactory factory,
int retryCount,
int retryTimeout,
Cache<Identifier,InetSocketAddress> cache)
Constructs a naming client
|
NameLookupClient(String serverAddr,
int serverPort,
IdentifierFactory factory,
int retryCount,
int retryTimeout,
Cache<Identifier,InetSocketAddress> cache)
Constructs a naming lookup client
|
NameLookupClient(String serverAddr,
int serverPort,
long timeout,
IdentifierFactory factory,
int retryCount,
int retryTimeout,
Cache<Identifier,InetSocketAddress> cache)
Constructs a naming lookup client
|
NameRegistryClient(String serverAddr,
int serverPort,
IdentifierFactory factory)
Constructs a naming registry client
|
NameRegistryClient(String serverAddr,
int serverPort,
long timeout,
IdentifierFactory factory)
Constructs a naming registry client
|
NameRegistryClient(String serverAddr,
int serverPort,
long timeout,
IdentifierFactory factory,
BlockingQueue<NamingRegisterResponse> replyQueue,
Transport transport) |
NameServerImpl(int port,
IdentifierFactory factory)
Deprecated.
inject the NameServer instead of new it up
Constructs a name server
|
NameServerImpl(int port,
IdentifierFactory factory,
ReefEventStateManager reefEventStateManager)
Constructs a name server
|
| Constructor and Description |
|---|
NamingLookupRequestCodec(IdentifierFactory factory)
Constructs a naming lookup request codec
|
NamingLookupResponseCodec(IdentifierFactory factory)
Constructs a naming lookup response codec
|
NamingRegisterRequestCodec(IdentifierFactory factory)
Constructs a naming registration request codec
|
NamingUnregisterRequestCodec(IdentifierFactory factory)
Constructs a naming un-registration request codec
|
| Modifier and Type | Class and Description |
|---|---|
class |
StringIdentifierFactory
Factory that creates StringIdentifier
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultIdentifierFactory
Default remote identifier factory that creates a specific remote identifier
from a string representation
A string representation is broken into two parts type and type-specific details separated by "://"
A remote identifier implementation should implement a constructor that accepts a string.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
RemoteIdentifierFactory
Factory that creates a RemoteIdentifier
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultRemoteIdentifierFactoryImplementation |
Copyright © 2015 The Apache Software Foundation. All rights reserved.