Summary: 49 instances, 46 unique Text Count // TODO: replace IOException with custom data-prepper exception 1 //creation. except for running the creation again, it will not harm anything - TODO Fix this 1 root_span_flush_delay: 3 # TODO: remove after 1.1 release 1 * TODO: support sample test cases. 1 // TODO: extract out version number into version enum 2 // TODO: support more certificate providers 1 root_span_flush_delay: 1 # TODO: remove after 1.1 release 1 * TODO: 1 sourceConnectorMap.put(pipelineName, pipelineConnector); //TODO retrieve from parent Pipeline using name 1 // TODO: Potentially remove, this is file-specific 1 * TODO Update this to be more elegant and trigger destroy of plugins 1 * TODO: replace output List<String> with List<InternalModel> type 1 * TODO Add capability to discover custom new plugins 1 // TODO: Cleanup references to file-based map 1 // TODO: support other data-types as request body, e.g. json_lines, msgpack 1 // TODO: This function should be removed with the completion of: https://github.com/opensearch-project/data-prepper/issues/546 3 // TODO: This function should be removed with the completion of: https://github.com/opensearch-project/data-prepper/issues/546 1 //TODO: cleanup resources 1 // TODO: Temp code, complex instance creation logic should be moved to a separate class 1 // TODO: read span status from tags 1 // TODO: accommodate encrypted private key with password 1 // TODO: Remove DataPrepperServer dependency on DataPrepper 1 // TODO: enable encrypted key with password 1 // TODO: retry for status code 429 of OpenSearchException? 1 // TODO: remove singleton now that port is configurable 1 * TODO: add retryConfiguration 1 // TODO: replace with new _opensearch API 1 // TODO: replace with custom backoff policy setting including maximum interval between retries 1 // TODO: attach HealthCheckService 1 // TODO: Remove this along with the removal of com.amazon.dataprepper.plugins.PluginFactory 1 * TODO Add isolator pattern - Fail if one of the Sink fails [isolator Pattern] 1 private final Map sourceConnectorMap = new HashMap<>(); //TODO Remove this and rely only on pipelineMap 1 //TODO: Consider keeping this state in a db 1 // TODO: add library name and version 1 //TODO Hacky way to avoid logging continuously - Will be removed as part of metrics implementation 1 * TODO: Should this be removed? (unused code) 1 //TODO: Cleanup resources 1 //validateForOrphans(orderedPipelineNames, pipelineConfigurationMap); //TODO: Should we disable orphan pipelines ? 1 // TODO: This should not be tracked in this class, move it up to the creator 1 // TODO: replace hardcoded port with customization 1 // TODO: allow this to be configurable as well? 1 // TODO: Resolve to IP first, or is hostname good enough? 1 // TODO: extract out version number into version enum 1 // TODO: allow customization on URI path for log ingestion 1 * TODO: Can we do better? 1 * TODO: The current implementation focuses on proving the bare bones for which this class only need to 1