com.fr.third.jgroups.protocols

类 S3_PING

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

com.fr.third.jgroups.protocols.FILE_PING

com.fr.third.jgroups.protocols.S3_PING

直接已知子类:

GOOGLE_PING

public class S3_PING
extends FILE_PING

Discovery protocol using Amazon's S3 storage. The S3 access code reuses the example shipped by Amazon.

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected java.lang.String	access_key
protected com.fr.third.jgroups.protocols.S3_PING.AWSAuthConnection	conn
protected java.lang.String	pre_signed_delete_url
protected java.lang.String	pre_signed_put_url
protected java.lang.String	prefix
protected java.lang.String	secret_access_key
protected boolean	skip_bucket_existence_check

从类继承的字段 com.fr.third.jgroups.protocols.FILE_PING

filter, interval, location, prev_view, reads, root_dir, SUFFIX, writes

从类继承的字段 com.fr.third.jgroups.protocols.Discovery

always_send_physical_addr_with_discovery_request, async_discovery, break_on_coord_rsp, cluster_name, current_coord, discovery_rsp_expiry_time, force_sending_discovery_rsps, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, members, num_discovery_requests, num_initial_members, num_initial_srv_members, ping_responses, return_entire_cache, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
S3_PING()

方法概要

方法

限定符和类型	方法和说明
protected com.fr.third.jgroups.protocols.S3_PING.AWSAuthConnection	createConnection()
protected void	createRootDir()
static java.lang.String	generatePreSignedUrl(java.lang.String awsAccessKey, java.lang.String awsSecretAccessKey, java.lang.String method, java.lang.String bucket, java.lang.String key, long expirationDate) Use this helper method to generate pre-signed S3 urls for use with S3_PING.
void	init() Called after instance has been created (null constructor) and before protocol is started.
protected void	readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	readResponse(com.fr.third.jgroups.protocols.S3_PING.GetResponse rsp, java.util.List<Address> mbrs, Responses responses)
protected void	remove(java.lang.String clustername, Address addr)
protected static java.lang.String	sanitize(java.lang.String name) Sanitizes bucket and folder names according to AWS guidelines
protected boolean	usingPreSignedUrls()
protected void	validateProperties()
protected void	write(java.util.List<PingData> list, java.lang.String clustername)

从类继承的方法 com.fr.third.jgroups.protocols.FILE_PING

addDiscoveryResponseToCaches, addressToFilename, deleteFile, down, findMembers, handleView, isDynamic, read, read, resetStats, write, writeAll

从类继承的方法 com.fr.third.jgroups.protocols.Discovery

addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, dumpCache, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, readPingData, returnEntireCache, returnEntireCache, sendDiscoveryResponse, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, start, stop, timeout, timeout, up, useDiskCache, useDiskCache

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up

从类继承的方法 java.lang.Object

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

字段详细资料

access_key

protected java.lang.String access_key

secret_access_key

protected java.lang.String secret_access_key

prefix

protected java.lang.String prefix

pre_signed_put_url

protected java.lang.String pre_signed_put_url

pre_signed_delete_url

protected java.lang.String pre_signed_delete_url

skip_bucket_existence_check

protected boolean skip_bucket_existence_check

conn

protected com.fr.third.jgroups.protocols.S3_PING.AWSAuthConnection conn

构造器详细资料

S3_PING

public S3_PING()

方法详细资料

init

public void init()
          throws java.lang.Exception

从类复制的说明: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

覆盖:

init 在类中 FILE_PING

抛出:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

createConnection

protected com.fr.third.jgroups.protocols.S3_PING.AWSAuthConnection createConnection()

createRootDir

protected void createRootDir()

覆盖:

createRootDir 在类中 FILE_PING

readAll

protected void readAll(java.util.List<Address> members,
           java.lang.String clustername,
           Responses responses)

覆盖:

readAll 在类中 FILE_PING

readResponse

protected void readResponse(com.fr.third.jgroups.protocols.S3_PING.GetResponse rsp,
                java.util.List<Address> mbrs,
                Responses responses)

write

protected void write(java.util.List<PingData> list,
         java.lang.String clustername)

覆盖:

write 在类中 FILE_PING

remove

protected void remove(java.lang.String clustername,
          Address addr)

覆盖:

remove 在类中 FILE_PING

validateProperties

protected void validateProperties()

usingPreSignedUrls

protected boolean usingPreSignedUrls()

sanitize

protected static java.lang.String sanitize(java.lang.String name)

Sanitizes bucket and folder names according to AWS guidelines

generatePreSignedUrl

public static java.lang.String generatePreSignedUrl(java.lang.String awsAccessKey,
                                    java.lang.String awsSecretAccessKey,
                                    java.lang.String method,
                                    java.lang.String bucket,
                                    java.lang.String key,
                                    long expirationDate)

Use this helper method to generate pre-signed S3 urls for use with S3_PING. You'll need to generate urls for both the put and delete http methods. Example: Your AWS Access Key is "abcd". Your AWS Secret Access Key is "efgh". You want this node to write its information to "/S3_PING/DemoCluster/node1". So, your bucket is "S3_PING" and your key is "DemoCluster/node1". You want this to expire one year from now, or (System.currentTimeMillis / 1000) + (60 * 60 * 24 * 365) Let's assume that this equals 1316286684

Here's how to generate the value for the pre_signed_put_url property: String putUrl = S3_PING.generatePreSignedUrl("abcd", "efgh", "put", "S3_Ping", "DemoCluster/node1", 1316286684);

Here's how to generate the value for the pre_signed_delete_url property: String deleteUrl = S3_PING.generatePreSignedUrl("abcd", "efgh", "delete", "S3_Ping", "DemoCluster/node1", 1316286684);

参数:

awsAccessKey - Your AWS Access Key

awsSecretAccessKey - Your AWS Secret Access Key

method - The HTTP method - use "put" or "delete" for use with S3_PING

bucket - The S3 bucket you want to write to

key - The key within the bucket to write to

expirationDate - The date this pre-signed url should expire, in seconds since epoch

返回:

The pre-signed url to be used in pre_signed_put_url or pre_signed_delete_url properties