org.apache.ignite.spi.discovery.tcp.ipfinder.s3

Class TcpDiscoveryS3IpFinder

java.lang.Object

org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinderAdapter

org.apache.ignite.spi.discovery.tcp.ipfinder.s3.TcpDiscoveryS3IpFinder

All Implemented Interfaces:

TcpDiscoveryIpFinder

public class TcpDiscoveryS3IpFinder
extends TcpDiscoveryIpFinderAdapter

AWS S3-based IP finder.

For information about Amazon S3 visit aws.amazon.com.

Configuration

Mandatory

• AWS credentials (see setAwsCredentials(AWSCredentials))
• Bucket name (see setBucketName(String))

Optional

• Client configuration (see setClientConfiguration(ClientConfiguration))
• Shared flag (see TcpDiscoveryIpFinderAdapter.setShared(boolean))

The finder will create S3 bucket with configured name. The bucket will contain entries named like the following: 192.168.1.136#1001.

Note that storing data in AWS S3 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 by default (see TcpDiscoveryIpFinder.isShared().

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELIM Delimiter to use in S3 entries name.

Constructor Summary

Constructors

Constructor and Description
TcpDiscoveryS3IpFinder() Constructor.

Method Summary

Methods

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	setAwsCredentials(com.amazonaws.auth.AWSCredentials cred) Sets AWS credentials.
void	setBucketName(String bucketName) Sets bucket name for IP finder.
void	setClientConfiguration(com.amazonaws.ClientConfiguration cfg) Sets Amazon client configuration.
String	toString()
void	unregisterAddresses(Collection<InetSocketAddress> addrs) Unregisters provided addresses.

Methods inherited from class org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinderAdapter

close, initializeLocalAddresses, isShared, onSpiContextDestroyed, onSpiContextInitialized, setShared, spiContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DELIM

public static final String DELIM

Delimiter to use in S3 entries name.

See Also:

Constant Field Values

Constructor Detail

TcpDiscoveryS3IpFinder

public TcpDiscoveryS3IpFinder()

Constructor.

Method Detail

getRegisteredAddresses

public Collection<InetSocketAddress> getRegisteredAddresses()
                                                     throws IgniteSpiException

Gets all addresses registered in this finder.

Returns:

All known addresses, potentially empty, but never null.

Throws:

IgniteSpiException - In case of error.

registerAddresses

public void registerAddresses(Collection<InetSocketAddress> addrs)
                       throws IgniteSpiException

Registers new addresses.

Implementation should accept duplicates quietly, but should not register address if it is already registered.

Parameters:

addrs - Addresses to register. Not null and not empty.

Throws:

IgniteSpiException - In case of error.

unregisterAddresses

public void unregisterAddresses(Collection<InetSocketAddress> addrs)
                         throws IgniteSpiException

Unregisters provided addresses.

Implementation should accept addresses that are currently not registered quietly (just no-op).

Parameters:

addrs - Addresses to unregister. Not null and not empty.

Throws:

IgniteSpiException - In case of error.

setBucketName

@IgniteSpiConfiguration(optional=false)
public void setBucketName(String bucketName)

Sets bucket name for IP finder.

Parameters:

bucketName - Bucket name.

setClientConfiguration

@IgniteSpiConfiguration(optional=true)
public void setClientConfiguration(com.amazonaws.ClientConfiguration cfg)

Sets Amazon client configuration.

For details refer to Amazon S3 API reference.

Parameters:

cfg - Amazon client configuration.

setAwsCredentials

@IgniteSpiConfiguration(optional=false)
public void setAwsCredentials(com.amazonaws.auth.AWSCredentials cred)

Sets AWS credentials.

For details refer to Amazon S3 API reference.

Parameters:

cred - AWS credentials.

toString

public String toString()

Overrides:

toString in class TcpDiscoveryIpFinderAdapter