Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/nifi-minifi-cpp
/ functions
Functions
5,249 in github.com/apache/nifi-minifi-cpp
⨍
Functions
5,249
◇
Types & classes
1,209
↓ 1 callers
Method
transfer
(self, session, ff, rel)
python/minifi/__init__.py:81
↓ 1 callers
Method
transfer
(FlowFile flowFile, Relationship relationship)
extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java:137
↓ 1 callers
Method
transferFlowsToFail
extensions/libarchive/BinFiles.cpp:333
↓ 1 callers
Function
transfer_file_or_directory
nanofi/examples/transmit_flow.c:35
↓ 1 callers
Method
transmitPayload
libminifi/src/sitetosite/RawSocketProtocol.cpp:533
↓ 1 callers
Method
transmit_flowfile
(self, ff)
python/minifi/__init__.py:221
↓ 1 callers
Function
transmit_to_nifi
nanofi/include/blocks/comms.h:34
↓ 1 callers
Method
try_lock
* Spin lock to unlock the current atomic entry. */
libminifi/include/core/repository/AtomicRepoEntries.h:437
↓ 1 callers
Method
unpackNars
(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 callers
Method
updateAttribute
libminifi/src/core/FlowFile.cpp:174
↓ 1 callers
Method
updateAttribute
extensions/script/ScriptFlowFile.cpp:63
↓ 1 callers
Method
updateMapState
extensions/sql/data/MaxCollector.h:135
↓ 1 callers
Function
update_keys_in_legacy_states
extensions/standard-processors/processors/TailFile.cpp:155
↓ 1 callers
Function
update_proc_params
nanofi/src/api/ecu.c:186
↓ 1 callers
Method
useLatestFlowFile
extensions/standard-processors/processors/TailFile.cpp:253
↓ 1 callers
Method
validate
* Validate the payload, if necessary and/or possible. */
libminifi/include/c2/C2Payload.h:141
↓ 1 callers
Function
verify_uuid
nanofi/tests/CUUIDTests.cpp:25
↓ 1 callers
Method
waitForCompletion
extensions/librdkafka/PublishKafka.cpp:236
↓ 1 callers
Method
waitUnload
libminifi/test/unit/ProvenanceTestHelper.h:261
↓ 1 callers
Method
wait_for_output
(self, timeout_seconds)
docker/test/integration/minifi/core/DockerTestCluster.py:132
↓ 1 callers
Method
waitingOps
libminifi/src/utils/ByteArrayCallback.cpp:74
↓ 1 callers
Method
wasInterrupted
extensions/librdkafka/PublishKafka.cpp:283
↓ 1 callers
Function
windowsUuidGenerateTime
libminifi/src/utils/Id.cpp:64
↓ 1 callers
Function
windows_uuid_generate_random
nanofi/src/core/cuuid.c:50
↓ 1 callers
Function
windows_uuid_generate_time
nanofi/src/core/cuuid.c:44
↓ 1 callers
Method
write
libminifi/src/utils/ByteArrayCallback.cpp:52
↓ 1 callers
Method
write
libminifi/src/utils/FileOutputCallback.cpp:52
↓ 1 callers
Method
write
libminifi/include/utils/ByteArrayCallback.h:63
↓ 1 callers
Function
write_UTF
nanofi/include/sitetosite/CSiteToSite.h:390
↓ 1 callers
Function
write_uint16_t
nanofi/src/core/cstream.c:43
↓ 1 callers
Function
write_uint16t
nanofi/include/sitetosite/CSiteToSite.h:355
↓ 1 callers
Method
yield
libminifi/test/unit/MockClasses.h:57
↓ 1 callers
Method
yield
extensions/http-curl/client/HTTPClient.h:212
Method
AWSCredentialsProvider
extensions/aws/AWSCredentialsProvider.cpp:32
Method
AWSCredentialsService
extensions/aws/controllerservices/AWSCredentialsService.h:46
Method
AWSInitializer
extensions/aws/utils/AWSInitializer.cpp:48
Method
AWSObjectFactory
extensions/aws/AWSLoader.h:34
Method
AbstractAutoPersistingKeyValueStoreService
libminifi/src/controllers/keyvalue/AbstractAutoPersistingKeyValueStoreService.cpp:35
Method
AbstractCoreComponentStateManager
libminifi/src/controllers/keyvalue/AbstractCoreComponentStateManagerProvider.cpp:33
Method
AbstractMQTTProcessor
Constructor ! * Create a new processor */
extensions/mqtt/processors/AbstractMQTTProcessor.h:51
Method
AfterExecute
libminifi/include/utils/Monitors.h:42
Method
AgentDocs
main/AgentDocs.h:31
Method
AgentIdentifier
libminifi/include/core/state/nodes/AgentInformation.h:503
Method
AgentInformation
libminifi/include/core/state/nodes/AgentInformation.h:690
Method
AgentManifest
libminifi/include/core/state/nodes/AgentInformation.h:545
Method
AgentMonitor
libminifi/include/core/state/nodes/AgentInformation.h:522
Method
AgentNode
libminifi/include/core/state/nodes/AgentInformation.h:627
Method
AgentPrinter
extensions/http-curl/protocols/AgentPrinter.cpp:37
Method
AgentStatus
libminifi/include/core/state/nodes/AgentInformation.h:410
Method
AlwaysValid
libminifi/include/core/PropertyValidation.h:121
Method
AppendHostInfo
Constructor ! * Create a new processor */
extensions/standard-processors/processors/AppendHostInfo.h:47
Method
ApplyTemplate
! * Create a new processor */
extensions/bustache/ApplyTemplate.h:44
Method
ArchiveEntryReader
libminifi/test/archive-tests/MergeFileTests.cpp:113
Method
ArchiveFactory
extensions/libarchive/ArchiveLoader.h:30
Method
ArchiveWriter
extensions/libarchive/MergeContent.h:124
Method
AtomicEntry
* 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
Method
AtomicEntryStream
libminifi/include/io/AtomicEntryStream.h:42
Method
AttributeMerger
extensions/libarchive/MergeContent.h:256
Method
BackTrace
libminifi/include/utils/BackTrace.h:49
Method
BaseHTTPClient
libminifi/include/utils/HTTPClient.h:297
Method
BaseOPCProcessor
extensions/opc/include/opcbase.h:48
Method
Bin
Constructor ! * Create a new Bin. Note: this object is not thread safe */
extensions/libarchive/BinFiles.h:49
Method
BinaryConcatenationMerge
extensions/libarchive/MergeContent.cpp:348
Method
Bookmark
extensions/windows-event-log/Bookmark.cpp:33
Method
BoolValue
libminifi/include/core/state/Value.h:245
Method
BooleanValidator
libminifi/include/core/PropertyValidation.h:139
Method
BufferReader
libminifi/test/BufferReader.h:27
Method
BufferStream
libminifi/include/io/BufferStream.h:36
Method
BuildInformation
libminifi/include/core/state/nodes/BuildInformation.h:71
Method
Bundles
libminifi/include/core/state/nodes/AgentInformation.h:332
Method
ByteInputCallBack
libminifi/include/utils/ByteArrayCallback.h:39
Method
ByteOutputCallback
libminifi/include/utils/ByteArrayCallback.h:93
Method
C2Agent
libminifi/src/c2/C2Agent.cpp:54
Method
C2CallbackAgent
nanofi/src/cxx/C2CallbackAgent.cpp:37
Method
C2Client
libminifi/src/c2/C2Client.cpp:39
Method
C2ContentResponse
libminifi/include/c2/C2Payload.h:75
Method
C2FailedUpdateHandler
extensions/http-curl/tests/HTTPHandlers.h:523
Method
C2FlowProvider
extensions/http-curl/tests/HTTPHandlers.h:453
Method
C2HeartbeatHandler
extensions/http-curl/tests/C2RequestClassTest.cpp:57
Method
C2Payload
libminifi/src/c2/C2Payload.cpp:30
Method
C2Payload
libminifi/include/c2/C2Payload.h:120
Method
C2Protocol
libminifi/include/c2/C2Protocol.h:39
Method
C2Trigger
libminifi/include/c2/C2Trigger.h:43
Method
COAPObjectFactory
extensions/coap/COAPLoader.h:45
Method
CRCStream
libminifi/include/io/CRCStream.h:127
Method
CachedValueValidator
libminifi/include/core/CachedValueValidator.h:48
Method
CallBack
extensions/http-curl/tests/unit/InvokeHTTPTests.cpp:150
Method
CallBackTimer
libminifi/src/utils/CallBackTimer.cpp:28
Method
CallbackProcessor
Constructor ! * Create a new processor */
nanofi/include/cxx/CallbackProcessor.h:56
Method
CapturePacket
Constructor ! * Create a new processor */
extensions/pcap/CapturePacket.h:100
Method
CapturePacketMechanism
extensions/pcap/CapturePacket.h:46
Method
CaptureRTSPFrame
extensions/opencv/CaptureRTSPFrame.h:40
Method
CaptureRTSPFrameWriteCallback
extensions/opencv/CaptureRTSPFrame.h:67
Method
Child
extensions/sftp/processors/ListSFTP.cpp:289
Method
CivetLibrary
extensions/http-curl/tests/TestServer.h:36
Method
CivetStream
* 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
Method
ClassDescription
libminifi/include/agent/build_description.h:34
Method
ClassRegistrar
extensions/jni/ClassRegistrar.h:67
Method
Client
extensions/opc/src/opc.cpp:117
Method
CoapConnectorService
extensions/coap/controllerservice/CoapConnector.h:47
← previous
next →
1,801–1,900 of 5,249, ranked by callers