MCPcopy Create free account

hub / github.com/apache/nifi-minifi-cpp / functions

Functions5,249 in github.com/apache/nifi-minifi-cpp

↓ 1 callersMethodtransfer
(self, session, ff, rel)
python/minifi/__init__.py:81
↓ 1 callersMethodtransfer
(FlowFile flowFile, Relationship relationship)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java:137
↓ 1 callersMethodtransferFlowsToFail
extensions/libarchive/BinFiles.cpp:333
↓ 1 callersFunctiontransfer_file_or_directory
nanofi/examples/transmit_flow.c:35
↓ 1 callersMethodtransmitPayload
libminifi/src/sitetosite/RawSocketProtocol.cpp:533
↓ 1 callersMethodtransmit_flowfile
(self, ff)
python/minifi/__init__.py:221
↓ 1 callersFunctiontransmit_to_nifi
nanofi/include/blocks/comms.h:34
↓ 1 callersMethodtry_lock
* Spin lock to unlock the current atomic entry. */
libminifi/include/core/repository/AtomicRepoEntries.h:437
↓ 1 callersMethodunpackNars
(final File narFilesDir, final File unpackDirectory, List<File> paths )
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/nar/JniUnpacker.java:65
↓ 1 callersMethodupdateAttribute
libminifi/src/core/FlowFile.cpp:174
↓ 1 callersMethodupdateAttribute
extensions/script/ScriptFlowFile.cpp:63
↓ 1 callersMethodupdateMapState
extensions/sql/data/MaxCollector.h:135
↓ 1 callersFunctionupdate_keys_in_legacy_states
extensions/standard-processors/processors/TailFile.cpp:155
↓ 1 callersFunctionupdate_proc_params
nanofi/src/api/ecu.c:186
↓ 1 callersMethoduseLatestFlowFile
extensions/standard-processors/processors/TailFile.cpp:253
↓ 1 callersMethodvalidate
* Validate the payload, if necessary and/or possible. */
libminifi/include/c2/C2Payload.h:141
↓ 1 callersFunctionverify_uuid
nanofi/tests/CUUIDTests.cpp:25
↓ 1 callersMethodwaitForCompletion
extensions/librdkafka/PublishKafka.cpp:236
↓ 1 callersMethodwaitUnload
libminifi/test/unit/ProvenanceTestHelper.h:261
↓ 1 callersMethodwait_for_output
(self, timeout_seconds)
docker/test/integration/minifi/core/DockerTestCluster.py:132
↓ 1 callersMethodwaitingOps
libminifi/src/utils/ByteArrayCallback.cpp:74
↓ 1 callersMethodwasInterrupted
extensions/librdkafka/PublishKafka.cpp:283
↓ 1 callersFunctionwindowsUuidGenerateTime
libminifi/src/utils/Id.cpp:64
↓ 1 callersFunctionwindows_uuid_generate_random
nanofi/src/core/cuuid.c:50
↓ 1 callersFunctionwindows_uuid_generate_time
nanofi/src/core/cuuid.c:44
↓ 1 callersMethodwrite
libminifi/src/utils/ByteArrayCallback.cpp:52
↓ 1 callersMethodwrite
libminifi/src/utils/FileOutputCallback.cpp:52
↓ 1 callersMethodwrite
libminifi/include/utils/ByteArrayCallback.h:63
↓ 1 callersFunctionwrite_UTF
nanofi/include/sitetosite/CSiteToSite.h:390
↓ 1 callersFunctionwrite_uint16_t
nanofi/src/core/cstream.c:43
↓ 1 callersFunctionwrite_uint16t
nanofi/include/sitetosite/CSiteToSite.h:355
↓ 1 callersMethodyield
libminifi/test/unit/MockClasses.h:57
↓ 1 callersMethodyield
extensions/http-curl/client/HTTPClient.h:212
MethodAWSCredentialsProvider
extensions/aws/AWSCredentialsProvider.cpp:32
MethodAWSCredentialsService
extensions/aws/controllerservices/AWSCredentialsService.h:46
MethodAWSInitializer
extensions/aws/utils/AWSInitializer.cpp:48
MethodAWSObjectFactory
extensions/aws/AWSLoader.h:34
MethodAbstractAutoPersistingKeyValueStoreService
libminifi/src/controllers/keyvalue/AbstractAutoPersistingKeyValueStoreService.cpp:35
MethodAbstractCoreComponentStateManager
libminifi/src/controllers/keyvalue/AbstractCoreComponentStateManagerProvider.cpp:33
MethodAbstractMQTTProcessor
Constructor ! * Create a new processor */
extensions/mqtt/processors/AbstractMQTTProcessor.h:51
MethodAfterExecute
libminifi/include/utils/Monitors.h:42
MethodAgentDocs
main/AgentDocs.h:31
MethodAgentIdentifier
libminifi/include/core/state/nodes/AgentInformation.h:503
MethodAgentInformation
libminifi/include/core/state/nodes/AgentInformation.h:690
MethodAgentManifest
libminifi/include/core/state/nodes/AgentInformation.h:545
MethodAgentMonitor
libminifi/include/core/state/nodes/AgentInformation.h:522
MethodAgentNode
libminifi/include/core/state/nodes/AgentInformation.h:627
MethodAgentPrinter
extensions/http-curl/protocols/AgentPrinter.cpp:37
MethodAgentStatus
libminifi/include/core/state/nodes/AgentInformation.h:410
MethodAlwaysValid
libminifi/include/core/PropertyValidation.h:121
MethodAppendHostInfo
Constructor ! * Create a new processor */
extensions/standard-processors/processors/AppendHostInfo.h:47
MethodApplyTemplate
! * Create a new processor */
extensions/bustache/ApplyTemplate.h:44
MethodArchiveEntryReader
libminifi/test/archive-tests/MergeFileTests.cpp:113
MethodArchiveFactory
extensions/libarchive/ArchiveLoader.h:30
MethodArchiveWriter
extensions/libarchive/MergeContent.h:124
MethodAtomicEntry
* Constructor that accepts a max size and an atomic counter for the total * size allowd by this and other atomic entries. */
libminifi/include/core/repository/AtomicRepoEntries.h:177
MethodAtomicEntryStream
libminifi/include/io/AtomicEntryStream.h:42
MethodAttributeMerger
extensions/libarchive/MergeContent.h:256
MethodBackTrace
libminifi/include/utils/BackTrace.h:49
MethodBaseHTTPClient
libminifi/include/utils/HTTPClient.h:297
MethodBaseOPCProcessor
extensions/opc/include/opcbase.h:48
MethodBin
Constructor ! * Create a new Bin. Note: this object is not thread safe */
extensions/libarchive/BinFiles.h:49
MethodBinaryConcatenationMerge
extensions/libarchive/MergeContent.cpp:348
MethodBookmark
extensions/windows-event-log/Bookmark.cpp:33
MethodBoolValue
libminifi/include/core/state/Value.h:245
MethodBooleanValidator
libminifi/include/core/PropertyValidation.h:139
MethodBufferReader
libminifi/test/BufferReader.h:27
MethodBufferStream
libminifi/include/io/BufferStream.h:36
MethodBuildInformation
libminifi/include/core/state/nodes/BuildInformation.h:71
MethodBundles
libminifi/include/core/state/nodes/AgentInformation.h:332
MethodByteInputCallBack
libminifi/include/utils/ByteArrayCallback.h:39
MethodByteOutputCallback
libminifi/include/utils/ByteArrayCallback.h:93
MethodC2Agent
libminifi/src/c2/C2Agent.cpp:54
MethodC2CallbackAgent
nanofi/src/cxx/C2CallbackAgent.cpp:37
MethodC2Client
libminifi/src/c2/C2Client.cpp:39
MethodC2ContentResponse
libminifi/include/c2/C2Payload.h:75
MethodC2FailedUpdateHandler
extensions/http-curl/tests/HTTPHandlers.h:523
MethodC2FlowProvider
extensions/http-curl/tests/HTTPHandlers.h:453
MethodC2HeartbeatHandler
extensions/http-curl/tests/C2RequestClassTest.cpp:57
MethodC2Payload
libminifi/src/c2/C2Payload.cpp:30
MethodC2Payload
libminifi/include/c2/C2Payload.h:120
MethodC2Protocol
libminifi/include/c2/C2Protocol.h:39
MethodC2Trigger
libminifi/include/c2/C2Trigger.h:43
MethodCOAPObjectFactory
extensions/coap/COAPLoader.h:45
MethodCRCStream
libminifi/include/io/CRCStream.h:127
MethodCachedValueValidator
libminifi/include/core/CachedValueValidator.h:48
MethodCallBack
extensions/http-curl/tests/unit/InvokeHTTPTests.cpp:150
MethodCallBackTimer
libminifi/src/utils/CallBackTimer.cpp:28
MethodCallbackProcessor
Constructor ! * Create a new processor */
nanofi/include/cxx/CallbackProcessor.h:56
MethodCapturePacket
Constructor ! * Create a new processor */
extensions/pcap/CapturePacket.h:100
MethodCapturePacketMechanism
extensions/pcap/CapturePacket.h:46
MethodCaptureRTSPFrame
extensions/opencv/CaptureRTSPFrame.h:40
MethodCaptureRTSPFrameWriteCallback
extensions/opencv/CaptureRTSPFrame.h:67
MethodChild
extensions/sftp/processors/ListSFTP.cpp:289
MethodCivetLibrary
extensions/http-curl/tests/TestServer.h:36
MethodCivetStream
* File Stream constructor that accepts an fstream shared pointer. * It must already be initialized for read and write. */
extensions/http-curl/tests/CivetStream.h:43
MethodClassDescription
libminifi/include/agent/build_description.h:34
MethodClassRegistrar
extensions/jni/ClassRegistrar.h:67
MethodClient
extensions/opc/src/opc.cpp:117
MethodCoapConnectorService
extensions/coap/controllerservice/CoapConnector.h:47
← previousnext →1,801–1,900 of 5,249, ranked by callers