public class KubernetesMembershipScheme extends Object implements org.wso2.carbon.core.clustering.hazelcast.HazelcastMembershipScheme
Modifier and Type | Field and Description |
---|---|
protected com.hazelcast.config.NetworkConfig |
nwConfig |
Constructor and Description |
---|
KubernetesMembershipScheme(Map<String,org.apache.axis2.description.Parameter> parameters,
String primaryDomain,
com.hazelcast.config.Config config,
com.hazelcast.core.HazelcastInstance primaryHazelcastInstance,
List<org.apache.axis2.clustering.ClusteringMessage> messageBuffer) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
connectAndRead(KubernetesApiEndpoint endpoint,
String username,
String password) |
protected KubernetesApiEndpoint |
createAPIEndpoint(URL url) |
protected URL |
createUrl(String master,
String context) |
protected List<String> |
findContainerIPs(String kubernetesMaster,
String namespace,
String serviceName,
String username,
String password) |
protected Endpoints |
getEndpoints(InputStream inputStream) |
protected String |
getParameterValue(String parameterName) |
protected String |
getParameterValue(String parameterName,
String defaultValue) |
void |
init() |
void |
joinGroup() |
void |
setCarbonCluster(org.wso2.carbon.core.clustering.hazelcast.HazelcastCarbonClusterImpl hazelcastCarbonCluster) |
void |
setLocalMember(com.hazelcast.core.Member localMember) |
void |
setPrimaryHazelcastInstance(com.hazelcast.core.HazelcastInstance primaryHazelcastInstance) |
public KubernetesMembershipScheme(Map<String,org.apache.axis2.description.Parameter> parameters, String primaryDomain, com.hazelcast.config.Config config, com.hazelcast.core.HazelcastInstance primaryHazelcastInstance, List<org.apache.axis2.clustering.ClusteringMessage> messageBuffer)
public void setPrimaryHazelcastInstance(com.hazelcast.core.HazelcastInstance primaryHazelcastInstance)
setPrimaryHazelcastInstance
in interface org.wso2.carbon.core.clustering.hazelcast.HazelcastMembershipScheme
public void setLocalMember(com.hazelcast.core.Member localMember)
setLocalMember
in interface org.wso2.carbon.core.clustering.hazelcast.HazelcastMembershipScheme
public void setCarbonCluster(org.wso2.carbon.core.clustering.hazelcast.HazelcastCarbonClusterImpl hazelcastCarbonCluster)
setCarbonCluster
in interface org.wso2.carbon.core.clustering.hazelcast.HazelcastMembershipScheme
public void init() throws org.apache.axis2.clustering.ClusteringFault
init
in interface org.apache.axis2.clustering.MembershipScheme
org.apache.axis2.clustering.ClusteringFault
protected String getParameterValue(String parameterName) throws org.apache.axis2.clustering.ClusteringFault
org.apache.axis2.clustering.ClusteringFault
protected String getParameterValue(String parameterName, String defaultValue) throws org.apache.axis2.clustering.ClusteringFault
org.apache.axis2.clustering.ClusteringFault
protected List<String> findContainerIPs(String kubernetesMaster, String namespace, String serviceName, String username, String password) throws KubernetesMembershipSchemeException
protected URL createUrl(String master, String context) throws KubernetesMembershipSchemeException
protected KubernetesApiEndpoint createAPIEndpoint(URL url) throws KubernetesMembershipSchemeException
protected InputStream connectAndRead(KubernetesApiEndpoint endpoint, String username, String password) throws KubernetesMembershipSchemeException
protected Endpoints getEndpoints(InputStream inputStream) throws IOException
IOException
public void joinGroup() throws org.apache.axis2.clustering.ClusteringFault
joinGroup
in interface org.apache.axis2.clustering.MembershipScheme
org.apache.axis2.clustering.ClusteringFault
Copyright © 2016 WSO2. All rights reserved.