All URIs are relative to http://localhost/nifi-api
Method | HTTP request | Description |
---|---|---|
CreateBulletin | POST /controller/bulletin | Creates a new bulletin |
CreateControllerService | POST /controller/controller-services | Creates a new controller service |
CreateRegistryClient | POST /controller/registry-clients | Creates a new registry client |
CreateReportingTask | POST /controller/reporting-tasks | Creates a new reporting task |
DeleteHistory | DELETE /controller/history | Purges history |
DeleteNode | DELETE /controller/cluster/nodes/{id} | Removes a node from the cluster |
DeleteRegistryClient | DELETE /controller/registry-clients/{id} | Deletes a registry client |
GetCluster | GET /controller/cluster | Gets the contents of the cluster |
GetControllerConfig | GET /controller/config | Retrieves the configuration for this NiFi Controller |
GetNode | GET /controller/cluster/nodes/{id} | Gets a node in the cluster |
GetRegistryClient | GET /controller/registry-clients/{id} | Gets a registry client |
GetRegistryClients | GET /controller/registry-clients | Gets the listing of available registry clients |
UpdateControllerConfig | PUT /controller/config | Retrieves the configuration for this NiFi |
UpdateNode | PUT /controller/cluster/nodes/{id} | Updates a node in the cluster |
UpdateRegistryClient | PUT /controller/registry-clients/{id} | Updates a registry client |
BulletinEntity CreateBulletin (BulletinEntity body)
Creates a new bulletin
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class CreateBulletinExample
{
public void main()
{
var apiInstance = new ControllerApi();
var body = new BulletinEntity(); // BulletinEntity | The reporting task configuration details.
try
{
// Creates a new bulletin
BulletinEntity result = apiInstance.CreateBulletin(body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.CreateBulletin: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
body | BulletinEntity | The reporting task configuration details. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ControllerServiceEntity CreateControllerService (ControllerServiceEntity body)
Creates a new controller service
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class CreateControllerServiceExample
{
public void main()
{
var apiInstance = new ControllerApi();
var body = new ControllerServiceEntity(); // ControllerServiceEntity | The controller service configuration details.
try
{
// Creates a new controller service
ControllerServiceEntity result = apiInstance.CreateControllerService(body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.CreateControllerService: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
body | ControllerServiceEntity | The controller service configuration details. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
RegistryClientEntity CreateRegistryClient (RegistryClientEntity body)
Creates a new registry client
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class CreateRegistryClientExample
{
public void main()
{
var apiInstance = new ControllerApi();
var body = new RegistryClientEntity(); // RegistryClientEntity | The registry configuration details.
try
{
// Creates a new registry client
RegistryClientEntity result = apiInstance.CreateRegistryClient(body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.CreateRegistryClient: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
body | RegistryClientEntity | The registry configuration details. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ReportingTaskEntity CreateReportingTask (ReportingTaskEntity body)
Creates a new reporting task
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class CreateReportingTaskExample
{
public void main()
{
var apiInstance = new ControllerApi();
var body = new ReportingTaskEntity(); // ReportingTaskEntity | The reporting task configuration details.
try
{
// Creates a new reporting task
ReportingTaskEntity result = apiInstance.CreateReportingTask(body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.CreateReportingTask: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
body | ReportingTaskEntity | The reporting task configuration details. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
HistoryEntity DeleteHistory (string endDate)
Purges history
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class DeleteHistoryExample
{
public void main()
{
var apiInstance = new ControllerApi();
var endDate = endDate_example; // string | Purge actions before this date/time.
try
{
// Purges history
HistoryEntity result = apiInstance.DeleteHistory(endDate);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.DeleteHistory: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
endDate | string | Purge actions before this date/time. |
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
NodeEntity DeleteNode (string id)
Removes a node from the cluster
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class DeleteNodeExample
{
public void main()
{
var apiInstance = new ControllerApi();
var id = id_example; // string | The node id.
try
{
// Removes a node from the cluster
NodeEntity result = apiInstance.DeleteNode(id);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.DeleteNode: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
id | string | The node id. |
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
RegistryClientEntity DeleteRegistryClient (string id, string version = null, string clientId = null, bool? disconnectedNodeAcknowledged = null)
Deletes a registry client
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class DeleteRegistryClientExample
{
public void main()
{
var apiInstance = new ControllerApi();
var id = id_example; // string | The registry id.
var version = version_example; // string | The revision is used to verify the client is working with the latest version of the flow. (optional)
var clientId = clientId_example; // string | If the client id is not specified, new one will be generated. This value (whether specified or generated) is included in the response. (optional)
var disconnectedNodeAcknowledged = true; // bool? | Acknowledges that this node is disconnected to allow for mutable requests to proceed. (optional) (default to false)
try
{
// Deletes a registry client
RegistryClientEntity result = apiInstance.DeleteRegistryClient(id, version, clientId, disconnectedNodeAcknowledged);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.DeleteRegistryClient: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
id | string | The registry id. | |
version | string | The revision is used to verify the client is working with the latest version of the flow. | [optional] |
clientId | string | If the client id is not specified, new one will be generated. This value (whether specified or generated) is included in the response. | [optional] |
disconnectedNodeAcknowledged | bool? | Acknowledges that this node is disconnected to allow for mutable requests to proceed. | [optional] [default to false] |
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ClusterEntity GetCluster ()
Gets the contents of the cluster
Returns the contents of the cluster including all nodes and their status.
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class GetClusterExample
{
public void main()
{
var apiInstance = new ControllerApi();
try
{
// Gets the contents of the cluster
ClusterEntity result = apiInstance.GetCluster();
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.GetCluster: " + e.Message );
}
}
}
}
This endpoint does not need any parameter.
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ControllerConfigurationEntity GetControllerConfig ()
Retrieves the configuration for this NiFi Controller
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class GetControllerConfigExample
{
public void main()
{
var apiInstance = new ControllerApi();
try
{
// Retrieves the configuration for this NiFi Controller
ControllerConfigurationEntity result = apiInstance.GetControllerConfig();
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.GetControllerConfig: " + e.Message );
}
}
}
}
This endpoint does not need any parameter.
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
NodeEntity GetNode (string id)
Gets a node in the cluster
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class GetNodeExample
{
public void main()
{
var apiInstance = new ControllerApi();
var id = id_example; // string | The node id.
try
{
// Gets a node in the cluster
NodeEntity result = apiInstance.GetNode(id);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.GetNode: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
id | string | The node id. |
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
RegistryClientEntity GetRegistryClient (string id)
Gets a registry client
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class GetRegistryClientExample
{
public void main()
{
var apiInstance = new ControllerApi();
var id = id_example; // string | The registry id.
try
{
// Gets a registry client
RegistryClientEntity result = apiInstance.GetRegistryClient(id);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.GetRegistryClient: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
id | string | The registry id. |
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
RegistryClientsEntity GetRegistryClients ()
Gets the listing of available registry clients
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class GetRegistryClientsExample
{
public void main()
{
var apiInstance = new ControllerApi();
try
{
// Gets the listing of available registry clients
RegistryClientsEntity result = apiInstance.GetRegistryClients();
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.GetRegistryClients: " + e.Message );
}
}
}
}
This endpoint does not need any parameter.
No authorization required
- Content-Type: /
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ControllerConfigurationEntity UpdateControllerConfig (ControllerConfigurationEntity body)
Retrieves the configuration for this NiFi
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class UpdateControllerConfigExample
{
public void main()
{
var apiInstance = new ControllerApi();
var body = new ControllerConfigurationEntity(); // ControllerConfigurationEntity | The controller configuration.
try
{
// Retrieves the configuration for this NiFi
ControllerConfigurationEntity result = apiInstance.UpdateControllerConfig(body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.UpdateControllerConfig: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
body | ControllerConfigurationEntity | The controller configuration. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
NodeEntity UpdateNode (string id, NodeEntity body)
Updates a node in the cluster
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class UpdateNodeExample
{
public void main()
{
var apiInstance = new ControllerApi();
var id = id_example; // string | The node id.
var body = new NodeEntity(); // NodeEntity | The node configuration. The only configuration that will be honored at this endpoint is the status.
try
{
// Updates a node in the cluster
NodeEntity result = apiInstance.UpdateNode(id, body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.UpdateNode: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
id | string | The node id. | |
body | NodeEntity | The node configuration. The only configuration that will be honored at this endpoint is the status. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
RegistryClientEntity UpdateRegistryClient (string id, RegistryClientEntity body)
Updates a registry client
using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;
namespace Example
{
public class UpdateRegistryClientExample
{
public void main()
{
var apiInstance = new ControllerApi();
var id = id_example; // string | The registry id.
var body = new RegistryClientEntity(); // RegistryClientEntity | The registry configuration details.
try
{
// Updates a registry client
RegistryClientEntity result = apiInstance.UpdateRegistryClient(id, body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ControllerApi.UpdateRegistryClient: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
id | string | The registry id. | |
body | RegistryClientEntity | The registry configuration details. |
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]