com.fr.third.jgroups.protocols

类 RACKSPACE_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.RACKSPACE_PING

public class RACKSPACE_PING
extends FILE_PING

Discovery protocol based on Rackspace Cloud Files storage solution

作者:

Gustavo Fernandes

字段概要

字段

限定符和类型	字段和说明
protected java.lang.String	apiKey
protected java.lang.String	container
protected static Log	log
protected com.fr.third.jgroups.protocols.RACKSPACE_PING.RackspaceClient	rackspaceClient
protected java.lang.String	region
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

构造器概要

构造器

构造器和说明
RACKSPACE_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

字段详细资料

log

protected static final Log log

rackspaceClient

protected com.fr.third.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

构造器详细资料

RACKSPACE_PING

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