Package org.jgroups.protocols
Class SWIFT_PING
- java.lang.Object
-
- org.jgroups.stack.Protocol
-
- org.jgroups.protocols.Discovery
-
- org.jgroups.protocols.FILE_PING
-
- org.jgroups.protocols.SWIFT_PING
-
public class SWIFT_PING extends FILE_PING
Discovery protocol based on Openstack Swift (object storage). This implementation is derived from Gustavo Fernandes work on RACKSPACE_PING- Since:
- 3.1
- Author:
- tsegismont
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
SWIFT_PING.SwiftClient
A thread safe Swift client-
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 Description protected java.lang.String
auth_type
protected java.lang.String
auth_url
protected java.lang.String
container
protected java.lang.String
password
protected SWIFT_PING.SwiftClient
swiftClient
protected java.lang.String
tenant
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, location, reads, regexp, register_shutdown_hook, remove_all_data_on_view_change, remove_old_coords_on_view_change, root_dir, SUFFIX, update_store_on_view_change, write_data_on_find, writes
-
Fields inherited from class org.jgroups.protocols.Discovery
async_discovery, async_discovery_use_separate_thread_per_request, break_on_coord_rsp, cluster_name, current_coord, discovery_req_futures, discovery_rsp_callback, discovery_rsp_expiry_time, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, max_rank_to_reply, num_discovery_requests, num_discovery_runs, ping_responses, return_entire_cache, send_cache_on_join, sends_can_block, stagger_timeout, timer, transport, transport_supports_multicasting, use_disk_cache, use_ip_addrs, view, WHITESPACE
-
Fields inherited from class org.jgroups.stack.Protocol
after_creation_hook, down_prot, ergonomics, id, log, stack, stats, up_prot
-
-
Constructor Summary
Constructors Constructor Description SWIFT_PING()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 nameprotected void
write(java.util.List<PingData> list, java.lang.String clustername)
-
Methods inherited from class org.jgroups.protocols.FILE_PING
addressToFilename, deleteFile, down, findMembers, getLocation, getRemoveAllDataOnViewChange, handleView, isDynamic, isInfoWriterRunning, read, read, resetStats, setLocation, setRemoveAllDataOnViewChange, startInfoWriter, stop, stopInfoWriter, write, writeAll, writeAll, writeInfo
-
Methods inherited from class org.jgroups.protocols.Discovery
addDiscoveryResponseToCaches, addResponse, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, clearRequestFutures, deserialize, discoveryRequestReceived, discoveryRspExpiryTime, disseminateDiscoveryInformation, dumpCache, findInitialMembersAsString, findMembers, getClusterName, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, invokeFindMembers, isCoord, isMergeRunning, marshal, providedUpServices, readPingData, returnEntireCache, returnEntireCache, sendCacheInformation, sendDiscoveryResponse, serializeWithoutView, setClusterName, staggerTimeout, staggerTimeout, start, startCacheDissemination, up, up, useDiskCache, useDiskCache, weedOutCompletedDiscoveryResponses
-
Methods inherited from class org.jgroups.stack.Protocol
accept, afterCreationHook, destroy, down, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, providedDownServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, statsEnabled, up
-
-
-
-
Field Detail
-
swiftClient
protected SWIFT_PING.SwiftClient swiftClient
-
auth_url
protected java.lang.String auth_url
-
auth_type
protected java.lang.String auth_type
-
tenant
protected java.lang.String tenant
-
username
protected java.lang.String username
-
password
protected java.lang.String password
-
container
protected java.lang.String container
-
-
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.
-
createRootDir
protected void createRootDir()
- Overrides:
createRootDir
in classFILE_PING
-
readAll
protected void readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
-
write
protected void write(java.util.List<PingData> list, java.lang.String clustername)
-
remove
protected void remove(java.lang.String clustername, Address addr)
-
-