Skip to content

Latest commit

 

History

History
258 lines (198 loc) · 7.53 KB

InputPortsApi.md

File metadata and controls

258 lines (198 loc) · 7.53 KB

IO.Swagger.Api.InputPortsApi

All URIs are relative to http://localhost/nifi-api

Method HTTP request Description
GetInputPort GET /input-ports/{id} Gets an input port
RemoveInputPort DELETE /input-ports/{id} Deletes an input port
UpdateInputPort PUT /input-ports/{id} Updates an input port
UpdateRunStatus PUT /input-ports/{id}/run-status Updates run status of an input-port

GetInputPort

PortEntity GetInputPort (string id)

Gets an input port

Example

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class GetInputPortExample
    {
        public void main()
        {
            var apiInstance = new InputPortsApi();
            var id = id_example;  // string | The input port id.

            try
            {
                // Gets an input port
                PortEntity result = apiInstance.GetInputPort(id);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling InputPortsApi.GetInputPort: " + e.Message );
            }
        }
    }
}

Parameters

Name Type Description Notes
id string The input port id.

Return type

PortEntity

Authorization

No authorization required

HTTP request headers

  • Content-Type: /
  • Accept: application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

RemoveInputPort

PortEntity RemoveInputPort (string id, string version = null, string clientId = null, bool? disconnectedNodeAcknowledged = null)

Deletes an input port

Example

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class RemoveInputPortExample
    {
        public void main()
        {
            var apiInstance = new InputPortsApi();
            var id = id_example;  // string | The input port 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 an input port
                PortEntity result = apiInstance.RemoveInputPort(id, version, clientId, disconnectedNodeAcknowledged);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling InputPortsApi.RemoveInputPort: " + e.Message );
            }
        }
    }
}

Parameters

Name Type Description Notes
id string The input port 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]

Return type

PortEntity

Authorization

No authorization required

HTTP request headers

  • Content-Type: /
  • Accept: application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

UpdateInputPort

PortEntity UpdateInputPort (string id, PortEntity body)

Updates an input port

Example

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class UpdateInputPortExample
    {
        public void main()
        {
            var apiInstance = new InputPortsApi();
            var id = id_example;  // string | The input port id.
            var body = new PortEntity(); // PortEntity | The input port configuration details.

            try
            {
                // Updates an input port
                PortEntity result = apiInstance.UpdateInputPort(id, body);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling InputPortsApi.UpdateInputPort: " + e.Message );
            }
        }
    }
}

Parameters

Name Type Description Notes
id string The input port id.
body PortEntity The input port configuration details.

Return type

PortEntity

Authorization

No authorization required

HTTP request headers

  • Content-Type: application/json
  • Accept: application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]

UpdateRunStatus

ProcessorEntity UpdateRunStatus (string id, PortRunStatusEntity body)

Updates run status of an input-port

Example

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class UpdateRunStatusExample
    {
        public void main()
        {
            var apiInstance = new InputPortsApi();
            var id = id_example;  // string | The port id.
            var body = new PortRunStatusEntity(); // PortRunStatusEntity | The port run status.

            try
            {
                // Updates run status of an input-port
                ProcessorEntity result = apiInstance.UpdateRunStatus(id, body);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling InputPortsApi.UpdateRunStatus: " + e.Message );
            }
        }
    }
}

Parameters

Name Type Description Notes
id string The port id.
body PortRunStatusEntity The port run status.

Return type

ProcessorEntity

Authorization

No authorization required

HTTP request headers

  • Content-Type: application/json
  • Accept: application/json

[Back to top] [Back to API list] [Back to Model list] [Back to README]