public class EndpointsResource
extends java.lang.Object
Constructor and Description |
---|
EndpointsResource(StateStore stateStore,
java.lang.String serviceName)
Creates a new instance which retrieves task/pod state from the provided
StateStore ,
using the provided serviceName for endpoint paths. |
Modifier and Type | Method and Description |
---|---|
Response |
getEndpoint(java.lang.String name)
Produces the content of the specified endpoint.
|
Response |
getEndpoints()
Produces a listing of all endpoint names.
|
EndpointsResource |
setCustomEndpoint(java.lang.String name,
EndpointProducer endpointProducer)
Adds the provided custom endpoint key/value entry to this instance.
|
public EndpointsResource(StateStore stateStore, java.lang.String serviceName)
StateStore
,
using the provided serviceName
for endpoint paths.public EndpointsResource setCustomEndpoint(java.lang.String name, EndpointProducer endpointProducer)
DiscoveryInfo
, such as a Kafka service exposing a Zookeeper path that's separate from
the default broker host/port listing.
This only supports simple string values in order to ensure that the 'endpoints' endpoint
remains relatively consistent across services. For a per-task listing of endpoints, you
should provide that information via DiscoveryInfo
in your TaskInfo
and they
will appear automatically.name
- the name of the custom endpoint. custom endpoints take precedence over default
endpoints of the same nameendpointProducer
- the endpoint producer, which will be invoked whenever a user queries the
list of endpointspublic Response getEndpoints()
public Response getEndpoint(java.lang.String name)
name
- the name of the endpoint whose content should be included