org.jgroups.protocols

Class RACKSPACE_PING

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.Discovery

org.jgroups.protocols.FILE_PING

org.jgroups.protocols.RACKSPACE_PING

public class RACKSPACE_PING
extends FILE_PING

Discovery protocol based on Rackspace Cloud Files storage solution

Author:

Gustavo Fernandes

Nested Class Summary

Nested classes/interfaces inherited from class org.jgroups.protocols.FILE_PING

FILE_PING.InfoWriter

Nested classes/interfaces inherited from class org.jgroups.protocols.Discovery

Discovery.DiscoveryCacheDisseminationTask

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	apiKey
protected java.lang.String	container
protected static Log	log
protected org.jgroups.protocols.RACKSPACE_PING.RackspaceClient	rackspaceClient
protected java.lang.String	region
protected java.lang.String	username

Fields inherited from class org.jgroups.protocols.FILE_PING

filter, info_writer, info_writer_max_writes_after_view, info_writer_sleep_time, interval, location, reads, regexp, remove_all_files_on_view_change, remove_old_coords_on_view_change, root_dir, SUFFIX, write_data_on_find, writes

Fields inherited from class org.jgroups.protocols.Discovery

always_send_physical_addr_with_discovery_request, async_discovery, async_discovery_use_separate_thread_per_request, 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, send_cache_on_join, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE

Fields inherited from class org.jgroups.stack.Protocol

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

Constructor Summary

Constructors

Constructor and Description
RACKSPACE_PING()

Method Summary

Modifier and Type	Method and Description
protected void	createRootDir()
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	remove(java.lang.String clustername, Address addr)
protected void	removeAll(java.lang.String clustername) Removes all files for the given cluster name
protected void	write(java.util.List<PingData> list, java.lang.String clustername)

Methods inherited from class org.jgroups.protocols.FILE_PING

addDiscoveryResponseToCaches, addressToFilename, deleteFile, down, findMembers, getLocation, getRemoveAllDataOnViewChange, handleView, isDynamic, isInfoWriterRunning, read, read, resetStats, setLocation, setRemoveAllDataOnViewChange, startInfoWriter, stopInfoWriter, write, writeAll, writeInfo

Methods inherited from class org.jgroups.protocols.Discovery

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

Methods inherited from class org.jgroups.stack.Protocol

accept, afterCreationHook, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, 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

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final Log log

rackspaceClient

protected org.jgroups.protocols.RACKSPACE_PING.RackspaceClient rackspaceClient

username

protected java.lang.String username

apiKey

protected java.lang.String apiKey

region

protected java.lang.String region

container

protected java.lang.String container

Constructor Detail

RACKSPACE_PING

public RACKSPACE_PING()

Method Detail

init

public void init()
          throws java.lang.Exception

Description copied from class: 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.

Overrides:

init in class FILE_PING

Throws:

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

createRootDir

protected void createRootDir()

Overrides:

createRootDir in class FILE_PING

readAll

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

Overrides:

readAll in class FILE_PING

write

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

Overrides:

write in class FILE_PING

remove

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

Overrides:

remove in class FILE_PING

removeAll

protected void removeAll(java.lang.String clustername)

Description copied from class: FILE_PING

Removes all files for the given cluster name

Overrides:

removeAll in class FILE_PING