NiFi Swagger Client
Subpackages
- nipyapi.nifi.apis package
- Submodules
- nipyapi.nifi.apis.access_api module
AccessApi
AccessApi.create_access_token()
AccessApi.create_access_token_from_ticket()
AccessApi.create_access_token_from_ticket_with_http_info()
AccessApi.create_access_token_with_http_info()
AccessApi.get_access_status()
AccessApi.get_access_status_with_http_info()
AccessApi.get_access_token_expiration()
AccessApi.get_access_token_expiration_with_http_info()
AccessApi.get_login_config()
AccessApi.get_login_config_with_http_info()
AccessApi.knox_callback()
AccessApi.knox_callback_with_http_info()
AccessApi.knox_logout()
AccessApi.knox_logout_with_http_info()
AccessApi.knox_request()
AccessApi.knox_request_with_http_info()
AccessApi.log_out()
AccessApi.log_out_complete()
AccessApi.log_out_complete_with_http_info()
AccessApi.log_out_with_http_info()
- nipyapi.nifi.apis.connections_api module
- nipyapi.nifi.apis.controller_api module
ControllerApi
ControllerApi.create_bulletin()
ControllerApi.create_bulletin_with_http_info()
ControllerApi.create_controller_service()
ControllerApi.create_controller_service_with_http_info()
ControllerApi.create_flow_registry_client()
ControllerApi.create_flow_registry_client_with_http_info()
ControllerApi.create_parameter_provider()
ControllerApi.create_parameter_provider_with_http_info()
ControllerApi.create_reporting_task()
ControllerApi.create_reporting_task_with_http_info()
ControllerApi.delete_flow_registry_client()
ControllerApi.delete_flow_registry_client_with_http_info()
ControllerApi.delete_history()
ControllerApi.delete_history_with_http_info()
ControllerApi.delete_node()
ControllerApi.delete_node_with_http_info()
ControllerApi.get_cluster()
ControllerApi.get_cluster_with_http_info()
ControllerApi.get_controller_config()
ControllerApi.get_controller_config_with_http_info()
ControllerApi.get_flow_registry_client()
ControllerApi.get_flow_registry_client_with_http_info()
ControllerApi.get_flow_registry_clients()
ControllerApi.get_flow_registry_clients_with_http_info()
ControllerApi.get_node()
ControllerApi.get_node_status_history()
ControllerApi.get_node_status_history_with_http_info()
ControllerApi.get_node_with_http_info()
ControllerApi.get_property_descriptor()
ControllerApi.get_property_descriptor_with_http_info()
ControllerApi.get_registry_client_types()
ControllerApi.get_registry_client_types_with_http_info()
ControllerApi.update_controller_config()
ControllerApi.update_controller_config_with_http_info()
ControllerApi.update_flow_registry_client()
ControllerApi.update_flow_registry_client_with_http_info()
ControllerApi.update_node()
ControllerApi.update_node_with_http_info()
- nipyapi.nifi.apis.controller_services_api module
ControllerServicesApi
ControllerServicesApi.analyze_configuration()
ControllerServicesApi.analyze_configuration_with_http_info()
ControllerServicesApi.clear_state()
ControllerServicesApi.clear_state_with_http_info()
ControllerServicesApi.delete_verification_request()
ControllerServicesApi.delete_verification_request_with_http_info()
ControllerServicesApi.get_controller_service()
ControllerServicesApi.get_controller_service_references()
ControllerServicesApi.get_controller_service_references_with_http_info()
ControllerServicesApi.get_controller_service_with_http_info()
ControllerServicesApi.get_property_descriptor()
ControllerServicesApi.get_property_descriptor_with_http_info()
ControllerServicesApi.get_state()
ControllerServicesApi.get_state_with_http_info()
ControllerServicesApi.get_verification_request()
ControllerServicesApi.get_verification_request_with_http_info()
ControllerServicesApi.remove_controller_service()
ControllerServicesApi.remove_controller_service_with_http_info()
ControllerServicesApi.submit_config_verification_request()
ControllerServicesApi.submit_config_verification_request_with_http_info()
ControllerServicesApi.update_controller_service()
ControllerServicesApi.update_controller_service_references()
ControllerServicesApi.update_controller_service_references_with_http_info()
ControllerServicesApi.update_controller_service_with_http_info()
ControllerServicesApi.update_run_status()
ControllerServicesApi.update_run_status_with_http_info()
- nipyapi.nifi.apis.counters_api module
- nipyapi.nifi.apis.data_transfer_api module
DataTransferApi
DataTransferApi.commit_input_port_transaction()
DataTransferApi.commit_input_port_transaction_with_http_info()
DataTransferApi.commit_output_port_transaction()
DataTransferApi.commit_output_port_transaction_with_http_info()
DataTransferApi.create_port_transaction()
DataTransferApi.create_port_transaction_with_http_info()
DataTransferApi.extend_input_port_transaction_ttl()
DataTransferApi.extend_input_port_transaction_ttl_with_http_info()
DataTransferApi.extend_output_port_transaction_ttl()
DataTransferApi.extend_output_port_transaction_ttl_with_http_info()
DataTransferApi.receive_flow_files()
DataTransferApi.receive_flow_files_with_http_info()
DataTransferApi.transfer_flow_files()
DataTransferApi.transfer_flow_files_with_http_info()
- nipyapi.nifi.apis.flow_api module
FlowApi
FlowApi.activate_controller_services()
FlowApi.activate_controller_services_with_http_info()
FlowApi.generate_client_id()
FlowApi.generate_client_id_with_http_info()
FlowApi.get_about_info()
FlowApi.get_about_info_with_http_info()
FlowApi.get_action()
FlowApi.get_action_with_http_info()
FlowApi.get_banners()
FlowApi.get_banners_with_http_info()
FlowApi.get_buckets()
FlowApi.get_buckets_with_http_info()
FlowApi.get_bulletin_board()
FlowApi.get_bulletin_board_with_http_info()
FlowApi.get_bulletins()
FlowApi.get_bulletins_with_http_info()
FlowApi.get_cluster_summary()
FlowApi.get_cluster_summary_with_http_info()
FlowApi.get_component_history()
FlowApi.get_component_history_with_http_info()
FlowApi.get_connection_statistics()
FlowApi.get_connection_statistics_with_http_info()
FlowApi.get_connection_status()
FlowApi.get_connection_status_history()
FlowApi.get_connection_status_history_with_http_info()
FlowApi.get_connection_status_with_http_info()
FlowApi.get_controller_service_types()
FlowApi.get_controller_service_types_with_http_info()
FlowApi.get_controller_services_from_controller()
FlowApi.get_controller_services_from_controller_with_http_info()
FlowApi.get_controller_services_from_group()
FlowApi.get_controller_services_from_group_with_http_info()
FlowApi.get_controller_status()
FlowApi.get_controller_status_with_http_info()
FlowApi.get_current_user()
FlowApi.get_current_user_with_http_info()
FlowApi.get_details()
FlowApi.get_details_with_http_info()
FlowApi.get_flow()
FlowApi.get_flow_config()
FlowApi.get_flow_config_with_http_info()
FlowApi.get_flow_metrics()
FlowApi.get_flow_metrics_with_http_info()
FlowApi.get_flow_with_http_info()
FlowApi.get_flows()
FlowApi.get_flows_with_http_info()
FlowApi.get_input_port_status()
FlowApi.get_input_port_status_with_http_info()
FlowApi.get_output_port_status()
FlowApi.get_output_port_status_with_http_info()
FlowApi.get_parameter_contexts()
FlowApi.get_parameter_contexts_with_http_info()
FlowApi.get_parameter_provider_types()
FlowApi.get_parameter_provider_types_with_http_info()
FlowApi.get_parameter_providers()
FlowApi.get_parameter_providers_with_http_info()
FlowApi.get_prioritizers()
FlowApi.get_prioritizers_with_http_info()
FlowApi.get_process_group_status()
FlowApi.get_process_group_status_history()
FlowApi.get_process_group_status_history_with_http_info()
FlowApi.get_process_group_status_with_http_info()
FlowApi.get_processor_status()
FlowApi.get_processor_status_history()
FlowApi.get_processor_status_history_with_http_info()
FlowApi.get_processor_status_with_http_info()
FlowApi.get_processor_types()
FlowApi.get_processor_types_with_http_info()
FlowApi.get_registry_clients()
FlowApi.get_registry_clients_with_http_info()
FlowApi.get_remote_process_group_status()
FlowApi.get_remote_process_group_status_history()
FlowApi.get_remote_process_group_status_history_with_http_info()
FlowApi.get_remote_process_group_status_with_http_info()
FlowApi.get_reporting_task_types()
FlowApi.get_reporting_task_types_with_http_info()
FlowApi.get_reporting_tasks()
FlowApi.get_reporting_tasks_with_http_info()
FlowApi.get_runtime_manifest()
FlowApi.get_runtime_manifest_with_http_info()
FlowApi.get_templates()
FlowApi.get_templates_with_http_info()
FlowApi.get_versions()
FlowApi.get_versions_with_http_info()
FlowApi.query_history()
FlowApi.query_history_with_http_info()
FlowApi.schedule_components()
FlowApi.schedule_components_with_http_info()
FlowApi.search_cluster()
FlowApi.search_cluster_with_http_info()
FlowApi.search_flow()
FlowApi.search_flow_with_http_info()
- nipyapi.nifi.apis.flowfile_queues_api module
FlowfileQueuesApi
FlowfileQueuesApi.create_drop_request()
FlowfileQueuesApi.create_drop_request_with_http_info()
FlowfileQueuesApi.create_flow_file_listing()
FlowfileQueuesApi.create_flow_file_listing_with_http_info()
FlowfileQueuesApi.delete_listing_request()
FlowfileQueuesApi.delete_listing_request_with_http_info()
FlowfileQueuesApi.download_flow_file_content()
FlowfileQueuesApi.download_flow_file_content_with_http_info()
FlowfileQueuesApi.get_drop_request()
FlowfileQueuesApi.get_drop_request_with_http_info()
FlowfileQueuesApi.get_flow_file()
FlowfileQueuesApi.get_flow_file_with_http_info()
FlowfileQueuesApi.get_listing_request()
FlowfileQueuesApi.get_listing_request_with_http_info()
FlowfileQueuesApi.remove_drop_request()
FlowfileQueuesApi.remove_drop_request_with_http_info()
- nipyapi.nifi.apis.funnel_api module
- nipyapi.nifi.apis.input_ports_api module
InputPortsApi
InputPortsApi.get_input_port()
InputPortsApi.get_input_port_with_http_info()
InputPortsApi.remove_input_port()
InputPortsApi.remove_input_port_with_http_info()
InputPortsApi.update_input_port()
InputPortsApi.update_input_port_with_http_info()
InputPortsApi.update_run_status()
InputPortsApi.update_run_status_with_http_info()
- nipyapi.nifi.apis.labels_api module
- nipyapi.nifi.apis.output_ports_api module
OutputPortsApi
OutputPortsApi.get_output_port()
OutputPortsApi.get_output_port_with_http_info()
OutputPortsApi.remove_output_port()
OutputPortsApi.remove_output_port_with_http_info()
OutputPortsApi.update_output_port()
OutputPortsApi.update_output_port_with_http_info()
OutputPortsApi.update_run_status()
OutputPortsApi.update_run_status_with_http_info()
- nipyapi.nifi.apis.parameter_contexts_api module
ParameterContextsApi
ParameterContextsApi.create_parameter_context()
ParameterContextsApi.create_parameter_context_with_http_info()
ParameterContextsApi.delete_parameter_context()
ParameterContextsApi.delete_parameter_context_with_http_info()
ParameterContextsApi.delete_update_request()
ParameterContextsApi.delete_update_request_with_http_info()
ParameterContextsApi.delete_validation_request()
ParameterContextsApi.delete_validation_request_with_http_info()
ParameterContextsApi.get_parameter_context()
ParameterContextsApi.get_parameter_context_update()
ParameterContextsApi.get_parameter_context_update_with_http_info()
ParameterContextsApi.get_parameter_context_with_http_info()
ParameterContextsApi.get_validation_request()
ParameterContextsApi.get_validation_request_with_http_info()
ParameterContextsApi.submit_parameter_context_update()
ParameterContextsApi.submit_parameter_context_update_with_http_info()
ParameterContextsApi.submit_validation_request()
ParameterContextsApi.submit_validation_request_with_http_info()
ParameterContextsApi.update_parameter_context()
ParameterContextsApi.update_parameter_context_with_http_info()
- nipyapi.nifi.apis.policies_api module
PoliciesApi
PoliciesApi.create_access_policy()
PoliciesApi.create_access_policy_with_http_info()
PoliciesApi.get_access_policy()
PoliciesApi.get_access_policy_for_resource()
PoliciesApi.get_access_policy_for_resource_with_http_info()
PoliciesApi.get_access_policy_with_http_info()
PoliciesApi.remove_access_policy()
PoliciesApi.remove_access_policy_with_http_info()
PoliciesApi.update_access_policy()
PoliciesApi.update_access_policy_with_http_info()
- nipyapi.nifi.apis.process_groups_api module
ProcessGroupsApi
ProcessGroupsApi.copy_snippet()
ProcessGroupsApi.copy_snippet_with_http_info()
ProcessGroupsApi.create_connection()
ProcessGroupsApi.create_connection_with_http_info()
ProcessGroupsApi.create_controller_service()
ProcessGroupsApi.create_controller_service_with_http_info()
ProcessGroupsApi.create_empty_all_connections_request()
ProcessGroupsApi.create_empty_all_connections_request_with_http_info()
ProcessGroupsApi.create_funnel()
ProcessGroupsApi.create_funnel_with_http_info()
ProcessGroupsApi.create_input_port()
ProcessGroupsApi.create_input_port_with_http_info()
ProcessGroupsApi.create_label()
ProcessGroupsApi.create_label_with_http_info()
ProcessGroupsApi.create_output_port()
ProcessGroupsApi.create_output_port_with_http_info()
ProcessGroupsApi.create_process_group()
ProcessGroupsApi.create_process_group_with_http_info()
ProcessGroupsApi.create_processor()
ProcessGroupsApi.create_processor_with_http_info()
ProcessGroupsApi.create_remote_process_group()
ProcessGroupsApi.create_remote_process_group_with_http_info()
ProcessGroupsApi.create_template()
ProcessGroupsApi.create_template_with_http_info()
ProcessGroupsApi.delete_replace_process_group_request()
ProcessGroupsApi.delete_replace_process_group_request_with_http_info()
ProcessGroupsApi.delete_variable_registry_update_request()
ProcessGroupsApi.delete_variable_registry_update_request_with_http_info()
ProcessGroupsApi.export_process_group()
ProcessGroupsApi.export_process_group_with_http_info()
ProcessGroupsApi.get_connections()
ProcessGroupsApi.get_connections_with_http_info()
ProcessGroupsApi.get_drop_all_flowfiles_request()
ProcessGroupsApi.get_drop_all_flowfiles_request_with_http_info()
ProcessGroupsApi.get_funnels()
ProcessGroupsApi.get_funnels_with_http_info()
ProcessGroupsApi.get_input_ports()
ProcessGroupsApi.get_input_ports_with_http_info()
ProcessGroupsApi.get_labels()
ProcessGroupsApi.get_labels_with_http_info()
ProcessGroupsApi.get_local_modifications()
ProcessGroupsApi.get_local_modifications_with_http_info()
ProcessGroupsApi.get_output_ports()
ProcessGroupsApi.get_output_ports_with_http_info()
ProcessGroupsApi.get_process_group()
ProcessGroupsApi.get_process_group_with_http_info()
ProcessGroupsApi.get_process_groups()
ProcessGroupsApi.get_process_groups_with_http_info()
ProcessGroupsApi.get_processors()
ProcessGroupsApi.get_processors_with_http_info()
ProcessGroupsApi.get_remote_process_groups()
ProcessGroupsApi.get_remote_process_groups_with_http_info()
ProcessGroupsApi.get_replace_process_group_request()
ProcessGroupsApi.get_replace_process_group_request_with_http_info()
ProcessGroupsApi.get_variable_registry()
ProcessGroupsApi.get_variable_registry_update_request()
ProcessGroupsApi.get_variable_registry_update_request_with_http_info()
ProcessGroupsApi.get_variable_registry_with_http_info()
ProcessGroupsApi.import_process_group()
ProcessGroupsApi.import_process_group_with_http_info()
ProcessGroupsApi.import_template()
ProcessGroupsApi.import_template_with_http_info()
ProcessGroupsApi.initiate_replace_process_group()
ProcessGroupsApi.initiate_replace_process_group_with_http_info()
ProcessGroupsApi.instantiate_template()
ProcessGroupsApi.instantiate_template_with_http_info()
ProcessGroupsApi.remove_drop_request()
ProcessGroupsApi.remove_drop_request_with_http_info()
ProcessGroupsApi.remove_process_group()
ProcessGroupsApi.remove_process_group_with_http_info()
ProcessGroupsApi.replace_process_group()
ProcessGroupsApi.replace_process_group_with_http_info()
ProcessGroupsApi.submit_update_variable_registry_request()
ProcessGroupsApi.submit_update_variable_registry_request_with_http_info()
ProcessGroupsApi.update_process_group()
ProcessGroupsApi.update_process_group_with_http_info()
ProcessGroupsApi.update_variable_registry()
ProcessGroupsApi.update_variable_registry_with_http_info()
ProcessGroupsApi.upload_process_group()
ProcessGroupsApi.upload_process_group_with_http_info()
ProcessGroupsApi.upload_template()
ProcessGroupsApi.upload_template_with_http_info()
- nipyapi.nifi.apis.processors_api module
ProcessorsApi
ProcessorsApi.analyze_configuration()
ProcessorsApi.analyze_configuration_with_http_info()
ProcessorsApi.clear_state()
ProcessorsApi.clear_state_with_http_info()
ProcessorsApi.delete_processor()
ProcessorsApi.delete_processor_with_http_info()
ProcessorsApi.delete_verification_request()
ProcessorsApi.delete_verification_request_with_http_info()
ProcessorsApi.get_processor()
ProcessorsApi.get_processor_diagnostics()
ProcessorsApi.get_processor_diagnostics_with_http_info()
ProcessorsApi.get_processor_run_status_details()
ProcessorsApi.get_processor_run_status_details_with_http_info()
ProcessorsApi.get_processor_with_http_info()
ProcessorsApi.get_property_descriptor()
ProcessorsApi.get_property_descriptor_with_http_info()
ProcessorsApi.get_state()
ProcessorsApi.get_state_with_http_info()
ProcessorsApi.get_verification_request()
ProcessorsApi.get_verification_request_with_http_info()
ProcessorsApi.submit_processor_verification_request()
ProcessorsApi.submit_processor_verification_request_with_http_info()
ProcessorsApi.terminate_processor()
ProcessorsApi.terminate_processor_with_http_info()
ProcessorsApi.update_processor()
ProcessorsApi.update_processor_with_http_info()
ProcessorsApi.update_run_status()
ProcessorsApi.update_run_status_with_http_info()
- nipyapi.nifi.apis.provenance_api module
ProvenanceApi
ProvenanceApi.delete_lineage()
ProvenanceApi.delete_lineage_with_http_info()
ProvenanceApi.delete_provenance()
ProvenanceApi.delete_provenance_with_http_info()
ProvenanceApi.get_lineage()
ProvenanceApi.get_lineage_with_http_info()
ProvenanceApi.get_provenance()
ProvenanceApi.get_provenance_with_http_info()
ProvenanceApi.get_search_options()
ProvenanceApi.get_search_options_with_http_info()
ProvenanceApi.submit_lineage_request()
ProvenanceApi.submit_lineage_request_with_http_info()
ProvenanceApi.submit_provenance_request()
ProvenanceApi.submit_provenance_request_with_http_info()
- nipyapi.nifi.apis.provenance_events_api module
ProvenanceEventsApi
ProvenanceEventsApi.get_input_content()
ProvenanceEventsApi.get_input_content_with_http_info()
ProvenanceEventsApi.get_output_content()
ProvenanceEventsApi.get_output_content_with_http_info()
ProvenanceEventsApi.get_provenance_event()
ProvenanceEventsApi.get_provenance_event_with_http_info()
ProvenanceEventsApi.submit_replay()
ProvenanceEventsApi.submit_replay_latest_event()
ProvenanceEventsApi.submit_replay_latest_event_with_http_info()
ProvenanceEventsApi.submit_replay_with_http_info()
- nipyapi.nifi.apis.remote_process_groups_api module
RemoteProcessGroupsApi
RemoteProcessGroupsApi.get_remote_process_group()
RemoteProcessGroupsApi.get_remote_process_group_with_http_info()
RemoteProcessGroupsApi.get_state()
RemoteProcessGroupsApi.get_state_with_http_info()
RemoteProcessGroupsApi.remove_remote_process_group()
RemoteProcessGroupsApi.remove_remote_process_group_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group()
RemoteProcessGroupsApi.update_remote_process_group_input_port()
RemoteProcessGroupsApi.update_remote_process_group_input_port_run_status()
RemoteProcessGroupsApi.update_remote_process_group_input_port_run_status_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group_input_port_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group_output_port()
RemoteProcessGroupsApi.update_remote_process_group_output_port_run_status()
RemoteProcessGroupsApi.update_remote_process_group_output_port_run_status_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group_output_port_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group_run_status()
RemoteProcessGroupsApi.update_remote_process_group_run_status_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group_run_statuses()
RemoteProcessGroupsApi.update_remote_process_group_run_statuses_with_http_info()
RemoteProcessGroupsApi.update_remote_process_group_with_http_info()
- nipyapi.nifi.apis.reporting_tasks_api module
ReportingTasksApi
ReportingTasksApi.analyze_configuration()
ReportingTasksApi.analyze_configuration_with_http_info()
ReportingTasksApi.clear_state()
ReportingTasksApi.clear_state_with_http_info()
ReportingTasksApi.delete_verification_request()
ReportingTasksApi.delete_verification_request_with_http_info()
ReportingTasksApi.get_property_descriptor()
ReportingTasksApi.get_property_descriptor_with_http_info()
ReportingTasksApi.get_reporting_task()
ReportingTasksApi.get_reporting_task_with_http_info()
ReportingTasksApi.get_state()
ReportingTasksApi.get_state_with_http_info()
ReportingTasksApi.get_verification_request()
ReportingTasksApi.get_verification_request_with_http_info()
ReportingTasksApi.remove_reporting_task()
ReportingTasksApi.remove_reporting_task_with_http_info()
ReportingTasksApi.submit_config_verification_request()
ReportingTasksApi.submit_config_verification_request_with_http_info()
ReportingTasksApi.update_reporting_task()
ReportingTasksApi.update_reporting_task_with_http_info()
ReportingTasksApi.update_run_status()
ReportingTasksApi.update_run_status_with_http_info()
- nipyapi.nifi.apis.resources_api module
- nipyapi.nifi.apis.site_to_site_api module
- nipyapi.nifi.apis.snippets_api module
- nipyapi.nifi.apis.system_diagnostics_api module
- nipyapi.nifi.apis.templates_api module
- nipyapi.nifi.apis.tenants_api module
TenantsApi
TenantsApi.create_user()
TenantsApi.create_user_group()
TenantsApi.create_user_group_with_http_info()
TenantsApi.create_user_with_http_info()
TenantsApi.get_user()
TenantsApi.get_user_group()
TenantsApi.get_user_group_with_http_info()
TenantsApi.get_user_groups()
TenantsApi.get_user_groups_with_http_info()
TenantsApi.get_user_with_http_info()
TenantsApi.get_users()
TenantsApi.get_users_with_http_info()
TenantsApi.remove_user()
TenantsApi.remove_user_group()
TenantsApi.remove_user_group_with_http_info()
TenantsApi.remove_user_with_http_info()
TenantsApi.search_tenants()
TenantsApi.search_tenants_with_http_info()
TenantsApi.update_user()
TenantsApi.update_user_group()
TenantsApi.update_user_group_with_http_info()
TenantsApi.update_user_with_http_info()
- nipyapi.nifi.apis.versions_api module
VersionsApi
VersionsApi.create_version_control_request()
VersionsApi.create_version_control_request_with_http_info()
VersionsApi.delete_revert_request()
VersionsApi.delete_revert_request_with_http_info()
VersionsApi.delete_update_request()
VersionsApi.delete_update_request_with_http_info()
VersionsApi.delete_version_control_request()
VersionsApi.delete_version_control_request_with_http_info()
VersionsApi.export_flow_version()
VersionsApi.export_flow_version_with_http_info()
VersionsApi.get_revert_request()
VersionsApi.get_revert_request_with_http_info()
VersionsApi.get_update_request()
VersionsApi.get_update_request_with_http_info()
VersionsApi.get_version_information()
VersionsApi.get_version_information_with_http_info()
VersionsApi.initiate_revert_flow_version()
VersionsApi.initiate_revert_flow_version_with_http_info()
VersionsApi.initiate_version_control_update()
VersionsApi.initiate_version_control_update_with_http_info()
VersionsApi.save_to_flow_registry()
VersionsApi.save_to_flow_registry_with_http_info()
VersionsApi.stop_version_control()
VersionsApi.stop_version_control_with_http_info()
VersionsApi.update_flow_version()
VersionsApi.update_flow_version_with_http_info()
VersionsApi.update_version_control_request()
VersionsApi.update_version_control_request_with_http_info()
- nipyapi.nifi.models package
- Submodules
- nipyapi.nifi.models.about_dto module
- nipyapi.nifi.models.about_entity module
- nipyapi.nifi.models.access_configuration_dto module
- nipyapi.nifi.models.access_configuration_entity module
- nipyapi.nifi.models.access_policy_dto module
AccessPolicyDTO
AccessPolicyDTO.action
AccessPolicyDTO.attribute_map
AccessPolicyDTO.component_reference
AccessPolicyDTO.configurable
AccessPolicyDTO.id
AccessPolicyDTO.parent_group_id
AccessPolicyDTO.position
AccessPolicyDTO.resource
AccessPolicyDTO.swagger_types
AccessPolicyDTO.to_dict()
AccessPolicyDTO.to_str()
AccessPolicyDTO.user_groups
AccessPolicyDTO.users
AccessPolicyDTO.versioned_component_id
- nipyapi.nifi.models.access_policy_entity module
AccessPolicyEntity
AccessPolicyEntity.attribute_map
AccessPolicyEntity.bulletins
AccessPolicyEntity.component
AccessPolicyEntity.disconnected_node_acknowledged
AccessPolicyEntity.generated
AccessPolicyEntity.id
AccessPolicyEntity.permissions
AccessPolicyEntity.position
AccessPolicyEntity.revision
AccessPolicyEntity.swagger_types
AccessPolicyEntity.to_dict()
AccessPolicyEntity.to_str()
AccessPolicyEntity.uri
- nipyapi.nifi.models.access_policy_summary_dto module
AccessPolicySummaryDTO
AccessPolicySummaryDTO.action
AccessPolicySummaryDTO.attribute_map
AccessPolicySummaryDTO.component_reference
AccessPolicySummaryDTO.configurable
AccessPolicySummaryDTO.id
AccessPolicySummaryDTO.parent_group_id
AccessPolicySummaryDTO.position
AccessPolicySummaryDTO.resource
AccessPolicySummaryDTO.swagger_types
AccessPolicySummaryDTO.to_dict()
AccessPolicySummaryDTO.to_str()
AccessPolicySummaryDTO.versioned_component_id
- nipyapi.nifi.models.access_policy_summary_entity module
AccessPolicySummaryEntity
AccessPolicySummaryEntity.attribute_map
AccessPolicySummaryEntity.bulletins
AccessPolicySummaryEntity.component
AccessPolicySummaryEntity.disconnected_node_acknowledged
AccessPolicySummaryEntity.id
AccessPolicySummaryEntity.permissions
AccessPolicySummaryEntity.position
AccessPolicySummaryEntity.revision
AccessPolicySummaryEntity.swagger_types
AccessPolicySummaryEntity.to_dict()
AccessPolicySummaryEntity.to_str()
AccessPolicySummaryEntity.uri
- nipyapi.nifi.models.access_status_dto module
- nipyapi.nifi.models.access_status_entity module
- nipyapi.nifi.models.action_details_dto module
- nipyapi.nifi.models.action_dto module
- nipyapi.nifi.models.action_entity module
- nipyapi.nifi.models.activate_controller_services_entity module
ActivateControllerServicesEntity
ActivateControllerServicesEntity.attribute_map
ActivateControllerServicesEntity.components
ActivateControllerServicesEntity.disconnected_node_acknowledged
ActivateControllerServicesEntity.id
ActivateControllerServicesEntity.state
ActivateControllerServicesEntity.swagger_types
ActivateControllerServicesEntity.to_dict()
ActivateControllerServicesEntity.to_str()
- nipyapi.nifi.models.affected_component_dto module
AffectedComponentDTO
AffectedComponentDTO.active_thread_count
AffectedComponentDTO.attribute_map
AffectedComponentDTO.id
AffectedComponentDTO.name
AffectedComponentDTO.process_group_id
AffectedComponentDTO.reference_type
AffectedComponentDTO.state
AffectedComponentDTO.swagger_types
AffectedComponentDTO.to_dict()
AffectedComponentDTO.to_str()
AffectedComponentDTO.validation_errors
- nipyapi.nifi.models.affected_component_entity module
AffectedComponentEntity
AffectedComponentEntity.attribute_map
AffectedComponentEntity.bulletins
AffectedComponentEntity.component
AffectedComponentEntity.disconnected_node_acknowledged
AffectedComponentEntity.id
AffectedComponentEntity.permissions
AffectedComponentEntity.position
AffectedComponentEntity.process_group
AffectedComponentEntity.reference_type
AffectedComponentEntity.revision
AffectedComponentEntity.swagger_types
AffectedComponentEntity.to_dict()
AffectedComponentEntity.to_str()
AffectedComponentEntity.uri
- nipyapi.nifi.models.allowable_value_dto module
- nipyapi.nifi.models.allowable_value_entity module
- nipyapi.nifi.models.attribute_dto module
- nipyapi.nifi.models.banner_dto module
- nipyapi.nifi.models.banner_entity module
- nipyapi.nifi.models.batch_settings_dto module
- nipyapi.nifi.models.batch_size module
- nipyapi.nifi.models.bucket module
- nipyapi.nifi.models.bucket_dto module
- nipyapi.nifi.models.bucket_entity module
- nipyapi.nifi.models.buckets_entity module
- nipyapi.nifi.models.bulletin_board_dto module
- nipyapi.nifi.models.bulletin_board_entity module
- nipyapi.nifi.models.bulletin_dto module
- nipyapi.nifi.models.bulletin_entity module
- nipyapi.nifi.models.bundle module
- nipyapi.nifi.models.bundle_dto module
- nipyapi.nifi.models.cluste_summary_entity module
- nipyapi.nifi.models.cluster_dto module
- nipyapi.nifi.models.cluster_entity module
- nipyapi.nifi.models.cluster_search_results_entity module
- nipyapi.nifi.models.cluster_summary_dto module
- nipyapi.nifi.models.component_details_dto module
- nipyapi.nifi.models.component_difference_dto module
ComponentDifferenceDTO
ComponentDifferenceDTO.attribute_map
ComponentDifferenceDTO.component_id
ComponentDifferenceDTO.component_name
ComponentDifferenceDTO.component_type
ComponentDifferenceDTO.differences
ComponentDifferenceDTO.process_group_id
ComponentDifferenceDTO.swagger_types
ComponentDifferenceDTO.to_dict()
ComponentDifferenceDTO.to_str()
- nipyapi.nifi.models.component_history_dto module
- nipyapi.nifi.models.component_history_entity module
- nipyapi.nifi.models.component_reference_dto module
ComponentReferenceDTO
ComponentReferenceDTO.attribute_map
ComponentReferenceDTO.id
ComponentReferenceDTO.name
ComponentReferenceDTO.parent_group_id
ComponentReferenceDTO.position
ComponentReferenceDTO.swagger_types
ComponentReferenceDTO.to_dict()
ComponentReferenceDTO.to_str()
ComponentReferenceDTO.versioned_component_id
- nipyapi.nifi.models.component_reference_entity module
ComponentReferenceEntity
ComponentReferenceEntity.attribute_map
ComponentReferenceEntity.bulletins
ComponentReferenceEntity.component
ComponentReferenceEntity.disconnected_node_acknowledged
ComponentReferenceEntity.id
ComponentReferenceEntity.parent_group_id
ComponentReferenceEntity.permissions
ComponentReferenceEntity.position
ComponentReferenceEntity.revision
ComponentReferenceEntity.swagger_types
ComponentReferenceEntity.to_dict()
ComponentReferenceEntity.to_str()
ComponentReferenceEntity.uri
- nipyapi.nifi.models.component_search_result_dto module
ComponentSearchResultDTO
ComponentSearchResultDTO.attribute_map
ComponentSearchResultDTO.group_id
ComponentSearchResultDTO.id
ComponentSearchResultDTO.matches
ComponentSearchResultDTO.name
ComponentSearchResultDTO.parent_group
ComponentSearchResultDTO.swagger_types
ComponentSearchResultDTO.to_dict()
ComponentSearchResultDTO.to_str()
ComponentSearchResultDTO.versioned_group
- nipyapi.nifi.models.component_state_dto module
- nipyapi.nifi.models.component_state_entity module
- nipyapi.nifi.models.connectable_component module
ConnectableComponent
ConnectableComponent.attribute_map
ConnectableComponent.comments
ConnectableComponent.group_id
ConnectableComponent.id
ConnectableComponent.instance_identifier
ConnectableComponent.name
ConnectableComponent.swagger_types
ConnectableComponent.to_dict()
ConnectableComponent.to_str()
ConnectableComponent.type
- nipyapi.nifi.models.connectable_dto module
ConnectableDTO
ConnectableDTO.attribute_map
ConnectableDTO.comments
ConnectableDTO.exists
ConnectableDTO.group_id
ConnectableDTO.id
ConnectableDTO.name
ConnectableDTO.running
ConnectableDTO.swagger_types
ConnectableDTO.to_dict()
ConnectableDTO.to_str()
ConnectableDTO.transmitting
ConnectableDTO.type
ConnectableDTO.versioned_component_id
- nipyapi.nifi.models.connection_dto module
ConnectionDTO
ConnectionDTO.attribute_map
ConnectionDTO.available_relationships
ConnectionDTO.back_pressure_data_size_threshold
ConnectionDTO.back_pressure_object_threshold
ConnectionDTO.bends
ConnectionDTO.destination
ConnectionDTO.flow_file_expiration
ConnectionDTO.getz_index
ConnectionDTO.id
ConnectionDTO.label_index
ConnectionDTO.load_balance_compression
ConnectionDTO.load_balance_partition_attribute
ConnectionDTO.load_balance_status
ConnectionDTO.load_balance_strategy
ConnectionDTO.name
ConnectionDTO.parent_group_id
ConnectionDTO.position
ConnectionDTO.prioritizers
ConnectionDTO.selected_relationships
ConnectionDTO.source
ConnectionDTO.swagger_types
ConnectionDTO.to_dict()
ConnectionDTO.to_str()
ConnectionDTO.versioned_component_id
- nipyapi.nifi.models.connection_entity module
ConnectionEntity
ConnectionEntity.attribute_map
ConnectionEntity.bends
ConnectionEntity.bulletins
ConnectionEntity.component
ConnectionEntity.destination_group_id
ConnectionEntity.destination_id
ConnectionEntity.destination_type
ConnectionEntity.disconnected_node_acknowledged
ConnectionEntity.getz_index
ConnectionEntity.id
ConnectionEntity.label_index
ConnectionEntity.permissions
ConnectionEntity.position
ConnectionEntity.revision
ConnectionEntity.source_group_id
ConnectionEntity.source_id
ConnectionEntity.source_type
ConnectionEntity.status
ConnectionEntity.swagger_types
ConnectionEntity.to_dict()
ConnectionEntity.to_str()
ConnectionEntity.uri
- nipyapi.nifi.models.connection_status_dto module
ConnectionStatusDTO
ConnectionStatusDTO.aggregate_snapshot
ConnectionStatusDTO.attribute_map
ConnectionStatusDTO.destination_id
ConnectionStatusDTO.destination_name
ConnectionStatusDTO.group_id
ConnectionStatusDTO.id
ConnectionStatusDTO.name
ConnectionStatusDTO.node_snapshots
ConnectionStatusDTO.source_id
ConnectionStatusDTO.source_name
ConnectionStatusDTO.stats_last_refreshed
ConnectionStatusDTO.swagger_types
ConnectionStatusDTO.to_dict()
ConnectionStatusDTO.to_str()
- nipyapi.nifi.models.connection_status_entity module
- nipyapi.nifi.models.connection_status_snapshot_dto module
ConnectionStatusSnapshotDTO
ConnectionStatusSnapshotDTO.attribute_map
ConnectionStatusSnapshotDTO.bytes_in
ConnectionStatusSnapshotDTO.bytes_out
ConnectionStatusSnapshotDTO.bytes_queued
ConnectionStatusSnapshotDTO.destination_id
ConnectionStatusSnapshotDTO.destination_name
ConnectionStatusSnapshotDTO.flow_file_availability
ConnectionStatusSnapshotDTO.flow_files_in
ConnectionStatusSnapshotDTO.flow_files_out
ConnectionStatusSnapshotDTO.flow_files_queued
ConnectionStatusSnapshotDTO.group_id
ConnectionStatusSnapshotDTO.id
ConnectionStatusSnapshotDTO.input
ConnectionStatusSnapshotDTO.name
ConnectionStatusSnapshotDTO.output
ConnectionStatusSnapshotDTO.percent_use_bytes
ConnectionStatusSnapshotDTO.percent_use_count
ConnectionStatusSnapshotDTO.predictions
ConnectionStatusSnapshotDTO.queued
ConnectionStatusSnapshotDTO.queued_count
ConnectionStatusSnapshotDTO.queued_size
ConnectionStatusSnapshotDTO.source_id
ConnectionStatusSnapshotDTO.source_name
ConnectionStatusSnapshotDTO.swagger_types
ConnectionStatusSnapshotDTO.to_dict()
ConnectionStatusSnapshotDTO.to_str()
- nipyapi.nifi.models.connection_status_snapshot_entity module
ConnectionStatusSnapshotEntity
ConnectionStatusSnapshotEntity.attribute_map
ConnectionStatusSnapshotEntity.can_read
ConnectionStatusSnapshotEntity.connection_status_snapshot
ConnectionStatusSnapshotEntity.id
ConnectionStatusSnapshotEntity.swagger_types
ConnectionStatusSnapshotEntity.to_dict()
ConnectionStatusSnapshotEntity.to_str()
- nipyapi.nifi.models.connections_entity module
- nipyapi.nifi.models.controller_bulletins_entity module
ControllerBulletinsEntity
ControllerBulletinsEntity.attribute_map
ControllerBulletinsEntity.bulletins
ControllerBulletinsEntity.controller_service_bulletins
ControllerBulletinsEntity.flow_registry_client_bulletins
ControllerBulletinsEntity.parameter_provider_bulletins
ControllerBulletinsEntity.reporting_task_bulletins
ControllerBulletinsEntity.swagger_types
ControllerBulletinsEntity.to_dict()
ControllerBulletinsEntity.to_str()
- nipyapi.nifi.models.controller_configuration_dto module
- nipyapi.nifi.models.controller_configuration_entity module
ControllerConfigurationEntity
ControllerConfigurationEntity.attribute_map
ControllerConfigurationEntity.component
ControllerConfigurationEntity.disconnected_node_acknowledged
ControllerConfigurationEntity.permissions
ControllerConfigurationEntity.revision
ControllerConfigurationEntity.swagger_types
ControllerConfigurationEntity.to_dict()
ControllerConfigurationEntity.to_str()
- nipyapi.nifi.models.controller_dto module
ControllerDTO
ControllerDTO.active_remote_port_count
ControllerDTO.attribute_map
ControllerDTO.comments
ControllerDTO.disabled_count
ControllerDTO.id
ControllerDTO.inactive_remote_port_count
ControllerDTO.input_port_count
ControllerDTO.input_ports
ControllerDTO.instance_id
ControllerDTO.invalid_count
ControllerDTO.name
ControllerDTO.output_port_count
ControllerDTO.output_ports
ControllerDTO.remote_site_http_listening_port
ControllerDTO.remote_site_listening_port
ControllerDTO.running_count
ControllerDTO.site_to_site_secure
ControllerDTO.stopped_count
ControllerDTO.swagger_types
ControllerDTO.to_dict()
ControllerDTO.to_str()
- nipyapi.nifi.models.controller_entity module
- nipyapi.nifi.models.controller_service_api module
- nipyapi.nifi.models.controller_service_api_dto module
- nipyapi.nifi.models.controller_service_dto module
ControllerServiceDTO
ControllerServiceDTO.annotation_data
ControllerServiceDTO.attribute_map
ControllerServiceDTO.bulletin_level
ControllerServiceDTO.bundle
ControllerServiceDTO.comments
ControllerServiceDTO.controller_service_apis
ControllerServiceDTO.custom_ui_url
ControllerServiceDTO.deprecated
ControllerServiceDTO.descriptors
ControllerServiceDTO.extension_missing
ControllerServiceDTO.id
ControllerServiceDTO.multiple_versions_available
ControllerServiceDTO.name
ControllerServiceDTO.parent_group_id
ControllerServiceDTO.persists_state
ControllerServiceDTO.position
ControllerServiceDTO.properties
ControllerServiceDTO.referencing_components
ControllerServiceDTO.restricted
ControllerServiceDTO.sensitive_dynamic_property_names
ControllerServiceDTO.state
ControllerServiceDTO.supports_sensitive_dynamic_properties
ControllerServiceDTO.swagger_types
ControllerServiceDTO.to_dict()
ControllerServiceDTO.to_str()
ControllerServiceDTO.type
ControllerServiceDTO.validation_errors
ControllerServiceDTO.validation_status
ControllerServiceDTO.versioned_component_id
- nipyapi.nifi.models.controller_service_entity module
ControllerServiceEntity
ControllerServiceEntity.attribute_map
ControllerServiceEntity.bulletins
ControllerServiceEntity.component
ControllerServiceEntity.disconnected_node_acknowledged
ControllerServiceEntity.id
ControllerServiceEntity.operate_permissions
ControllerServiceEntity.parent_group_id
ControllerServiceEntity.permissions
ControllerServiceEntity.position
ControllerServiceEntity.revision
ControllerServiceEntity.status
ControllerServiceEntity.swagger_types
ControllerServiceEntity.to_dict()
ControllerServiceEntity.to_str()
ControllerServiceEntity.uri
- nipyapi.nifi.models.controller_service_referencing_component_dto module
ControllerServiceReferencingComponentDTO
ControllerServiceReferencingComponentDTO.active_thread_count
ControllerServiceReferencingComponentDTO.attribute_map
ControllerServiceReferencingComponentDTO.descriptors
ControllerServiceReferencingComponentDTO.group_id
ControllerServiceReferencingComponentDTO.id
ControllerServiceReferencingComponentDTO.name
ControllerServiceReferencingComponentDTO.properties
ControllerServiceReferencingComponentDTO.reference_cycle
ControllerServiceReferencingComponentDTO.reference_type
ControllerServiceReferencingComponentDTO.referencing_components
ControllerServiceReferencingComponentDTO.state
ControllerServiceReferencingComponentDTO.swagger_types
ControllerServiceReferencingComponentDTO.to_dict()
ControllerServiceReferencingComponentDTO.to_str()
ControllerServiceReferencingComponentDTO.type
ControllerServiceReferencingComponentDTO.validation_errors
- nipyapi.nifi.models.controller_service_referencing_component_entity module
ControllerServiceReferencingComponentEntity
ControllerServiceReferencingComponentEntity.attribute_map
ControllerServiceReferencingComponentEntity.bulletins
ControllerServiceReferencingComponentEntity.component
ControllerServiceReferencingComponentEntity.disconnected_node_acknowledged
ControllerServiceReferencingComponentEntity.id
ControllerServiceReferencingComponentEntity.operate_permissions
ControllerServiceReferencingComponentEntity.permissions
ControllerServiceReferencingComponentEntity.position
ControllerServiceReferencingComponentEntity.revision
ControllerServiceReferencingComponentEntity.swagger_types
ControllerServiceReferencingComponentEntity.to_dict()
ControllerServiceReferencingComponentEntity.to_str()
ControllerServiceReferencingComponentEntity.uri
- nipyapi.nifi.models.controller_service_referencing_components_entity module
ControllerServiceReferencingComponentsEntity
ControllerServiceReferencingComponentsEntity.attribute_map
ControllerServiceReferencingComponentsEntity.controller_service_referencing_components
ControllerServiceReferencingComponentsEntity.swagger_types
ControllerServiceReferencingComponentsEntity.to_dict()
ControllerServiceReferencingComponentsEntity.to_str()
- nipyapi.nifi.models.controller_service_types_entity module
- nipyapi.nifi.models.controller_services_entity module
- nipyapi.nifi.models.controller_status_dto module
ControllerStatusDTO
ControllerStatusDTO.active_remote_port_count
ControllerStatusDTO.active_thread_count
ControllerStatusDTO.attribute_map
ControllerStatusDTO.bytes_queued
ControllerStatusDTO.disabled_count
ControllerStatusDTO.flow_files_queued
ControllerStatusDTO.inactive_remote_port_count
ControllerStatusDTO.invalid_count
ControllerStatusDTO.locally_modified_and_stale_count
ControllerStatusDTO.locally_modified_count
ControllerStatusDTO.queued
ControllerStatusDTO.running_count
ControllerStatusDTO.stale_count
ControllerStatusDTO.stopped_count
ControllerStatusDTO.swagger_types
ControllerStatusDTO.sync_failure_count
ControllerStatusDTO.terminated_thread_count
ControllerStatusDTO.to_dict()
ControllerStatusDTO.to_str()
ControllerStatusDTO.up_to_date_count
- nipyapi.nifi.models.controller_status_entity module
- nipyapi.nifi.models.copy_snippet_request_entity module
CopySnippetRequestEntity
CopySnippetRequestEntity.attribute_map
CopySnippetRequestEntity.disconnected_node_acknowledged
CopySnippetRequestEntity.origin_x
CopySnippetRequestEntity.origin_y
CopySnippetRequestEntity.snippet_id
CopySnippetRequestEntity.swagger_types
CopySnippetRequestEntity.to_dict()
CopySnippetRequestEntity.to_str()
- nipyapi.nifi.models.counter_dto module
- nipyapi.nifi.models.counter_entity module
- nipyapi.nifi.models.counters_dto module
- nipyapi.nifi.models.counters_entity module
- nipyapi.nifi.models.counters_snapshot_dto module
- nipyapi.nifi.models.create_active_request_entity module
- nipyapi.nifi.models.create_template_request_entity module
CreateTemplateRequestEntity
CreateTemplateRequestEntity.attribute_map
CreateTemplateRequestEntity.description
CreateTemplateRequestEntity.disconnected_node_acknowledged
CreateTemplateRequestEntity.name
CreateTemplateRequestEntity.snippet_id
CreateTemplateRequestEntity.swagger_types
CreateTemplateRequestEntity.to_dict()
CreateTemplateRequestEntity.to_str()
- nipyapi.nifi.models.current_user_entity module
CurrentUserEntity
CurrentUserEntity.anonymous
CurrentUserEntity.attribute_map
CurrentUserEntity.can_version_flows
CurrentUserEntity.component_restriction_permissions
CurrentUserEntity.controller_permissions
CurrentUserEntity.counters_permissions
CurrentUserEntity.identity
CurrentUserEntity.parameter_context_permissions
CurrentUserEntity.policies_permissions
CurrentUserEntity.provenance_permissions
CurrentUserEntity.restricted_components_permissions
CurrentUserEntity.swagger_types
CurrentUserEntity.system_permissions
CurrentUserEntity.tenants_permissions
CurrentUserEntity.to_dict()
CurrentUserEntity.to_str()
- nipyapi.nifi.models.difference_dto module
- nipyapi.nifi.models.dimensions_dto module
- nipyapi.nifi.models.documented_type_dto module
DocumentedTypeDTO
DocumentedTypeDTO.attribute_map
DocumentedTypeDTO.bundle
DocumentedTypeDTO.controller_service_apis
DocumentedTypeDTO.deprecation_reason
DocumentedTypeDTO.description
DocumentedTypeDTO.explicit_restrictions
DocumentedTypeDTO.restricted
DocumentedTypeDTO.swagger_types
DocumentedTypeDTO.tags
DocumentedTypeDTO.to_dict()
DocumentedTypeDTO.to_str()
DocumentedTypeDTO.type
DocumentedTypeDTO.usage_restriction
- nipyapi.nifi.models.drop_request_dto module
DropRequestDTO
DropRequestDTO.attribute_map
DropRequestDTO.current
DropRequestDTO.current_count
DropRequestDTO.current_size
DropRequestDTO.dropped
DropRequestDTO.dropped_count
DropRequestDTO.dropped_size
DropRequestDTO.failure_reason
DropRequestDTO.finished
DropRequestDTO.id
DropRequestDTO.last_updated
DropRequestDTO.original
DropRequestDTO.original_count
DropRequestDTO.original_size
DropRequestDTO.percent_completed
DropRequestDTO.state
DropRequestDTO.submission_time
DropRequestDTO.swagger_types
DropRequestDTO.to_dict()
DropRequestDTO.to_str()
DropRequestDTO.uri
- nipyapi.nifi.models.drop_request_entity module
- nipyapi.nifi.models.flow_breadcrumb_dto module
- nipyapi.nifi.models.flow_breadcrumb_entity module
FlowBreadcrumbEntity
FlowBreadcrumbEntity.attribute_map
FlowBreadcrumbEntity.breadcrumb
FlowBreadcrumbEntity.id
FlowBreadcrumbEntity.parent_breadcrumb
FlowBreadcrumbEntity.permissions
FlowBreadcrumbEntity.swagger_types
FlowBreadcrumbEntity.to_dict()
FlowBreadcrumbEntity.to_str()
FlowBreadcrumbEntity.versioned_flow_state
- nipyapi.nifi.models.flow_comparison_entity module
- nipyapi.nifi.models.flow_configuration_dto module
FlowConfigurationDTO
FlowConfigurationDTO.attribute_map
FlowConfigurationDTO.auto_refresh_interval_seconds
FlowConfigurationDTO.current_time
FlowConfigurationDTO.default_back_pressure_data_size_threshold
FlowConfigurationDTO.default_back_pressure_object_threshold
FlowConfigurationDTO.supports_configurable_authorizer
FlowConfigurationDTO.supports_configurable_users_and_groups
FlowConfigurationDTO.supports_managed_authorizer
FlowConfigurationDTO.swagger_types
FlowConfigurationDTO.time_offset
FlowConfigurationDTO.to_dict()
FlowConfigurationDTO.to_str()
- nipyapi.nifi.models.flow_configuration_entity module
- nipyapi.nifi.models.flow_dto module
- nipyapi.nifi.models.flow_entity module
- nipyapi.nifi.models.flow_file_dto module
FlowFileDTO
FlowFileDTO.attribute_map
FlowFileDTO.attributes
FlowFileDTO.cluster_node_address
FlowFileDTO.cluster_node_id
FlowFileDTO.content_claim_container
FlowFileDTO.content_claim_file_size
FlowFileDTO.content_claim_file_size_bytes
FlowFileDTO.content_claim_identifier
FlowFileDTO.content_claim_offset
FlowFileDTO.content_claim_section
FlowFileDTO.filename
FlowFileDTO.lineage_duration
FlowFileDTO.penalized
FlowFileDTO.penalty_expires_in
FlowFileDTO.position
FlowFileDTO.queued_duration
FlowFileDTO.size
FlowFileDTO.swagger_types
FlowFileDTO.to_dict()
FlowFileDTO.to_str()
FlowFileDTO.uri
FlowFileDTO.uuid
- nipyapi.nifi.models.flow_file_entity module
- nipyapi.nifi.models.flow_file_summary_dto module
FlowFileSummaryDTO
FlowFileSummaryDTO.attribute_map
FlowFileSummaryDTO.cluster_node_address
FlowFileSummaryDTO.cluster_node_id
FlowFileSummaryDTO.filename
FlowFileSummaryDTO.lineage_duration
FlowFileSummaryDTO.penalized
FlowFileSummaryDTO.penalty_expires_in
FlowFileSummaryDTO.position
FlowFileSummaryDTO.queued_duration
FlowFileSummaryDTO.size
FlowFileSummaryDTO.swagger_types
FlowFileSummaryDTO.to_dict()
FlowFileSummaryDTO.to_str()
FlowFileSummaryDTO.uri
FlowFileSummaryDTO.uuid
- nipyapi.nifi.models.flow_snippet_dto module
FlowSnippetDTO
FlowSnippetDTO.attribute_map
FlowSnippetDTO.connections
FlowSnippetDTO.controller_services
FlowSnippetDTO.funnels
FlowSnippetDTO.input_ports
FlowSnippetDTO.labels
FlowSnippetDTO.output_ports
FlowSnippetDTO.process_groups
FlowSnippetDTO.processors
FlowSnippetDTO.remote_process_groups
FlowSnippetDTO.swagger_types
FlowSnippetDTO.to_dict()
FlowSnippetDTO.to_str()
- nipyapi.nifi.models.funnel_dto module
- nipyapi.nifi.models.funnel_entity module
- nipyapi.nifi.models.funnels_entity module
- nipyapi.nifi.models.garbage_collection_dto module
- nipyapi.nifi.models.history_dto module
- nipyapi.nifi.models.history_entity module
- nipyapi.nifi.models.input_ports_entity module
- nipyapi.nifi.models.instantiate_template_request_entity module
InstantiateTemplateRequestEntity
InstantiateTemplateRequestEntity.attribute_map
InstantiateTemplateRequestEntity.disconnected_node_acknowledged
InstantiateTemplateRequestEntity.encoding_version
InstantiateTemplateRequestEntity.origin_x
InstantiateTemplateRequestEntity.origin_y
InstantiateTemplateRequestEntity.snippet
InstantiateTemplateRequestEntity.swagger_types
InstantiateTemplateRequestEntity.template_id
InstantiateTemplateRequestEntity.to_dict()
InstantiateTemplateRequestEntity.to_str()
- nipyapi.nifi.models.label_dto module
- nipyapi.nifi.models.label_entity module
LabelEntity
LabelEntity.attribute_map
LabelEntity.bulletins
LabelEntity.component
LabelEntity.dimensions
LabelEntity.disconnected_node_acknowledged
LabelEntity.getz_index
LabelEntity.id
LabelEntity.permissions
LabelEntity.position
LabelEntity.revision
LabelEntity.swagger_types
LabelEntity.to_dict()
LabelEntity.to_str()
LabelEntity.uri
- nipyapi.nifi.models.labels_entity module
- nipyapi.nifi.models.lineage_dto module
- nipyapi.nifi.models.lineage_entity module
- nipyapi.nifi.models.lineage_request_dto module
- nipyapi.nifi.models.lineage_results_dto module
- nipyapi.nifi.models.listing_request_dto module
ListingRequestDTO
ListingRequestDTO.attribute_map
ListingRequestDTO.destination_running
ListingRequestDTO.failure_reason
ListingRequestDTO.finished
ListingRequestDTO.flow_file_summaries
ListingRequestDTO.id
ListingRequestDTO.last_updated
ListingRequestDTO.max_results
ListingRequestDTO.percent_completed
ListingRequestDTO.queue_size
ListingRequestDTO.source_running
ListingRequestDTO.state
ListingRequestDTO.submission_time
ListingRequestDTO.swagger_types
ListingRequestDTO.to_dict()
ListingRequestDTO.to_str()
ListingRequestDTO.uri
- nipyapi.nifi.models.listing_request_entity module
- nipyapi.nifi.models.node_connection_status_snapshot_dto module
NodeConnectionStatusSnapshotDTO
NodeConnectionStatusSnapshotDTO.address
NodeConnectionStatusSnapshotDTO.api_port
NodeConnectionStatusSnapshotDTO.attribute_map
NodeConnectionStatusSnapshotDTO.node_id
NodeConnectionStatusSnapshotDTO.status_snapshot
NodeConnectionStatusSnapshotDTO.swagger_types
NodeConnectionStatusSnapshotDTO.to_dict()
NodeConnectionStatusSnapshotDTO.to_str()
- nipyapi.nifi.models.node_counters_snapshot_dto module
- nipyapi.nifi.models.node_dto module
- nipyapi.nifi.models.node_entity module
- nipyapi.nifi.models.node_event_dto module
- nipyapi.nifi.models.node_port_status_snapshot_dto module
- nipyapi.nifi.models.node_process_group_status_snapshot_dto module
NodeProcessGroupStatusSnapshotDTO
NodeProcessGroupStatusSnapshotDTO.address
NodeProcessGroupStatusSnapshotDTO.api_port
NodeProcessGroupStatusSnapshotDTO.attribute_map
NodeProcessGroupStatusSnapshotDTO.node_id
NodeProcessGroupStatusSnapshotDTO.status_snapshot
NodeProcessGroupStatusSnapshotDTO.swagger_types
NodeProcessGroupStatusSnapshotDTO.to_dict()
NodeProcessGroupStatusSnapshotDTO.to_str()
- nipyapi.nifi.models.node_processor_status_snapshot_dto module
NodeProcessorStatusSnapshotDTO
NodeProcessorStatusSnapshotDTO.address
NodeProcessorStatusSnapshotDTO.api_port
NodeProcessorStatusSnapshotDTO.attribute_map
NodeProcessorStatusSnapshotDTO.node_id
NodeProcessorStatusSnapshotDTO.status_snapshot
NodeProcessorStatusSnapshotDTO.swagger_types
NodeProcessorStatusSnapshotDTO.to_dict()
NodeProcessorStatusSnapshotDTO.to_str()
- nipyapi.nifi.models.node_remote_process_group_status_snapshot_dto module
NodeRemoteProcessGroupStatusSnapshotDTO
NodeRemoteProcessGroupStatusSnapshotDTO.address
NodeRemoteProcessGroupStatusSnapshotDTO.api_port
NodeRemoteProcessGroupStatusSnapshotDTO.attribute_map
NodeRemoteProcessGroupStatusSnapshotDTO.node_id
NodeRemoteProcessGroupStatusSnapshotDTO.status_snapshot
NodeRemoteProcessGroupStatusSnapshotDTO.swagger_types
NodeRemoteProcessGroupStatusSnapshotDTO.to_dict()
NodeRemoteProcessGroupStatusSnapshotDTO.to_str()
- nipyapi.nifi.models.node_search_result_dto module
- nipyapi.nifi.models.node_status_snapshots_dto module
- nipyapi.nifi.models.node_system_diagnostics_snapshot_dto module
NodeSystemDiagnosticsSnapshotDTO
NodeSystemDiagnosticsSnapshotDTO.address
NodeSystemDiagnosticsSnapshotDTO.api_port
NodeSystemDiagnosticsSnapshotDTO.attribute_map
NodeSystemDiagnosticsSnapshotDTO.node_id
NodeSystemDiagnosticsSnapshotDTO.snapshot
NodeSystemDiagnosticsSnapshotDTO.swagger_types
NodeSystemDiagnosticsSnapshotDTO.to_dict()
NodeSystemDiagnosticsSnapshotDTO.to_str()
- nipyapi.nifi.models.output_ports_entity module
- nipyapi.nifi.models.peer_dto module
- nipyapi.nifi.models.peers_entity module
- nipyapi.nifi.models.permissions module
- nipyapi.nifi.models.permissions_dto module
- nipyapi.nifi.models.port_dto module
PortDTO
PortDTO.allow_remote_access
PortDTO.attribute_map
PortDTO.comments
PortDTO.concurrently_schedulable_task_count
PortDTO.group_access_control
PortDTO.id
PortDTO.name
PortDTO.parent_group_id
PortDTO.position
PortDTO.state
PortDTO.swagger_types
PortDTO.to_dict()
PortDTO.to_str()
PortDTO.transmitting
PortDTO.type
PortDTO.user_access_control
PortDTO.validation_errors
PortDTO.versioned_component_id
- nipyapi.nifi.models.port_entity module
PortEntity
PortEntity.allow_remote_access
PortEntity.attribute_map
PortEntity.bulletins
PortEntity.component
PortEntity.disconnected_node_acknowledged
PortEntity.id
PortEntity.operate_permissions
PortEntity.permissions
PortEntity.port_type
PortEntity.position
PortEntity.revision
PortEntity.status
PortEntity.swagger_types
PortEntity.to_dict()
PortEntity.to_str()
PortEntity.uri
- nipyapi.nifi.models.port_status_dto module
PortStatusDTO
PortStatusDTO.aggregate_snapshot
PortStatusDTO.attribute_map
PortStatusDTO.group_id
PortStatusDTO.id
PortStatusDTO.name
PortStatusDTO.node_snapshots
PortStatusDTO.run_status
PortStatusDTO.stats_last_refreshed
PortStatusDTO.swagger_types
PortStatusDTO.to_dict()
PortStatusDTO.to_str()
PortStatusDTO.transmitting
- nipyapi.nifi.models.port_status_entity module
- nipyapi.nifi.models.port_status_snapshot_dto module
PortStatusSnapshotDTO
PortStatusSnapshotDTO.active_thread_count
PortStatusSnapshotDTO.attribute_map
PortStatusSnapshotDTO.bytes_in
PortStatusSnapshotDTO.bytes_out
PortStatusSnapshotDTO.flow_files_in
PortStatusSnapshotDTO.flow_files_out
PortStatusSnapshotDTO.group_id
PortStatusSnapshotDTO.id
PortStatusSnapshotDTO.input
PortStatusSnapshotDTO.name
PortStatusSnapshotDTO.output
PortStatusSnapshotDTO.run_status
PortStatusSnapshotDTO.swagger_types
PortStatusSnapshotDTO.to_dict()
PortStatusSnapshotDTO.to_str()
PortStatusSnapshotDTO.transmitting
- nipyapi.nifi.models.port_status_snapshot_entity module
- nipyapi.nifi.models.position_dto module
- nipyapi.nifi.models.previous_value_dto module
- nipyapi.nifi.models.prioritizer_types_entity module
- nipyapi.nifi.models.process_group_dto module
ProcessGroupDTO
ProcessGroupDTO.active_remote_port_count
ProcessGroupDTO.attribute_map
ProcessGroupDTO.comments
ProcessGroupDTO.contents
ProcessGroupDTO.default_back_pressure_data_size_threshold
ProcessGroupDTO.default_back_pressure_object_threshold
ProcessGroupDTO.default_flow_file_expiration
ProcessGroupDTO.disabled_count
ProcessGroupDTO.flowfile_concurrency
ProcessGroupDTO.flowfile_outbound_policy
ProcessGroupDTO.id
ProcessGroupDTO.inactive_remote_port_count
ProcessGroupDTO.input_port_count
ProcessGroupDTO.invalid_count
ProcessGroupDTO.local_input_port_count
ProcessGroupDTO.local_output_port_count
ProcessGroupDTO.locally_modified_and_stale_count
ProcessGroupDTO.locally_modified_count
ProcessGroupDTO.log_file_suffix
ProcessGroupDTO.name
ProcessGroupDTO.output_port_count
ProcessGroupDTO.parameter_context
ProcessGroupDTO.parent_group_id
ProcessGroupDTO.position
ProcessGroupDTO.public_input_port_count
ProcessGroupDTO.public_output_port_count
ProcessGroupDTO.running_count
ProcessGroupDTO.stale_count
ProcessGroupDTO.stopped_count
ProcessGroupDTO.swagger_types
ProcessGroupDTO.sync_failure_count
ProcessGroupDTO.to_dict()
ProcessGroupDTO.to_str()
ProcessGroupDTO.up_to_date_count
ProcessGroupDTO.variables
ProcessGroupDTO.version_control_information
ProcessGroupDTO.versioned_component_id
- nipyapi.nifi.models.process_group_entity module
ProcessGroupEntity
ProcessGroupEntity.active_remote_port_count
ProcessGroupEntity.attribute_map
ProcessGroupEntity.bulletins
ProcessGroupEntity.component
ProcessGroupEntity.disabled_count
ProcessGroupEntity.disconnected_node_acknowledged
ProcessGroupEntity.id
ProcessGroupEntity.inactive_remote_port_count
ProcessGroupEntity.input_port_count
ProcessGroupEntity.invalid_count
ProcessGroupEntity.local_input_port_count
ProcessGroupEntity.local_output_port_count
ProcessGroupEntity.locally_modified_and_stale_count
ProcessGroupEntity.locally_modified_count
ProcessGroupEntity.output_port_count
ProcessGroupEntity.parameter_context
ProcessGroupEntity.permissions
ProcessGroupEntity.position
ProcessGroupEntity.public_input_port_count
ProcessGroupEntity.public_output_port_count
ProcessGroupEntity.revision
ProcessGroupEntity.running_count
ProcessGroupEntity.stale_count
ProcessGroupEntity.status
ProcessGroupEntity.stopped_count
ProcessGroupEntity.swagger_types
ProcessGroupEntity.sync_failure_count
ProcessGroupEntity.to_dict()
ProcessGroupEntity.to_str()
ProcessGroupEntity.up_to_date_count
ProcessGroupEntity.uri
ProcessGroupEntity.versioned_flow_snapshot
ProcessGroupEntity.versioned_flow_state
- nipyapi.nifi.models.process_group_flow_dto module
ProcessGroupFlowDTO
ProcessGroupFlowDTO.attribute_map
ProcessGroupFlowDTO.breadcrumb
ProcessGroupFlowDTO.flow
ProcessGroupFlowDTO.id
ProcessGroupFlowDTO.last_refreshed
ProcessGroupFlowDTO.parameter_context
ProcessGroupFlowDTO.parent_group_id
ProcessGroupFlowDTO.swagger_types
ProcessGroupFlowDTO.to_dict()
ProcessGroupFlowDTO.to_str()
ProcessGroupFlowDTO.uri
- nipyapi.nifi.models.process_group_flow_entity module
- nipyapi.nifi.models.process_group_status_dto module
ProcessGroupStatusDTO
ProcessGroupStatusDTO.aggregate_snapshot
ProcessGroupStatusDTO.attribute_map
ProcessGroupStatusDTO.id
ProcessGroupStatusDTO.name
ProcessGroupStatusDTO.node_snapshots
ProcessGroupStatusDTO.stats_last_refreshed
ProcessGroupStatusDTO.swagger_types
ProcessGroupStatusDTO.to_dict()
ProcessGroupStatusDTO.to_str()
- nipyapi.nifi.models.process_group_status_entity module
- nipyapi.nifi.models.process_group_status_snapshot_dto module
ProcessGroupStatusSnapshotDTO
ProcessGroupStatusSnapshotDTO.active_thread_count
ProcessGroupStatusSnapshotDTO.attribute_map
ProcessGroupStatusSnapshotDTO.bytes_in
ProcessGroupStatusSnapshotDTO.bytes_out
ProcessGroupStatusSnapshotDTO.bytes_queued
ProcessGroupStatusSnapshotDTO.bytes_read
ProcessGroupStatusSnapshotDTO.bytes_received
ProcessGroupStatusSnapshotDTO.bytes_sent
ProcessGroupStatusSnapshotDTO.bytes_transferred
ProcessGroupStatusSnapshotDTO.bytes_written
ProcessGroupStatusSnapshotDTO.connection_status_snapshots
ProcessGroupStatusSnapshotDTO.flow_files_in
ProcessGroupStatusSnapshotDTO.flow_files_out
ProcessGroupStatusSnapshotDTO.flow_files_queued
ProcessGroupStatusSnapshotDTO.flow_files_received
ProcessGroupStatusSnapshotDTO.flow_files_sent
ProcessGroupStatusSnapshotDTO.flow_files_transferred
ProcessGroupStatusSnapshotDTO.id
ProcessGroupStatusSnapshotDTO.input
ProcessGroupStatusSnapshotDTO.input_port_status_snapshots
ProcessGroupStatusSnapshotDTO.name
ProcessGroupStatusSnapshotDTO.output
ProcessGroupStatusSnapshotDTO.output_port_status_snapshots
ProcessGroupStatusSnapshotDTO.process_group_status_snapshots
ProcessGroupStatusSnapshotDTO.processing_nanos
ProcessGroupStatusSnapshotDTO.processor_status_snapshots
ProcessGroupStatusSnapshotDTO.queued
ProcessGroupStatusSnapshotDTO.queued_count
ProcessGroupStatusSnapshotDTO.queued_size
ProcessGroupStatusSnapshotDTO.read
ProcessGroupStatusSnapshotDTO.received
ProcessGroupStatusSnapshotDTO.remote_process_group_status_snapshots
ProcessGroupStatusSnapshotDTO.sent
ProcessGroupStatusSnapshotDTO.swagger_types
ProcessGroupStatusSnapshotDTO.terminated_thread_count
ProcessGroupStatusSnapshotDTO.to_dict()
ProcessGroupStatusSnapshotDTO.to_str()
ProcessGroupStatusSnapshotDTO.transferred
ProcessGroupStatusSnapshotDTO.versioned_flow_state
ProcessGroupStatusSnapshotDTO.written
- nipyapi.nifi.models.process_group_status_snapshot_entity module
ProcessGroupStatusSnapshotEntity
ProcessGroupStatusSnapshotEntity.attribute_map
ProcessGroupStatusSnapshotEntity.can_read
ProcessGroupStatusSnapshotEntity.id
ProcessGroupStatusSnapshotEntity.process_group_status_snapshot
ProcessGroupStatusSnapshotEntity.swagger_types
ProcessGroupStatusSnapshotEntity.to_dict()
ProcessGroupStatusSnapshotEntity.to_str()
- nipyapi.nifi.models.process_groups_entity module
- nipyapi.nifi.models.processor_config_dto module
ProcessorConfigDTO
ProcessorConfigDTO.annotation_data
ProcessorConfigDTO.attribute_map
ProcessorConfigDTO.auto_terminated_relationships
ProcessorConfigDTO.backoff_mechanism
ProcessorConfigDTO.bulletin_level
ProcessorConfigDTO.comments
ProcessorConfigDTO.concurrently_schedulable_task_count
ProcessorConfigDTO.custom_ui_url
ProcessorConfigDTO.default_concurrent_tasks
ProcessorConfigDTO.default_scheduling_period
ProcessorConfigDTO.descriptors
ProcessorConfigDTO.execution_node
ProcessorConfigDTO.loss_tolerant
ProcessorConfigDTO.max_backoff_period
ProcessorConfigDTO.penalty_duration
ProcessorConfigDTO.properties
ProcessorConfigDTO.retried_relationships
ProcessorConfigDTO.retry_count
ProcessorConfigDTO.run_duration_millis
ProcessorConfigDTO.scheduling_period
ProcessorConfigDTO.scheduling_strategy
ProcessorConfigDTO.sensitive_dynamic_property_names
ProcessorConfigDTO.swagger_types
ProcessorConfigDTO.to_dict()
ProcessorConfigDTO.to_str()
ProcessorConfigDTO.yield_duration
- nipyapi.nifi.models.processor_dto module
ProcessorDTO
ProcessorDTO.attribute_map
ProcessorDTO.bundle
ProcessorDTO.config
ProcessorDTO.deprecated
ProcessorDTO.description
ProcessorDTO.execution_node_restricted
ProcessorDTO.extension_missing
ProcessorDTO.id
ProcessorDTO.input_requirement
ProcessorDTO.multiple_versions_available
ProcessorDTO.name
ProcessorDTO.parent_group_id
ProcessorDTO.persists_state
ProcessorDTO.position
ProcessorDTO.relationships
ProcessorDTO.restricted
ProcessorDTO.state
ProcessorDTO.style
ProcessorDTO.supports_batching
ProcessorDTO.supports_event_driven
ProcessorDTO.supports_parallel_processing
ProcessorDTO.supports_sensitive_dynamic_properties
ProcessorDTO.swagger_types
ProcessorDTO.to_dict()
ProcessorDTO.to_str()
ProcessorDTO.type
ProcessorDTO.validation_errors
ProcessorDTO.validation_status
ProcessorDTO.versioned_component_id
- nipyapi.nifi.models.processor_entity module
ProcessorEntity
ProcessorEntity.attribute_map
ProcessorEntity.bulletins
ProcessorEntity.component
ProcessorEntity.disconnected_node_acknowledged
ProcessorEntity.id
ProcessorEntity.input_requirement
ProcessorEntity.operate_permissions
ProcessorEntity.permissions
ProcessorEntity.position
ProcessorEntity.revision
ProcessorEntity.status
ProcessorEntity.swagger_types
ProcessorEntity.to_dict()
ProcessorEntity.to_str()
ProcessorEntity.uri
- nipyapi.nifi.models.processor_status_dto module
ProcessorStatusDTO
ProcessorStatusDTO.aggregate_snapshot
ProcessorStatusDTO.attribute_map
ProcessorStatusDTO.group_id
ProcessorStatusDTO.id
ProcessorStatusDTO.name
ProcessorStatusDTO.node_snapshots
ProcessorStatusDTO.run_status
ProcessorStatusDTO.stats_last_refreshed
ProcessorStatusDTO.swagger_types
ProcessorStatusDTO.to_dict()
ProcessorStatusDTO.to_str()
ProcessorStatusDTO.type
- nipyapi.nifi.models.processor_status_entity module
- nipyapi.nifi.models.processor_status_snapshot_dto module
ProcessorStatusSnapshotDTO
ProcessorStatusSnapshotDTO.active_thread_count
ProcessorStatusSnapshotDTO.attribute_map
ProcessorStatusSnapshotDTO.bytes_in
ProcessorStatusSnapshotDTO.bytes_out
ProcessorStatusSnapshotDTO.bytes_read
ProcessorStatusSnapshotDTO.bytes_written
ProcessorStatusSnapshotDTO.execution_node
ProcessorStatusSnapshotDTO.flow_files_in
ProcessorStatusSnapshotDTO.flow_files_out
ProcessorStatusSnapshotDTO.group_id
ProcessorStatusSnapshotDTO.id
ProcessorStatusSnapshotDTO.input
ProcessorStatusSnapshotDTO.name
ProcessorStatusSnapshotDTO.output
ProcessorStatusSnapshotDTO.read
ProcessorStatusSnapshotDTO.run_status
ProcessorStatusSnapshotDTO.swagger_types
ProcessorStatusSnapshotDTO.task_count
ProcessorStatusSnapshotDTO.tasks
ProcessorStatusSnapshotDTO.tasks_duration
ProcessorStatusSnapshotDTO.tasks_duration_nanos
ProcessorStatusSnapshotDTO.terminated_thread_count
ProcessorStatusSnapshotDTO.to_dict()
ProcessorStatusSnapshotDTO.to_str()
ProcessorStatusSnapshotDTO.type
ProcessorStatusSnapshotDTO.written
- nipyapi.nifi.models.processor_status_snapshot_entity module
- nipyapi.nifi.models.processor_types_entity module
- nipyapi.nifi.models.processors_entity module
- nipyapi.nifi.models.property_descriptor_dto module
PropertyDescriptorDTO
PropertyDescriptorDTO.allowable_values
PropertyDescriptorDTO.attribute_map
PropertyDescriptorDTO.default_value
PropertyDescriptorDTO.dependencies
PropertyDescriptorDTO.description
PropertyDescriptorDTO.display_name
PropertyDescriptorDTO.dynamic
PropertyDescriptorDTO.expression_language_scope
PropertyDescriptorDTO.identifies_controller_service
PropertyDescriptorDTO.identifies_controller_service_bundle
PropertyDescriptorDTO.name
PropertyDescriptorDTO.required
PropertyDescriptorDTO.sensitive
PropertyDescriptorDTO.supports_el
PropertyDescriptorDTO.swagger_types
PropertyDescriptorDTO.to_dict()
PropertyDescriptorDTO.to_str()
- nipyapi.nifi.models.property_descriptor_entity module
- nipyapi.nifi.models.property_history_dto module
- nipyapi.nifi.models.provenance_dto module
- nipyapi.nifi.models.provenance_entity module
- nipyapi.nifi.models.provenance_event_dto module
ProvenanceEventDTO
ProvenanceEventDTO.alternate_identifier_uri
ProvenanceEventDTO.attribute_map
ProvenanceEventDTO.attributes
ProvenanceEventDTO.child_uuids
ProvenanceEventDTO.cluster_node_address
ProvenanceEventDTO.cluster_node_id
ProvenanceEventDTO.component_id
ProvenanceEventDTO.component_name
ProvenanceEventDTO.component_type
ProvenanceEventDTO.content_equal
ProvenanceEventDTO.details
ProvenanceEventDTO.event_duration
ProvenanceEventDTO.event_id
ProvenanceEventDTO.event_time
ProvenanceEventDTO.event_type
ProvenanceEventDTO.file_size
ProvenanceEventDTO.file_size_bytes
ProvenanceEventDTO.flow_file_uuid
ProvenanceEventDTO.group_id
ProvenanceEventDTO.id
ProvenanceEventDTO.input_content_available
ProvenanceEventDTO.input_content_claim_container
ProvenanceEventDTO.input_content_claim_file_size
ProvenanceEventDTO.input_content_claim_file_size_bytes
ProvenanceEventDTO.input_content_claim_identifier
ProvenanceEventDTO.input_content_claim_offset
ProvenanceEventDTO.input_content_claim_section
ProvenanceEventDTO.lineage_duration
ProvenanceEventDTO.output_content_available
ProvenanceEventDTO.output_content_claim_container
ProvenanceEventDTO.output_content_claim_file_size
ProvenanceEventDTO.output_content_claim_file_size_bytes
ProvenanceEventDTO.output_content_claim_identifier
ProvenanceEventDTO.output_content_claim_offset
ProvenanceEventDTO.output_content_claim_section
ProvenanceEventDTO.parent_uuids
ProvenanceEventDTO.relationship
ProvenanceEventDTO.replay_available
ProvenanceEventDTO.replay_explanation
ProvenanceEventDTO.source_connection_identifier
ProvenanceEventDTO.source_system_flow_file_id
ProvenanceEventDTO.swagger_types
ProvenanceEventDTO.to_dict()
ProvenanceEventDTO.to_str()
ProvenanceEventDTO.transit_uri
- nipyapi.nifi.models.provenance_event_entity module
- nipyapi.nifi.models.provenance_link_dto module
- nipyapi.nifi.models.provenance_node_dto module
ProvenanceNodeDTO
ProvenanceNodeDTO.attribute_map
ProvenanceNodeDTO.child_uuids
ProvenanceNodeDTO.cluster_node_identifier
ProvenanceNodeDTO.event_type
ProvenanceNodeDTO.flow_file_uuid
ProvenanceNodeDTO.id
ProvenanceNodeDTO.millis
ProvenanceNodeDTO.parent_uuids
ProvenanceNodeDTO.swagger_types
ProvenanceNodeDTO.timestamp
ProvenanceNodeDTO.to_dict()
ProvenanceNodeDTO.to_str()
ProvenanceNodeDTO.type
- nipyapi.nifi.models.provenance_options_dto module
- nipyapi.nifi.models.provenance_options_entity module
- nipyapi.nifi.models.provenance_request_dto module
ProvenanceRequestDTO
ProvenanceRequestDTO.attribute_map
ProvenanceRequestDTO.cluster_node_id
ProvenanceRequestDTO.end_date
ProvenanceRequestDTO.incremental_results
ProvenanceRequestDTO.max_results
ProvenanceRequestDTO.maximum_file_size
ProvenanceRequestDTO.minimum_file_size
ProvenanceRequestDTO.search_terms
ProvenanceRequestDTO.start_date
ProvenanceRequestDTO.summarize
ProvenanceRequestDTO.swagger_types
ProvenanceRequestDTO.to_dict()
ProvenanceRequestDTO.to_str()
- nipyapi.nifi.models.provenance_results_dto module
ProvenanceResultsDTO
ProvenanceResultsDTO.attribute_map
ProvenanceResultsDTO.errors
ProvenanceResultsDTO.generated
ProvenanceResultsDTO.oldest_event
ProvenanceResultsDTO.provenance_events
ProvenanceResultsDTO.swagger_types
ProvenanceResultsDTO.time_offset
ProvenanceResultsDTO.to_dict()
ProvenanceResultsDTO.to_str()
ProvenanceResultsDTO.total
ProvenanceResultsDTO.total_count
- nipyapi.nifi.models.provenance_searchable_field_dto module
- nipyapi.nifi.models.queue_size_dto module
- nipyapi.nifi.models.registry_client_entity module
- nipyapi.nifi.models.registry_clients_entity module
- nipyapi.nifi.models.registry_dto module
- nipyapi.nifi.models.relationship_dto module
- nipyapi.nifi.models.remote_process_group_contents_dto module
- nipyapi.nifi.models.remote_process_group_dto module
RemoteProcessGroupDTO
RemoteProcessGroupDTO.active_remote_input_port_count
RemoteProcessGroupDTO.active_remote_output_port_count
RemoteProcessGroupDTO.attribute_map
RemoteProcessGroupDTO.authorization_issues
RemoteProcessGroupDTO.comments
RemoteProcessGroupDTO.communications_timeout
RemoteProcessGroupDTO.contents
RemoteProcessGroupDTO.flow_refreshed
RemoteProcessGroupDTO.id
RemoteProcessGroupDTO.inactive_remote_input_port_count
RemoteProcessGroupDTO.inactive_remote_output_port_count
RemoteProcessGroupDTO.input_port_count
RemoteProcessGroupDTO.local_network_interface
RemoteProcessGroupDTO.name
RemoteProcessGroupDTO.output_port_count
RemoteProcessGroupDTO.parent_group_id
RemoteProcessGroupDTO.position
RemoteProcessGroupDTO.proxy_host
RemoteProcessGroupDTO.proxy_password
RemoteProcessGroupDTO.proxy_port
RemoteProcessGroupDTO.proxy_user
RemoteProcessGroupDTO.swagger_types
RemoteProcessGroupDTO.target_secure
RemoteProcessGroupDTO.target_uri
RemoteProcessGroupDTO.target_uris
RemoteProcessGroupDTO.to_dict()
RemoteProcessGroupDTO.to_str()
RemoteProcessGroupDTO.transmitting
RemoteProcessGroupDTO.transport_protocol
RemoteProcessGroupDTO.validation_errors
RemoteProcessGroupDTO.versioned_component_id
RemoteProcessGroupDTO.yield_duration
- nipyapi.nifi.models.remote_process_group_entity module
RemoteProcessGroupEntity
RemoteProcessGroupEntity.attribute_map
RemoteProcessGroupEntity.bulletins
RemoteProcessGroupEntity.component
RemoteProcessGroupEntity.disconnected_node_acknowledged
RemoteProcessGroupEntity.id
RemoteProcessGroupEntity.input_port_count
RemoteProcessGroupEntity.operate_permissions
RemoteProcessGroupEntity.output_port_count
RemoteProcessGroupEntity.permissions
RemoteProcessGroupEntity.position
RemoteProcessGroupEntity.revision
RemoteProcessGroupEntity.status
RemoteProcessGroupEntity.swagger_types
RemoteProcessGroupEntity.to_dict()
RemoteProcessGroupEntity.to_str()
RemoteProcessGroupEntity.uri
- nipyapi.nifi.models.remote_process_group_port_dto module
RemoteProcessGroupPortDTO
RemoteProcessGroupPortDTO.attribute_map
RemoteProcessGroupPortDTO.batch_settings
RemoteProcessGroupPortDTO.comments
RemoteProcessGroupPortDTO.concurrently_schedulable_task_count
RemoteProcessGroupPortDTO.connected
RemoteProcessGroupPortDTO.exists
RemoteProcessGroupPortDTO.group_id
RemoteProcessGroupPortDTO.id
RemoteProcessGroupPortDTO.name
RemoteProcessGroupPortDTO.swagger_types
RemoteProcessGroupPortDTO.target_id
RemoteProcessGroupPortDTO.target_running
RemoteProcessGroupPortDTO.to_dict()
RemoteProcessGroupPortDTO.to_str()
RemoteProcessGroupPortDTO.transmitting
RemoteProcessGroupPortDTO.use_compression
RemoteProcessGroupPortDTO.versioned_component_id
- nipyapi.nifi.models.remote_process_group_port_entity module
RemoteProcessGroupPortEntity
RemoteProcessGroupPortEntity.attribute_map
RemoteProcessGroupPortEntity.bulletins
RemoteProcessGroupPortEntity.disconnected_node_acknowledged
RemoteProcessGroupPortEntity.id
RemoteProcessGroupPortEntity.operate_permissions
RemoteProcessGroupPortEntity.permissions
RemoteProcessGroupPortEntity.position
RemoteProcessGroupPortEntity.remote_process_group_port
RemoteProcessGroupPortEntity.revision
RemoteProcessGroupPortEntity.swagger_types
RemoteProcessGroupPortEntity.to_dict()
RemoteProcessGroupPortEntity.to_str()
RemoteProcessGroupPortEntity.uri
- nipyapi.nifi.models.remote_process_group_status_dto module
RemoteProcessGroupStatusDTO
RemoteProcessGroupStatusDTO.aggregate_snapshot
RemoteProcessGroupStatusDTO.attribute_map
RemoteProcessGroupStatusDTO.group_id
RemoteProcessGroupStatusDTO.id
RemoteProcessGroupStatusDTO.name
RemoteProcessGroupStatusDTO.node_snapshots
RemoteProcessGroupStatusDTO.stats_last_refreshed
RemoteProcessGroupStatusDTO.swagger_types
RemoteProcessGroupStatusDTO.target_uri
RemoteProcessGroupStatusDTO.to_dict()
RemoteProcessGroupStatusDTO.to_str()
RemoteProcessGroupStatusDTO.transmission_status
RemoteProcessGroupStatusDTO.validation_status
- nipyapi.nifi.models.remote_process_group_status_entity module
- nipyapi.nifi.models.remote_process_group_status_snapshot_dto module
RemoteProcessGroupStatusSnapshotDTO
RemoteProcessGroupStatusSnapshotDTO.active_thread_count
RemoteProcessGroupStatusSnapshotDTO.attribute_map
RemoteProcessGroupStatusSnapshotDTO.bytes_received
RemoteProcessGroupStatusSnapshotDTO.bytes_sent
RemoteProcessGroupStatusSnapshotDTO.flow_files_received
RemoteProcessGroupStatusSnapshotDTO.flow_files_sent
RemoteProcessGroupStatusSnapshotDTO.group_id
RemoteProcessGroupStatusSnapshotDTO.id
RemoteProcessGroupStatusSnapshotDTO.name
RemoteProcessGroupStatusSnapshotDTO.received
RemoteProcessGroupStatusSnapshotDTO.sent
RemoteProcessGroupStatusSnapshotDTO.swagger_types
RemoteProcessGroupStatusSnapshotDTO.target_uri
RemoteProcessGroupStatusSnapshotDTO.to_dict()
RemoteProcessGroupStatusSnapshotDTO.to_str()
RemoteProcessGroupStatusSnapshotDTO.transmission_status
- nipyapi.nifi.models.remote_process_group_status_snapshot_entity module
RemoteProcessGroupStatusSnapshotEntity
RemoteProcessGroupStatusSnapshotEntity.attribute_map
RemoteProcessGroupStatusSnapshotEntity.can_read
RemoteProcessGroupStatusSnapshotEntity.id
RemoteProcessGroupStatusSnapshotEntity.remote_process_group_status_snapshot
RemoteProcessGroupStatusSnapshotEntity.swagger_types
RemoteProcessGroupStatusSnapshotEntity.to_dict()
RemoteProcessGroupStatusSnapshotEntity.to_str()
- nipyapi.nifi.models.remote_process_groups_entity module
- nipyapi.nifi.models.reporting_task_dto module
ReportingTaskDTO
ReportingTaskDTO.active_thread_count
ReportingTaskDTO.annotation_data
ReportingTaskDTO.attribute_map
ReportingTaskDTO.bundle
ReportingTaskDTO.comments
ReportingTaskDTO.custom_ui_url
ReportingTaskDTO.default_scheduling_period
ReportingTaskDTO.deprecated
ReportingTaskDTO.descriptors
ReportingTaskDTO.extension_missing
ReportingTaskDTO.id
ReportingTaskDTO.multiple_versions_available
ReportingTaskDTO.name
ReportingTaskDTO.parent_group_id
ReportingTaskDTO.persists_state
ReportingTaskDTO.position
ReportingTaskDTO.properties
ReportingTaskDTO.restricted
ReportingTaskDTO.scheduling_period
ReportingTaskDTO.scheduling_strategy
ReportingTaskDTO.sensitive_dynamic_property_names
ReportingTaskDTO.state
ReportingTaskDTO.supports_sensitive_dynamic_properties
ReportingTaskDTO.swagger_types
ReportingTaskDTO.to_dict()
ReportingTaskDTO.to_str()
ReportingTaskDTO.type
ReportingTaskDTO.validation_errors
ReportingTaskDTO.validation_status
ReportingTaskDTO.versioned_component_id
- nipyapi.nifi.models.reporting_task_entity module
ReportingTaskEntity
ReportingTaskEntity.attribute_map
ReportingTaskEntity.bulletins
ReportingTaskEntity.component
ReportingTaskEntity.disconnected_node_acknowledged
ReportingTaskEntity.id
ReportingTaskEntity.operate_permissions
ReportingTaskEntity.permissions
ReportingTaskEntity.position
ReportingTaskEntity.revision
ReportingTaskEntity.status
ReportingTaskEntity.swagger_types
ReportingTaskEntity.to_dict()
ReportingTaskEntity.to_str()
ReportingTaskEntity.uri
- nipyapi.nifi.models.reporting_task_types_entity module
- nipyapi.nifi.models.reporting_tasks_entity module
- nipyapi.nifi.models.resource_dto module
- nipyapi.nifi.models.resources_entity module
- nipyapi.nifi.models.revision_dto module
- nipyapi.nifi.models.schedule_components_entity module
- nipyapi.nifi.models.search_results_dto module
SearchResultsDTO
SearchResultsDTO.attribute_map
SearchResultsDTO.connection_results
SearchResultsDTO.controller_service_node_results
SearchResultsDTO.funnel_results
SearchResultsDTO.input_port_results
SearchResultsDTO.label_results
SearchResultsDTO.output_port_results
SearchResultsDTO.parameter_context_results
SearchResultsDTO.parameter_provider_node_results
SearchResultsDTO.parameter_results
SearchResultsDTO.process_group_results
SearchResultsDTO.processor_results
SearchResultsDTO.remote_process_group_results
SearchResultsDTO.swagger_types
SearchResultsDTO.to_dict()
SearchResultsDTO.to_str()
- nipyapi.nifi.models.search_results_entity module
- nipyapi.nifi.models.snippet_dto module
SnippetDTO
SnippetDTO.attribute_map
SnippetDTO.connections
SnippetDTO.funnels
SnippetDTO.id
SnippetDTO.input_ports
SnippetDTO.labels
SnippetDTO.output_ports
SnippetDTO.parent_group_id
SnippetDTO.process_groups
SnippetDTO.processors
SnippetDTO.remote_process_groups
SnippetDTO.swagger_types
SnippetDTO.to_dict()
SnippetDTO.to_str()
SnippetDTO.uri
- nipyapi.nifi.models.snippet_entity module
- nipyapi.nifi.models.start_version_control_request_entity module
StartVersionControlRequestEntity
StartVersionControlRequestEntity.attribute_map
StartVersionControlRequestEntity.disconnected_node_acknowledged
StartVersionControlRequestEntity.process_group_revision
StartVersionControlRequestEntity.swagger_types
StartVersionControlRequestEntity.to_dict()
StartVersionControlRequestEntity.to_str()
StartVersionControlRequestEntity.versioned_flow
- nipyapi.nifi.models.state_entry_dto module
- nipyapi.nifi.models.state_map_dto module
- nipyapi.nifi.models.status_descriptor_dto module
- nipyapi.nifi.models.status_history_dto module
- nipyapi.nifi.models.status_history_entity module
- nipyapi.nifi.models.status_snapshot_dto module
- nipyapi.nifi.models.storage_usage_dto module
StorageUsageDTO
StorageUsageDTO.attribute_map
StorageUsageDTO.free_space
StorageUsageDTO.free_space_bytes
StorageUsageDTO.identifier
StorageUsageDTO.swagger_types
StorageUsageDTO.to_dict()
StorageUsageDTO.to_str()
StorageUsageDTO.total_space
StorageUsageDTO.total_space_bytes
StorageUsageDTO.used_space
StorageUsageDTO.used_space_bytes
StorageUsageDTO.utilization
- nipyapi.nifi.models.streaming_output module
- nipyapi.nifi.models.submit_replay_request_entity module
- nipyapi.nifi.models.system_diagnostics_dto module
- nipyapi.nifi.models.system_diagnostics_entity module
- nipyapi.nifi.models.system_diagnostics_snapshot_dto module
SystemDiagnosticsSnapshotDTO
SystemDiagnosticsSnapshotDTO.attribute_map
SystemDiagnosticsSnapshotDTO.available_processors
SystemDiagnosticsSnapshotDTO.content_repository_storage_usage
SystemDiagnosticsSnapshotDTO.daemon_threads
SystemDiagnosticsSnapshotDTO.flow_file_repository_storage_usage
SystemDiagnosticsSnapshotDTO.free_heap
SystemDiagnosticsSnapshotDTO.free_heap_bytes
SystemDiagnosticsSnapshotDTO.free_non_heap
SystemDiagnosticsSnapshotDTO.free_non_heap_bytes
SystemDiagnosticsSnapshotDTO.garbage_collection
SystemDiagnosticsSnapshotDTO.heap_utilization
SystemDiagnosticsSnapshotDTO.max_heap
SystemDiagnosticsSnapshotDTO.max_heap_bytes
SystemDiagnosticsSnapshotDTO.max_non_heap
SystemDiagnosticsSnapshotDTO.max_non_heap_bytes
SystemDiagnosticsSnapshotDTO.non_heap_utilization
SystemDiagnosticsSnapshotDTO.processor_load_average
SystemDiagnosticsSnapshotDTO.provenance_repository_storage_usage
SystemDiagnosticsSnapshotDTO.stats_last_refreshed
SystemDiagnosticsSnapshotDTO.swagger_types
SystemDiagnosticsSnapshotDTO.to_dict()
SystemDiagnosticsSnapshotDTO.to_str()
SystemDiagnosticsSnapshotDTO.total_heap
SystemDiagnosticsSnapshotDTO.total_heap_bytes
SystemDiagnosticsSnapshotDTO.total_non_heap
SystemDiagnosticsSnapshotDTO.total_non_heap_bytes
SystemDiagnosticsSnapshotDTO.total_threads
SystemDiagnosticsSnapshotDTO.uptime
SystemDiagnosticsSnapshotDTO.used_heap
SystemDiagnosticsSnapshotDTO.used_heap_bytes
SystemDiagnosticsSnapshotDTO.used_non_heap
SystemDiagnosticsSnapshotDTO.used_non_heap_bytes
SystemDiagnosticsSnapshotDTO.version_info
- nipyapi.nifi.models.template_dto module
- nipyapi.nifi.models.template_entity module
TemplateEntity
TemplateEntity.attribute_map
TemplateEntity.bulletins
TemplateEntity.disconnected_node_acknowledged
TemplateEntity.id
TemplateEntity.permissions
TemplateEntity.position
TemplateEntity.revision
TemplateEntity.swagger_types
TemplateEntity.template
TemplateEntity.to_dict()
TemplateEntity.to_str()
TemplateEntity.uri
- nipyapi.nifi.models.templates_entity module
- nipyapi.nifi.models.tenant_dto module
- nipyapi.nifi.models.tenant_entity module
- nipyapi.nifi.models.tenants_entity module
- nipyapi.nifi.models.transaction_result_entity module
- nipyapi.nifi.models.update_controller_service_reference_request_entity module
UpdateControllerServiceReferenceRequestEntity
UpdateControllerServiceReferenceRequestEntity.attribute_map
UpdateControllerServiceReferenceRequestEntity.disconnected_node_acknowledged
UpdateControllerServiceReferenceRequestEntity.id
UpdateControllerServiceReferenceRequestEntity.referencing_component_revisions
UpdateControllerServiceReferenceRequestEntity.state
UpdateControllerServiceReferenceRequestEntity.swagger_types
UpdateControllerServiceReferenceRequestEntity.to_dict()
UpdateControllerServiceReferenceRequestEntity.to_str()
UpdateControllerServiceReferenceRequestEntity.ui_only
- nipyapi.nifi.models.user_dto module
- nipyapi.nifi.models.user_entity module
- nipyapi.nifi.models.user_group_dto module
- nipyapi.nifi.models.user_group_entity module
UserGroupEntity
UserGroupEntity.attribute_map
UserGroupEntity.bulletins
UserGroupEntity.component
UserGroupEntity.disconnected_node_acknowledged
UserGroupEntity.id
UserGroupEntity.permissions
UserGroupEntity.position
UserGroupEntity.revision
UserGroupEntity.swagger_types
UserGroupEntity.to_dict()
UserGroupEntity.to_str()
UserGroupEntity.uri
- nipyapi.nifi.models.user_groups_entity module
- nipyapi.nifi.models.users_entity module
- nipyapi.nifi.models.variable_dto module
- nipyapi.nifi.models.variable_entity module
- nipyapi.nifi.models.variable_registry_dto module
- nipyapi.nifi.models.variable_registry_entity module
- nipyapi.nifi.models.variable_registry_update_request_dto module
VariableRegistryUpdateRequestDTO
VariableRegistryUpdateRequestDTO.affected_components
VariableRegistryUpdateRequestDTO.attribute_map
VariableRegistryUpdateRequestDTO.complete
VariableRegistryUpdateRequestDTO.failure_reason
VariableRegistryUpdateRequestDTO.last_updated
VariableRegistryUpdateRequestDTO.percent_completed
VariableRegistryUpdateRequestDTO.process_group_id
VariableRegistryUpdateRequestDTO.request_id
VariableRegistryUpdateRequestDTO.state
VariableRegistryUpdateRequestDTO.submission_time
VariableRegistryUpdateRequestDTO.swagger_types
VariableRegistryUpdateRequestDTO.to_dict()
VariableRegistryUpdateRequestDTO.to_str()
VariableRegistryUpdateRequestDTO.update_steps
VariableRegistryUpdateRequestDTO.uri
- nipyapi.nifi.models.variable_registry_update_request_entity module
- nipyapi.nifi.models.variable_registry_update_step_dto module
- nipyapi.nifi.models.version_control_component_mapping_entity module
VersionControlComponentMappingEntity
VersionControlComponentMappingEntity.attribute_map
VersionControlComponentMappingEntity.disconnected_node_acknowledged
VersionControlComponentMappingEntity.process_group_revision
VersionControlComponentMappingEntity.swagger_types
VersionControlComponentMappingEntity.to_dict()
VersionControlComponentMappingEntity.to_str()
VersionControlComponentMappingEntity.version_control_component_mapping
VersionControlComponentMappingEntity.version_control_information
- nipyapi.nifi.models.version_control_information_dto module
VersionControlInformationDTO
VersionControlInformationDTO.attribute_map
VersionControlInformationDTO.bucket_id
VersionControlInformationDTO.bucket_name
VersionControlInformationDTO.flow_description
VersionControlInformationDTO.flow_id
VersionControlInformationDTO.flow_name
VersionControlInformationDTO.group_id
VersionControlInformationDTO.registry_id
VersionControlInformationDTO.registry_name
VersionControlInformationDTO.state
VersionControlInformationDTO.state_explanation
VersionControlInformationDTO.storage_location
VersionControlInformationDTO.swagger_types
VersionControlInformationDTO.to_dict()
VersionControlInformationDTO.to_str()
VersionControlInformationDTO.version
- nipyapi.nifi.models.version_control_information_entity module
VersionControlInformationEntity
VersionControlInformationEntity.attribute_map
VersionControlInformationEntity.disconnected_node_acknowledged
VersionControlInformationEntity.process_group_revision
VersionControlInformationEntity.swagger_types
VersionControlInformationEntity.to_dict()
VersionControlInformationEntity.to_str()
VersionControlInformationEntity.version_control_information
- nipyapi.nifi.models.version_info_dto module
VersionInfoDTO
VersionInfoDTO.attribute_map
VersionInfoDTO.build_branch
VersionInfoDTO.build_revision
VersionInfoDTO.build_tag
VersionInfoDTO.build_timestamp
VersionInfoDTO.java_vendor
VersionInfoDTO.java_version
VersionInfoDTO.ni_fi_version
VersionInfoDTO.os_architecture
VersionInfoDTO.os_name
VersionInfoDTO.os_version
VersionInfoDTO.swagger_types
VersionInfoDTO.to_dict()
VersionInfoDTO.to_str()
- nipyapi.nifi.models.versioned_connection module
VersionedConnection
VersionedConnection.attribute_map
VersionedConnection.back_pressure_data_size_threshold
VersionedConnection.back_pressure_object_threshold
VersionedConnection.bends
VersionedConnection.comments
VersionedConnection.component_type
VersionedConnection.destination
VersionedConnection.flow_file_expiration
VersionedConnection.group_identifier
VersionedConnection.identifier
VersionedConnection.instance_identifier
VersionedConnection.label_index
VersionedConnection.load_balance_compression
VersionedConnection.load_balance_strategy
VersionedConnection.name
VersionedConnection.partitioning_attribute
VersionedConnection.position
VersionedConnection.prioritizers
VersionedConnection.selected_relationships
VersionedConnection.source
VersionedConnection.swagger_types
VersionedConnection.to_dict()
VersionedConnection.to_str()
VersionedConnection.z_index
- nipyapi.nifi.models.versioned_controller_service module
VersionedControllerService
VersionedControllerService.annotation_data
VersionedControllerService.attribute_map
VersionedControllerService.bulletin_level
VersionedControllerService.bundle
VersionedControllerService.comments
VersionedControllerService.component_type
VersionedControllerService.controller_service_apis
VersionedControllerService.group_identifier
VersionedControllerService.identifier
VersionedControllerService.instance_identifier
VersionedControllerService.name
VersionedControllerService.position
VersionedControllerService.properties
VersionedControllerService.property_descriptors
VersionedControllerService.scheduled_state
VersionedControllerService.swagger_types
VersionedControllerService.to_dict()
VersionedControllerService.to_str()
VersionedControllerService.type
- nipyapi.nifi.models.versioned_flow module
- nipyapi.nifi.models.versioned_flow_coordinates module
VersionedFlowCoordinates
VersionedFlowCoordinates.attribute_map
VersionedFlowCoordinates.bucket_id
VersionedFlowCoordinates.flow_id
VersionedFlowCoordinates.latest
VersionedFlowCoordinates.registry_id
VersionedFlowCoordinates.registry_url
VersionedFlowCoordinates.storage_location
VersionedFlowCoordinates.swagger_types
VersionedFlowCoordinates.to_dict()
VersionedFlowCoordinates.to_str()
VersionedFlowCoordinates.version
- nipyapi.nifi.models.versioned_flow_dto module
VersionedFlowDTO
VersionedFlowDTO.action
VersionedFlowDTO.attribute_map
VersionedFlowDTO.bucket_id
VersionedFlowDTO.comments
VersionedFlowDTO.description
VersionedFlowDTO.flow_id
VersionedFlowDTO.flow_name
VersionedFlowDTO.registry_id
VersionedFlowDTO.swagger_types
VersionedFlowDTO.to_dict()
VersionedFlowDTO.to_str()
- nipyapi.nifi.models.versioned_flow_entity module
- nipyapi.nifi.models.versioned_flow_snapshot module
- nipyapi.nifi.models.versioned_flow_snapshot_entity module
VersionedFlowSnapshotEntity
VersionedFlowSnapshotEntity.attribute_map
VersionedFlowSnapshotEntity.disconnected_node_acknowledged
VersionedFlowSnapshotEntity.process_group_revision
VersionedFlowSnapshotEntity.registry_id
VersionedFlowSnapshotEntity.swagger_types
VersionedFlowSnapshotEntity.to_dict()
VersionedFlowSnapshotEntity.to_str()
VersionedFlowSnapshotEntity.update_descendant_versioned_flows
VersionedFlowSnapshotEntity.versioned_flow_snapshot
- nipyapi.nifi.models.versioned_flow_snapshot_metadata_entity module
VersionedFlowSnapshotMetadataEntity
VersionedFlowSnapshotMetadataEntity.attribute_map
VersionedFlowSnapshotMetadataEntity.registry_id
VersionedFlowSnapshotMetadataEntity.swagger_types
VersionedFlowSnapshotMetadataEntity.to_dict()
VersionedFlowSnapshotMetadataEntity.to_str()
VersionedFlowSnapshotMetadataEntity.versioned_flow_snapshot_metadata
- nipyapi.nifi.models.versioned_flow_snapshot_metadata_set_entity module
- nipyapi.nifi.models.versioned_flow_update_request_dto module
VersionedFlowUpdateRequestDTO
VersionedFlowUpdateRequestDTO.attribute_map
VersionedFlowUpdateRequestDTO.complete
VersionedFlowUpdateRequestDTO.failure_reason
VersionedFlowUpdateRequestDTO.last_updated
VersionedFlowUpdateRequestDTO.percent_completed
VersionedFlowUpdateRequestDTO.process_group_id
VersionedFlowUpdateRequestDTO.request_id
VersionedFlowUpdateRequestDTO.state
VersionedFlowUpdateRequestDTO.swagger_types
VersionedFlowUpdateRequestDTO.to_dict()
VersionedFlowUpdateRequestDTO.to_str()
VersionedFlowUpdateRequestDTO.uri
VersionedFlowUpdateRequestDTO.version_control_information
- nipyapi.nifi.models.versioned_flow_update_request_entity module
- nipyapi.nifi.models.versioned_flows_entity module
- nipyapi.nifi.models.versioned_funnel module
VersionedFunnel
VersionedFunnel.attribute_map
VersionedFunnel.comments
VersionedFunnel.component_type
VersionedFunnel.group_identifier
VersionedFunnel.identifier
VersionedFunnel.instance_identifier
VersionedFunnel.name
VersionedFunnel.position
VersionedFunnel.swagger_types
VersionedFunnel.to_dict()
VersionedFunnel.to_str()
- nipyapi.nifi.models.versioned_label module
VersionedLabel
VersionedLabel.attribute_map
VersionedLabel.comments
VersionedLabel.component_type
VersionedLabel.group_identifier
VersionedLabel.height
VersionedLabel.identifier
VersionedLabel.instance_identifier
VersionedLabel.label
VersionedLabel.name
VersionedLabel.position
VersionedLabel.style
VersionedLabel.swagger_types
VersionedLabel.to_dict()
VersionedLabel.to_str()
VersionedLabel.width
VersionedLabel.z_index
- nipyapi.nifi.models.versioned_port module
VersionedPort
VersionedPort.allow_remote_access
VersionedPort.attribute_map
VersionedPort.comments
VersionedPort.component_type
VersionedPort.concurrently_schedulable_task_count
VersionedPort.group_identifier
VersionedPort.identifier
VersionedPort.instance_identifier
VersionedPort.name
VersionedPort.position
VersionedPort.scheduled_state
VersionedPort.swagger_types
VersionedPort.to_dict()
VersionedPort.to_str()
VersionedPort.type
- nipyapi.nifi.models.versioned_process_group module
VersionedProcessGroup
VersionedProcessGroup.attribute_map
VersionedProcessGroup.comments
VersionedProcessGroup.component_type
VersionedProcessGroup.connections
VersionedProcessGroup.controller_services
VersionedProcessGroup.default_back_pressure_data_size_threshold
VersionedProcessGroup.default_back_pressure_object_threshold
VersionedProcessGroup.default_flow_file_expiration
VersionedProcessGroup.flow_file_concurrency
VersionedProcessGroup.flow_file_outbound_policy
VersionedProcessGroup.funnels
VersionedProcessGroup.group_identifier
VersionedProcessGroup.identifier
VersionedProcessGroup.input_ports
VersionedProcessGroup.instance_identifier
VersionedProcessGroup.labels
VersionedProcessGroup.log_file_suffix
VersionedProcessGroup.name
VersionedProcessGroup.output_ports
VersionedProcessGroup.parameter_context_name
VersionedProcessGroup.position
VersionedProcessGroup.process_groups
VersionedProcessGroup.processors
VersionedProcessGroup.remote_process_groups
VersionedProcessGroup.swagger_types
VersionedProcessGroup.to_dict()
VersionedProcessGroup.to_str()
VersionedProcessGroup.variables
VersionedProcessGroup.versioned_flow_coordinates
- nipyapi.nifi.models.versioned_processor module
VersionedProcessor
VersionedProcessor.annotation_data
VersionedProcessor.attribute_map
VersionedProcessor.auto_terminated_relationships
VersionedProcessor.backoff_mechanism
VersionedProcessor.bulletin_level
VersionedProcessor.bundle
VersionedProcessor.comments
VersionedProcessor.component_type
VersionedProcessor.concurrently_schedulable_task_count
VersionedProcessor.execution_node
VersionedProcessor.group_identifier
VersionedProcessor.identifier
VersionedProcessor.instance_identifier
VersionedProcessor.max_backoff_period
VersionedProcessor.name
VersionedProcessor.penalty_duration
VersionedProcessor.position
VersionedProcessor.properties
VersionedProcessor.property_descriptors
VersionedProcessor.retried_relationships
VersionedProcessor.retry_count
VersionedProcessor.run_duration_millis
VersionedProcessor.scheduled_state
VersionedProcessor.scheduling_period
VersionedProcessor.scheduling_strategy
VersionedProcessor.style
VersionedProcessor.swagger_types
VersionedProcessor.to_dict()
VersionedProcessor.to_str()
VersionedProcessor.type
VersionedProcessor.yield_duration
- nipyapi.nifi.models.versioned_property_descriptor module
VersionedPropertyDescriptor
VersionedPropertyDescriptor.attribute_map
VersionedPropertyDescriptor.display_name
VersionedPropertyDescriptor.identifies_controller_service
VersionedPropertyDescriptor.name
VersionedPropertyDescriptor.resource_definition
VersionedPropertyDescriptor.sensitive
VersionedPropertyDescriptor.swagger_types
VersionedPropertyDescriptor.to_dict()
VersionedPropertyDescriptor.to_str()
- nipyapi.nifi.models.versioned_remote_group_port module
VersionedRemoteGroupPort
VersionedRemoteGroupPort.attribute_map
VersionedRemoteGroupPort.batch_size
VersionedRemoteGroupPort.comments
VersionedRemoteGroupPort.component_type
VersionedRemoteGroupPort.concurrently_schedulable_task_count
VersionedRemoteGroupPort.group_identifier
VersionedRemoteGroupPort.identifier
VersionedRemoteGroupPort.instance_identifier
VersionedRemoteGroupPort.name
VersionedRemoteGroupPort.position
VersionedRemoteGroupPort.remote_group_id
VersionedRemoteGroupPort.scheduled_state
VersionedRemoteGroupPort.swagger_types
VersionedRemoteGroupPort.target_id
VersionedRemoteGroupPort.to_dict()
VersionedRemoteGroupPort.to_str()
VersionedRemoteGroupPort.use_compression
- nipyapi.nifi.models.versioned_remote_process_group module
VersionedRemoteProcessGroup
VersionedRemoteProcessGroup.attribute_map
VersionedRemoteProcessGroup.comments
VersionedRemoteProcessGroup.communications_timeout
VersionedRemoteProcessGroup.component_type
VersionedRemoteProcessGroup.group_identifier
VersionedRemoteProcessGroup.identifier
VersionedRemoteProcessGroup.input_ports
VersionedRemoteProcessGroup.instance_identifier
VersionedRemoteProcessGroup.local_network_interface
VersionedRemoteProcessGroup.name
VersionedRemoteProcessGroup.output_ports
VersionedRemoteProcessGroup.position
VersionedRemoteProcessGroup.proxy_host
VersionedRemoteProcessGroup.proxy_password
VersionedRemoteProcessGroup.proxy_port
VersionedRemoteProcessGroup.proxy_user
VersionedRemoteProcessGroup.swagger_types
VersionedRemoteProcessGroup.target_uri
VersionedRemoteProcessGroup.target_uris
VersionedRemoteProcessGroup.to_dict()
VersionedRemoteProcessGroup.to_str()
VersionedRemoteProcessGroup.transport_protocol
VersionedRemoteProcessGroup.yield_duration
Submodules
nipyapi.nifi.api_client module
NiFi Rest API
The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description, definitions of the expected input and output, potential response codes, and the authorizations required to invoke each service.
OpenAPI spec version: 1.23.2 Contact: dev@nifi.apache.org Generated by: https://github.com/swagger-api/swagger-codegen.git
- class nipyapi.nifi.api_client.ApiClient(host=None, header_name=None, header_value=None, cookie=None)[source]
Bases:
object
Generic API client for Swagger client library builds.
Swagger generic API client. This client handles the client- server communication, and is invariant across implementations. Specifics of the methods and models for each application are generated from the Swagger templates.
NOTE: This class is auto generated by the swagger code generator program. Ref: https://github.com/swagger-api/swagger-codegen Do not edit the class manually.
- Parameters:
host – The base path for the server to call.
header_name – a header to pass when making calls to the API.
header_value – a header value to pass when making calls to the API.
Constructor of the class.
- NATIVE_TYPES_MAPPING = {'bool': <class 'bool'>, 'date': <class 'datetime.date'>, 'datetime': <class 'datetime.datetime'>, 'float': <class 'float'>, 'int': <class 'int'>, 'long': <class 'int'>, 'object': <class 'object'>, 'str': <class 'str'>}
- PRIMITIVE_TYPES = (<class 'float'>, <class 'bool'>, <class 'bytes'>, <class 'str'>, <class 'int'>)
- call_api(resource_path, method, path_params=None, query_params=None, header_params=None, body=None, post_params=None, files=None, response_type=None, auth_settings=None, callback=None, _return_http_data_only=None, collection_formats=None, _preload_content=True, _request_timeout=None)[source]
Makes the HTTP request (synchronous) and return the deserialized data. To make an async request, define a function for callback.
- Parameters:
resource_path – Path to method endpoint.
method – Method to call.
path_params – Path parameters in the url.
query_params – Query parameters in the url.
header_params – Header parameters to be placed in the request header.
body – Request body.
dict (files) – Request post form parameters, for application/x-www-form-urlencoded, multipart/form-data.
list (auth_settings) – Auth Settings names for the request.
response – Response data type.
dict – key -> filename, value -> filepath, for multipart/form-data.
function (callback) – Callback function for asynchronous request. If provide this parameter, the request will be called asynchronously.
_return_http_data_only – response data without head status code and headers
collection_formats – dict of collection formats for path, query, header, and post parameters.
_preload_content – if False, the urllib3.HTTPResponse object will be returned without reading/decoding response data. Default is True.
_request_timeout – timeout setting for this request. If one number provided, it will be total request timeout. It can also be a pair (tuple) of (connection, read) timeouts.
- Returns:
If provide parameter callback, the request will be called asynchronously. The method will return the request thread. If parameter callback is None, then the method will return the response directly.
- deserialize(response, response_type)[source]
Deserializes response into an object.
- Parameters:
response – RESTResponse object to be deserialized.
response_type – class literal for deserialized object, or string of class name.
- Returns:
deserialized object.
- deserialize_model(data, klass)[source]
Deserializes list or dict to model.
- Parameters:
data – dict, list.
klass – class literal.
- Returns:
model object.
- parameters_to_tuples(params, collection_formats)[source]
Get parameters as list of tuples, formatting collections.
- Parameters:
params – Parameters as dict or list of two-tuples
collection_formats (dict) – Parameter collection formats
- Returns:
Parameters as list of tuples, collections formatted
- prepare_post_parameters(post_params=None, files=None)[source]
Builds form parameters.
- Parameters:
post_params – Normal form parameters.
files – File parameters.
- Returns:
Form parameters with files.
- request(method, url, query_params=None, headers=None, post_params=None, body=None, _preload_content=True, _request_timeout=None)[source]
Makes the HTTP request using RESTClient.
- sanitize_for_serialization(obj)[source]
Builds a JSON POST object.
If obj is None, return None. If obj is str, int, long, float, bool, return directly. If obj is datetime.datetime, datetime.date
convert to string in iso8601 format.
If obj is list, sanitize each element in the list. If obj is dict, return the dict. If obj is swagger model, return the properties dict.
- Parameters:
obj – The data to serialize.
- Returns:
The serialized form of data.
- select_header_accept(accepts)[source]
Returns Accept based on an array of accepts provided.
- Parameters:
accepts – List of headers.
- Returns:
Accept (e.g. application/json).
- select_header_content_type(content_types)[source]
Returns Content-Type based on an array of content_types provided.
- Parameters:
content_types – List of content-types.
- Returns:
Content-Type (e.g. application/json).
- update_params_for_auth(headers, querys, auth_settings)[source]
Updates header and query params based on authentication setting.
- Parameters:
headers – Header parameters dict to be updated.
querys – Query parameters tuple list to be updated.
auth_settings – Authentication setting identifiers list.
- property user_agent
Gets user agent.
nipyapi.nifi.configuration module
NiFi Rest API
The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description, definitions of the expected input and output, potential response codes, and the authorizations required to invoke each service.
OpenAPI spec version: 1.23.2 Contact: dev@nifi.apache.org Generated by: https://github.com/swagger-api/swagger-codegen.git
nipyapi.nifi.rest module
NiFi Rest API
The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description, definitions of the expected input and output, potential response codes, and the authorizations required to invoke each service.
OpenAPI spec version: 1.23.2 Contact: dev@nifi.apache.org Generated by: https://github.com/swagger-api/swagger-codegen.git
- exception nipyapi.nifi.rest.ApiException(status=None, reason=None, http_resp=None)[source]
Bases:
Exception
- class nipyapi.nifi.rest.RESTClientObject(pools_size=4, maxsize=4)[source]
Bases:
object
- DELETE(url, headers=None, query_params=None, body=None, _preload_content=True, _request_timeout=None)[source]
- OPTIONS(url, headers=None, query_params=None, post_params=None, body=None, _preload_content=True, _request_timeout=None)[source]
- PATCH(url, headers=None, query_params=None, post_params=None, body=None, _preload_content=True, _request_timeout=None)[source]
- POST(url, headers=None, query_params=None, post_params=None, body=None, _preload_content=True, _request_timeout=None)[source]
- PUT(url, headers=None, query_params=None, post_params=None, body=None, _preload_content=True, _request_timeout=None)[source]
- request(method, url, query_params=None, headers=None, body=None, post_params=None, _preload_content=True, _request_timeout=None)[source]
- Parameters:
method – http request method
url – http request url
query_params – query parameters in the url
headers – http request headers
body – request json body, for application/json
post_params – request post parameters, application/x-www-form-urlencoded and multipart/form-data
_preload_content – if False, the urllib3.HTTPResponse object will be returned without reading/decoding response data. Default is True.
_request_timeout – timeout setting for this request. If one number provided, it will be total request timeout. It can also be a pair (tuple) of (connection, read) timeouts.