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

All Implemented Interfaces:

Lifecycle

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	SWIFT_PING.AUTH_TYPE	Supported Swift authentication providers
private static interface	SWIFT_PING.Authenticator	Contract for Swift authentication providers
private static class	SWIFT_PING.ConnBuilder	Build HttpURLConnections with adequate headers and method
private static class	SWIFT_PING.Credentials	Result of a successfully authenticated session
private static class	SWIFT_PING.HttpHeaders
private static class	SWIFT_PING.HttpResponse	Response for a Swift API call
private static class	SWIFT_PING.Keystone_V_2_0_Auth	Openstack Keytsone v2.0 authentication provider.
protected static class	SWIFT_PING.SwiftClient	A thread safe Swift client
private static class	SWIFT_PING.Utils

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 String	auth_type
protected String	auth_url
protected String	container
protected String	password
protected SWIFT_PING.SwiftClient	swiftClient
protected String	tenant
protected 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, 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, view, WHITESPACE

Fields inherited from class org.jgroups.stack.Protocol

after_creation_hook, down_prot, ergonomics, id, local_addr, log, policies, stack, stats, up_prot

Constructor Summary

Constructors

Constructor	Description
SWIFT_PING()

Method Summary

Modifier and Type	Method	Description
private SWIFT_PING.Authenticator	createAuthenticator()
protected void	createRootDir()
void	init()	Called after a protocol has been created and before the protocol is started.
protected void	readAll(List<Address> members, String clustername, Responses responses)
protected void	remove(String clustername, Address addr)
protected void	removeAll(String clustername)	Removes all files for the given cluster name
protected void	write(List<PingData> list, String clustername)

Methods inherited from class org.jgroups.protocols.FILE_PING

addressToFilename, deleteFile, down, findMembers, getInfoWriterMaxWritesAfterView, getInfoWriterSleepTime, getLocation, handleView, isDynamic, isInfoWriterRunning, read, read, registerShutdownHook, registerShutdownHook, removeAllDataOnViewChange, removeAllDataOnViewChange, removeOldCoordsOnViewChange, removeOldCoordsOnViewChange, resetStats, setInfoWriterMaxWritesAfterView, setInfoWriterSleepTime, setLocation, startInfoWriter, stop, stopInfoWriter, updateStoreOnViewChange, updateStoreOnViewChange, write, writeAll, writeAll, writeDataOnFind, writeDataOnFind, writeInfo

Methods inherited from class org.jgroups.protocols.Discovery

addDiscoveryResponseToCaches, addResponse, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, callFindMembersInAllDiscoveryProtocols, clearRequestFutures, deserialize, discoveryRequestReceived, discoveryRspExpiryTime, disseminateDiscoveryInformation, dumpCache, findInitialMembersAsString, findMembers, findTopmostDiscoveryProtocol, getClusterName, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getView, getViewId, handle, handleConnect, handleDisconnect, handleDiscoveryResponse, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, marshal, marshal, print, providedUpServices, readPingData, returnEntireCache, returnEntireCache, sendCacheInformation, sendCacheOnJoin, sendCacheOnJoin, sendDiscoveryResponse, sendDiscoveryResponse, serializeWithoutView, setClusterName, staggerTimeout, staggerTimeout, start, startCacheDissemination, up, up, up, useDiskCache, useDiskCache, weedOutCompletedDiscoveryResponses

Methods inherited from class org.jgroups.stack.Protocol

accept, addPolicy, addr, addr, afterCreationHook, destroy, down, down, enableStats, getAddress, getComponents, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getPolicies, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, policies, providedDownServices, removePolicy, requiredDownServices, requiredUpServices, resetStatistics, setAddress, setDownProtocol, setErgonomics, setId, setLevel, setPolicies, setProtocolStack, setSocketFactory, setUpProtocol, setValue, statsEnabled, toString

Methods inherited from class java.lang.Object

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

Field Details

swiftClient

protected SWIFT_PING.SwiftClient swiftClient

auth_url

protected String auth_url

auth_type

protected String auth_type

tenant

protected String tenant

username

protected String username

password

protected String password

container

protected String container

Constructor Details

SWIFT_PING

public SWIFT_PING()

Method Details

init

public void init()
          throws Exception

Description copied from class: Protocol

Called after a protocol has been created and before the protocol is started. Attributes are already set. Other protocols are not yet connected and events cannot yet be sent.

Specified by:

init in interface Lifecycle

Overrides:

init in class FILE_PING

Throws:

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

createAuthenticator

private SWIFT_PING.Authenticator createAuthenticator()
                                              throws Exception

Throws:

Exception

createRootDir

protected void createRootDir()

Overrides:

createRootDir in class FILE_PING

readAll

protected void readAll(List<Address> members,
 String clustername,
 Responses responses)

Overrides:

readAll in class FILE_PING

write

protected void write(List<PingData> list,
 String clustername)

Overrides:

write in class FILE_PING

remove

protected void remove(String clustername,
 Address addr)

Overrides:

remove in class FILE_PING

removeAll

protected void removeAll(String clustername)

Description copied from class: FILE_PING

Removes all files for the given cluster name

Overrides:

removeAll in class FILE_PING