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 and 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.WriterTask

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

Discovery.Responses

Field Summary

Fields

Modifier and Type	Field and 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, interval, location, root_dir, SUFFIX

Fields inherited from class org.jgroups.protocols.Discovery

always_send_physical_addr_with_discovery_request, break_on_coord_rsp, current_coord, force_sending_discovery_rsps, group_addr, is_coord, is_leaving, is_server, local_addr, members, num_discovery_requests, num_initial_members, num_initial_srv_members, ping_responses, return_entire_cache, stagger_timeout, timeout, timer, use_disk_cache, view

Fields inherited from class org.jgroups.stack.Protocol

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

Constructor Summary

Constructors

Constructor and Description
SWIFT_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 List<PingData>	readAll(String clustername) Reads all information from the given directory under clustername
protected void	remove(String clustername, Address addr)
protected void	writeToFile(PingData data, String clustername)

Methods inherited from class org.jgroups.protocols.FILE_PING

addressAsString, down, fetchClusterMembers, handleView, isDynamic, sendDiscoveryRequestsInParallel, start, stop

Methods inherited from class org.jgroups.protocols.Discovery

breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, findAllViews, findAllViewsAsString, findInitialMembers, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, readPingData, resetStats, returnEntireCache, returnEntireCache, sendDiscoveryRequest, sendDiscoveryResponse, sendMcastDiscoveryRequest, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, timeout, timeout, up, useDiskCache, useDiskCache

Methods inherited from class org.jgroups.stack.Protocol

accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, 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

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 Detail

SWIFT_PING

public SWIFT_PING()

Method Detail

init

public void init()
          throws 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:

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

remove

protected void remove(String clustername,
                      Address addr)

Overrides:

remove in class FILE_PING

readAll

protected List<PingData> readAll(String clustername)

Description copied from class: FILE_PING

Reads all information from the given directory under clustername

Overrides:

readAll in class FILE_PING

Returns:

writeToFile

protected void writeToFile(PingData data,
                           String clustername)

Overrides:

writeToFile in class FILE_PING

createRootDir

protected void createRootDir()

Overrides:

createRootDir in class FILE_PING