Class CloudMembershipProvider

    • Constructor Detail

      • CloudMembershipProvider

        public CloudMembershipProvider()
    • Method Detail

      • getEnv

        protected static String getEnv​(String... keys)
        Get value of environment variable.
        Parameters:
        keys - the environment variables
        Returns:
        the env variables values, or null if not found
      • getNamespace

        protected String getNamespace()
        Get the Kubernetes namespace, or "tomcat" if the Kubernetes environment variable cannot be found (with a warning log about the missing namespace).
        Returns:
        the namespace
      • heartbeat

        public void heartbeat()
        Description copied from interface: Heartbeat
        Heartbeat invocation for resources cleanup etc
        Specified by:
        heartbeat in interface Heartbeat
      • fetchMembers

        protected abstract Member[] fetchMembers()
        Fetch current cluster members from the cloud orchestration.
        Returns:
        the member array
      • updateMember

        protected void updateMember​(Member member,
                                    boolean add)
        Add or remove specified member.
        Parameters:
        member - the member to add
        add - true if the member is added, false otherwise
      • accept

        public boolean accept​(Serializable msg,
                              Member sender)
        Description copied from interface: ChannelListener
        Invoked by the channel to determine if the listener will process this message or not.
        Specified by:
        accept in interface ChannelListener
        Parameters:
        msg - Serializable
        sender - Member
        Returns:
        boolean