com.fr.third.jgroups.protocols

类 SWIFT_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.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

从以下版本开始:

3.1

作者:

tsegismont

嵌套类概要

嵌套类

限定符和类型	类和说明
protected static class	SWIFT_PING.SwiftClient A thread safe Swift client

字段概要

字段

限定符和类型	字段和说明
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

从类继承的字段 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, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
SWIFT_PING()

方法概要

方法

限定符和类型	方法和说明
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	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

字段详细资料

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

构造器详细资料

SWIFT_PING

public SWIFT_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

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

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