Class KubernetesMembershipProvider

    • Constructor Detail

      • KubernetesMembershipProvider

        public KubernetesMembershipProvider()
    • Method Detail

      • start

        public void start​(int level)
                   throws java.lang.Exception
        Description copied from interface: MembershipProvider
        Start the membership provider.
        Specified by:
        start in interface MembershipProvider
        Overrides:
        start in class CloudMembershipProvider
        Parameters:
        level - the readiness level
        • Channel.DEFAULT - will start all services
        • Channel.MBR_RX_SEQ - starts the membership receiver
        • Channel.MBR_TX_SEQ - starts the membership broadcaster
        Throws:
        java.lang.Exception - if an error occurs
      • stop

        public boolean stop​(int level)
                     throws java.lang.Exception
        Description copied from interface: MembershipProvider
        Stop the membership provider.
        Specified by:
        stop in interface MembershipProvider
        Overrides:
        stop in class CloudMembershipProvider
        Parameters:
        level - the readiness level
        • Channel.DEFAULT - will stop all services
        • Channel.MBR_RX_SEQ - stops the membership receiver
        • Channel.MBR_TX_SEQ - stops the membership broadcaster
        Returns:
        true if successful
        Throws:
        java.lang.Exception - if an error occurs
      • parsePods

        protected void parsePods​(java.io.Reader reader,
                                 java.util.List<MemberImpl> members)