org.apache.nifi.registry.client.impl

Class JerseyNiFiRegistryClient

java.lang.Object

org.apache.nifi.registry.client.impl.JerseyNiFiRegistryClient

All Implemented Interfaces:

Closeable, AutoCloseable, NiFiRegistryClient

public class JerseyNiFiRegistryClient
extends Object
implements NiFiRegistryClient

A NiFiRegistryClient that uses Jersey Client.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JerseyNiFiRegistryClient.Builder Builder for creating a JerseyNiFiRegistryClient.

Field Summary

Fields

Modifier and Type	Field and Description
private javax.ws.rs.client.WebTarget	baseTarget
private BucketClient	bucketClient
private javax.ws.rs.client.Client	client
(package private) static int	DEFAULT_CONNECT_TIMEOUT
(package private) static int	DEFAULT_READ_TIMEOUT
private FlowClient	flowClient
private FlowSnapshotClient	flowSnapshotClient
private ItemsClient	itemsClient
(package private) static String	NIFI_REGISTRY_CONTEXT

Constructor Summary

Constructors

Modifier	Constructor and Description
private	JerseyNiFiRegistryClient(NiFiRegistryClient.Builder builder)

Method Summary

Modifier and Type	Method and Description
void	close()
BucketClient	getBucketClient()
BucketClient	getBucketClient(String... proxiedEntity)
FlowClient	getFlowClient()
FlowClient	getFlowClient(String... proxiedEntity)
FlowSnapshotClient	getFlowSnapshotClient()
FlowSnapshotClient	getFlowSnapshotClient(String... proxiedEntity)
private Map<String,String>	getHeaders(String[] proxiedEntities)
ItemsClient	getItemsClient()
ItemsClient	getItemsClient(String... proxiedEntity)
private String	getProxiedEntitesValue(String[] proxiedEntities)
UserClient	getUserClient()
UserClient	getUserClient(String... proxiedEntity)
private static org.glassfish.jersey.jackson.internal.jackson.jaxrs.json.JacksonJaxbJsonProvider	jacksonJaxbJsonProvider()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NIFI_REGISTRY_CONTEXT

static final String NIFI_REGISTRY_CONTEXT

See Also:

Constant Field Values

DEFAULT_CONNECT_TIMEOUT

static final int DEFAULT_CONNECT_TIMEOUT

See Also:

Constant Field Values

DEFAULT_READ_TIMEOUT

static final int DEFAULT_READ_TIMEOUT

See Also:

Constant Field Values

client

private final javax.ws.rs.client.Client client

baseTarget

private final javax.ws.rs.client.WebTarget baseTarget

bucketClient

private final BucketClient bucketClient

flowClient

private final FlowClient flowClient

flowSnapshotClient

private final FlowSnapshotClient flowSnapshotClient

itemsClient

private final ItemsClient itemsClient

Constructor Detail

JerseyNiFiRegistryClient

private JerseyNiFiRegistryClient(NiFiRegistryClient.Builder builder)

Method Detail

getBucketClient

public BucketClient getBucketClient()

Specified by:

getBucketClient in interface NiFiRegistryClient

Returns:

the client for interacting with buckets

getFlowClient

public FlowClient getFlowClient()

Specified by:

getFlowClient in interface NiFiRegistryClient

Returns:

the client for interacting with flows

getFlowSnapshotClient

public FlowSnapshotClient getFlowSnapshotClient()

Specified by:

getFlowSnapshotClient in interface NiFiRegistryClient

Returns:

the client for interacting with flows/snapshots

getItemsClient

public ItemsClient getItemsClient()

Specified by:

getItemsClient in interface NiFiRegistryClient

Returns:

the client for interacting with bucket items

getBucketClient

public BucketClient getBucketClient(String... proxiedEntity)

Specified by:

getBucketClient in interface NiFiRegistryClient

Returns:

the client for interacting with buckets on behalf of the given proxied entities

getFlowClient

public FlowClient getFlowClient(String... proxiedEntity)

Specified by:

getFlowClient in interface NiFiRegistryClient

Returns:

the client for interacting with flows on behalf of the given proxied entities

getFlowSnapshotClient

public FlowSnapshotClient getFlowSnapshotClient(String... proxiedEntity)

Specified by:

getFlowSnapshotClient in interface NiFiRegistryClient

Returns:

the client for interacting with flows/snapshots on behalf of the given proxied entities

getItemsClient

public ItemsClient getItemsClient(String... proxiedEntity)

Specified by:

getItemsClient in interface NiFiRegistryClient

Returns:

the client for interacting with bucket items on behalf of the given proxied entities

getUserClient

public UserClient getUserClient()

Specified by:

getUserClient in interface NiFiRegistryClient

Returns:

the client for obtaining information about the current user

getUserClient

public UserClient getUserClient(String... proxiedEntity)

Specified by:

getUserClient in interface NiFiRegistryClient

Returns:

the client for obtaining information about the current user based on the given proxied entities

getHeaders

private Map<String,String> getHeaders(String[] proxiedEntities)

getProxiedEntitesValue

private String getProxiedEntitesValue(String[] proxiedEntities)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

jacksonJaxbJsonProvider

private static org.glassfish.jersey.jackson.internal.jackson.jaxrs.json.JacksonJaxbJsonProvider jacksonJaxbJsonProvider()