public class TcpDiscoveryElbIpFinder extends TcpDiscoveryIpFinderAdapter
For information about Amazon ELB visit aws.amazon.com.
setCredentialsProvider(AWSCredentialsProvider)
setLoadBalancerName(String)
)setRegion(String)
)The finder will fetch all nodes connected under an ELB and share with its peers for cluster awareness.
Note that using AWS ELB service will result in charges to your AWS account.
Choose another implementation of TcpDiscoveryIpFinder
for local or home network tests.
Note that this finder is shared.
ignite
Constructor and Description |
---|
TcpDiscoveryElbIpFinder()
Creates ELB IP finder instance.
|
Modifier and Type | Method and Description |
---|---|
Collection<InetSocketAddress> |
getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
setCredentialsProvider(com.amazonaws.auth.AWSCredentialsProvider credsProvider)
Sets AWS credentials provider.
|
void |
setLoadBalancerName(String loadBalancerName)
Sets AWS Elastic Load Balancing name which nodes are plugged under it.
|
void |
setRegion(String region)
Sets AWS Elastic Load Balancer's region.
|
void |
unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
close, discoveryClientMode, initializeLocalAddresses, isShared, onSpiContextDestroyed, onSpiContextInitialized, setShared, spiContext, toString
public TcpDiscoveryElbIpFinder()
public Collection<InetSocketAddress> getRegisteredAddresses() throws IgniteSpiException
null
.IgniteSpiException
- In case of error.@IgniteSpiConfiguration(optional=false) public void setLoadBalancerName(String loadBalancerName)
loadBalancerName
- AWS Elastic Load Balancing name.@IgniteSpiConfiguration(optional=false) public void setRegion(String region)
region
- AWS Elastic Load Balancer region (i.e: us-east-1)@IgniteSpiConfiguration(optional=false) public void setCredentialsProvider(com.amazonaws.auth.AWSCredentialsProvider credsProvider)
credsProvider
- AWS credentials provider.public void registerAddresses(Collection<InetSocketAddress> addrs) throws IgniteSpiException
Implementation should accept duplicates quietly, but should not register address if it is already registered.
addrs
- Addresses to register. Not null
and not empty.IgniteSpiException
- In case of error.public void unregisterAddresses(Collection<InetSocketAddress> addrs) throws IgniteSpiException
Implementation should accept addresses that are currently not registered quietly (just no-op).
addrs
- Addresses to unregister. Not null
and not empty.IgniteSpiException
- In case of error.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019