Package | Description |
---|---|
org.elasticsearch.discovery.zen.ping | |
org.elasticsearch.discovery.zen.ping.multicast | |
org.elasticsearch.discovery.zen.ping.unicast |
Modifier and Type | Field and Description |
---|---|
static ZenPing.PingResponse[] |
ZenPing.PingResponse.EMPTY |
Modifier and Type | Method and Description |
---|---|
ZenPing.PingResponse[] |
ZenPingService.pingAndWait(TimeValue timeout) |
static ZenPing.PingResponse |
ZenPing.PingResponse.readPingResponse(StreamInput in) |
ZenPing.PingResponse[] |
ZenPing.PingCollection.toArray()
serialize current pings to an array
|
Modifier and Type | Method and Description |
---|---|
boolean |
ZenPing.PingCollection.addPing(ZenPing.PingResponse ping)
adds a ping if newer than previous pings from the same node
|
void |
ZenPing.PingCollection.addPings(ZenPing.PingResponse[] pings)
adds multiple pings if newer than previous pings from the same node
|
void |
ZenPing.PingListener.onPing(ZenPing.PingResponse[] pings) |
Modifier and Type | Method and Description |
---|---|
ZenPing.PingResponse[] |
MulticastZenPing.pingAndWait(TimeValue timeout) |
Modifier and Type | Method and Description |
---|---|
ZenPing.PingResponse[] |
UnicastZenPing.pingAndWait(TimeValue timeout) |
Copyright © 2009–2015. All rights reserved.