ChannelListener
, Heartbeat
, MembershipProvider
public class KubernetesMembershipProvider extends CloudMembershipProvider
connectionTimeout, expirationTime, headers, localIp, md5, port, readTimeout, sm, startTime, streamProvider, url
executor, membership, membershipListener, service
Constructor | Description |
---|---|
KubernetesMembershipProvider() |
Modifier and Type | Method | Description |
---|---|---|
protected Member[] |
fetchMembers() |
Fetch current cluster members from the cloud orchestration.
|
protected void |
parsePods(java.io.Reader reader,
java.util.List<MemberImpl> members) |
|
void |
start(int level) |
|
boolean |
stop(int level) |
equals, hashCode
accept, getEnv, heartbeat, init, messageReceived
getMember, getMembers, hasMembers, setMembershipListener, setMembershipService
public void start(int level) throws java.lang.Exception
start
in interface MembershipProvider
start
in class CloudMembershipProvider
java.lang.Exception
public boolean stop(int level) throws java.lang.Exception
stop
in interface MembershipProvider
stop
in class CloudMembershipProvider
java.lang.Exception
protected Member[] fetchMembers()
CloudMembershipProvider
fetchMembers
in class CloudMembershipProvider
protected void parsePods(java.io.Reader reader, java.util.List<MemberImpl> members)
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.