Class 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
    Author:
    tsegismont
    • Field Detail

      • 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
    • Constructor Detail

      • SWIFT_PING

        public SWIFT_PING()
    • Method Detail

      • init

        public void init()
                  throws java.lang.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:
        java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the the channel constructor will throw an exception
      • readAll

        protected void readAll​(java.util.List<Address> members,
                               java.lang.String clustername,
                               Responses responses)
        Overrides:
        readAll in class FILE_PING
      • write

        protected void write​(java.util.List<PingData> list,
                             java.lang.String clustername)
        Overrides:
        write in class FILE_PING
      • remove

        protected void remove​(java.lang.String clustername,
                              Address addr)
        Overrides:
        remove in class FILE_PING
      • removeAll

        protected void removeAll​(java.lang.String clustername)
        Description copied from class: FILE_PING
        Removes all files for the given cluster name
        Overrides:
        removeAll in class FILE_PING