Package org.jgroups.protocols.azure

Class AZURE_PING

java.lang.Object
org.jgroups.stack.Protocol
org.jgroups.protocols.Discovery
org.jgroups.protocols.FILE_PING
org.jgroups.protocols.azure.AZURE_PING
All Implemented Interfaces:
org.jgroups.Lifecycle
public class AZURE_PING extends org.jgroups.protocols.FILE_PING
Implementation of a Discovery protocol for Microsoft Azure using Blob Service as cluster information store.
Author:
Radoslav Husar

  • Nested Class Summary

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

    org.jgroups.protocols.FILE_PING.InfoWriter

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

    org.jgroups.protocols.Discovery.DiscoveryCacheDisseminationTask

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected String
    blob_storage_uri
     
    protected String
    connection_string
     
    protected String
    container
     
    protected String
    endpoint_suffix
     
    protected String
    storage_access_key
     
    protected String
    storage_account_name
     
    static final int
    STREAM_BUFFER_SIZE
     
    protected boolean
    use_https
     

    Fields inherited from class org.jgroups.protocols.FILE_PING

    filter, info_writer, info_writer_max_writes_after_view, info_writer_sleep_time, location, num_read_loops, read_sleep, reads, regexp, register_shutdown_hook, remove_all_data_on_view_change, remove_old_coords_on_view_change, root_dir, shutdown_hook, 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, policies, preview_warning, stack, stats, up_prot

  • Constructor Summary

    Constructors
    Constructor
    Description
    AZURE_PING()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected static String
    addressToFilename(String clustername, org.jgroups.Address address)
    Converts cluster name and address into a filename.
    protected void
    createRootDir()
     
    protected static String
    getSanitizedPrefix(String name)
    Sanitizes names replacing backslashes and forward slashes with a dash and appends a separator.
    void
    init()
     
    protected void
    parsePingData(byte[] pingBytes, List<org.jgroups.Address> members, org.jgroups.util.Responses responses)
     
    protected void
    readAll(List<org.jgroups.Address> members, String clustername, org.jgroups.util.Responses responses)
     
    protected void
    remove(String clustername, org.jgroups.Address addr)
     
    protected void
    removeAll(String clustername)
     
    void
    validateConfiguration()
     
    protected void
    write(List<org.jgroups.protocols.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, start, startInfoWriter, stop, stopInfoWriter, updateStoreOnViewChange, updateStoreOnViewChange, write, writeAll, writeAll, writeDataOnFind, writeDataOnFind, writeInfo

    Methods inherited from class org.jgroups.protocols.Discovery

    addDiscoveryResponseToCaches, addResponse, addResponse, addressAsString, addToCache, asyncDiscovery, asyncDiscovery, asyncDiscoveryUseSeparateThread, asyncDiscoveryUseSeparateThread, breakOnCoordResponse, breakOnCoordResponse, callFindMembersInAllDiscoveryProtocols, clearRequestFutures, deserialize, discoveryRequestReceived, discoveryRspExpiryTime, discoveryRspExpiryTime, disseminateDiscoveryInformation, dumpCache, findInitialMembersAsString, findMembers, findTopmostDiscoveryProtocol, getClusterName, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getView, getViewId, handle, handleConnect, handleDisconnect, handleDiscoveryResponse, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, marshal, marshal, maxRankToReply, maxRankToReply, numDiscoveryRuns, numDiscoveryRuns, print, providedUpServices, readPingData, returnEntireCache, returnEntireCache, sendCacheInformation, sendCacheOnJoin, sendCacheOnJoin, sendDiscoveryResponse, sendDiscoveryResponse, serializeWithoutView, setClusterName, staggerTimeout, staggerTimeout, startCacheDissemination, transportSupportsMulticasting, 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, previewWarning, previewWarning, 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

    • storage_account_name

      protected String storage_account_name

    • storage_access_key

      protected String storage_access_key

    • connection_string

      protected String connection_string

    • container

      protected String container

    • use_https

      protected boolean use_https

    • endpoint_suffix

      protected String endpoint_suffix

    • blob_storage_uri

      protected String blob_storage_uri

    • STREAM_BUFFER_SIZE

      public static final int STREAM_BUFFER_SIZE
      See Also:

  • Constructor Details

    • AZURE_PING

      public AZURE_PING()

  • Method Details

    • init

      public void init() throws Exception
      Specified by:
      init in interface org.jgroups.Lifecycle
      Overrides:
      init in class org.jgroups.protocols.FILE_PING
      Throws:
      Exception

    • validateConfiguration

      public void validateConfiguration() throws IllegalArgumentException
      Throws:
      IllegalArgumentException

    • createRootDir

      protected void createRootDir()
      Overrides:
      createRootDir in class org.jgroups.protocols.FILE_PING

    • readAll

      protected void readAll(List<org.jgroups.Address> members, String clustername, org.jgroups.util.Responses responses)
      Overrides:
      readAll in class org.jgroups.protocols.FILE_PING

    • parsePingData

      protected void parsePingData(byte[] pingBytes, List<org.jgroups.Address> members, org.jgroups.util.Responses responses)

    • write

      protected void write(List<org.jgroups.protocols.PingData> list, String clustername)
      Overrides:
      write in class org.jgroups.protocols.FILE_PING

    • remove

      protected void remove(String clustername, org.jgroups.Address addr)
      Overrides:
      remove in class org.jgroups.protocols.FILE_PING

    • removeAll

      protected void removeAll(String clustername)
      Overrides:
      removeAll in class org.jgroups.protocols.FILE_PING

    • addressToFilename

      protected static String addressToFilename(String clustername, org.jgroups.Address address)
      Converts cluster name and address into a filename.

    • getSanitizedPrefix

      protected static String getSanitizedPrefix(String name)
      Sanitizes names replacing backslashes and forward slashes with a dash and appends a separator.