eventmesh-operator/config/crd/bases/eventmesh-operator.eventmesh_runtimes.yaml (29 lines): - line 1282: TODO: Add other useful fields. apiVersion, - line 1354: TODO: Add other useful fields. apiVersion, - line 1390: TODO: Add other useful fields. apiVersion, - line 1410: TODO: Add other useful fields. apiVersion, - line 2727: TODO: Add other useful fields. apiVersion, - line 2799: TODO: Add other useful fields. apiVersion, - line 2835: TODO: Add other useful fields. apiVersion, - line 2855: TODO: Add other useful fields. apiVersion, - line 4090: TODO: Add other useful fields. apiVersion, kind, - line 4185: TODO: Add other useful fields. apiVersion, - line 4257: TODO: Add other useful fields. apiVersion, - line 4293: TODO: Add other useful fields. apiVersion, - line 4313: TODO: Add other useful fields. apiVersion, - line 6200: TODO: how do we prevent errors in the filesystem - line 6322: TODO: Add other useful fields. apiVersion, - line 6360: TODO: Add other useful fields. apiVersion, - line 6439: TODO: Add other useful fields. apiVersion, - line 6478: TODO: Add other useful fields. apiVersion, - line 6973: if unspecified. TODO: how do we prevent errors - line 7040: TODO: Add other useful fields. apiVersion, - line 7077: TODO: how do we prevent errors in the filesystem - line 7195: TODO: how do we prevent errors in the filesystem - line 7238: TODO: Add other useful fields. apiVersion, - line 7424: TODO: Add other useful fields. apiVersion, - line 7593: TODO: Add other useful fields. apiVersion, - line 7694: TODO: how do we prevent errors in the filesystem - line 7729: TODO: Add other useful fields. apiVersion, - line 7775: TODO: Add other useful fields. apiVersion, - line 7905: TODO: Add other useful fields. apiVersion, eventmesh-operator/config/crd/bases/eventmesh-operator.eventmesh_connectors.yaml (21 lines): - line 935: TODO: Add other useful fields. apiVersion, kind, - line 1002: TODO: Add other useful fields. apiVersion, kind, - line 1035: TODO: Add other useful fields. apiVersion, kind, - line 1053: TODO: Add other useful fields. apiVersion, kind, - line 2287: TODO: Add other useful fields. apiVersion, kind, uid?' - line 2532: TODO: how do we prevent errors in the filesystem from - line 2640: TODO: Add other useful fields. apiVersion, kind, uid?' - line 2672: TODO: Add other useful fields. apiVersion, kind, uid?' - line 2740: TODO: Add other useful fields. apiVersion, kind, uid?' - line 2775: TODO: Add other useful fields. apiVersion, kind, uid?' - line 3198: if unspecified. TODO: how do we prevent errors in the - line 3257: TODO: Add other useful fields. apiVersion, kind, uid?' - line 3290: TODO: how do we prevent errors in the filesystem from - line 3398: TODO: how do we prevent errors in the filesystem from - line 3435: TODO: Add other useful fields. apiVersion, kind, uid?' - line 3601: TODO: Add other useful fields. apiVersion, kind, - line 3746: TODO: Add other useful fields. apiVersion, kind, - line 3836: TODO: how do we prevent errors in the filesystem from - line 3868: TODO: Add other useful fields. apiVersion, kind, uid?' - line 3908: TODO: Add other useful fields. apiVersion, kind, uid?' - line 4024: TODO: Add other useful fields. apiVersion, kind, uid?' eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntime.java (3 lines): - line 190: // TODO: init producer & consumer - line 379: // TODO: use producer pub record to storage replace below - line 526: // TODO: use consumer sub from storage to replace below eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/mysql/MysqlCdcEngine.java (3 lines): - line 506: // TODO: next version support - line 767: // TODO: Add support for handling view change event - line 777: // TODO: Add support for handling XA prepare transaction event eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/CreateTableParserListener.java (2 lines): - line 85: // TODO support next version - line 91: // TODO support next version eventmesh-sdks/eventmesh-sdk-go/common/protocol/tcp/codec/codec.go (2 lines): - line 174: // FIXME improve codes - line 183: // TODO add check eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumer/SubscriptionManager.java (2 lines): - line 86: // TODO: compare the whole Client would be better? - line 148: // TODO: idcUrl list is not thread-safe eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java (2 lines): - line 244: // TODO: Implementation in API. Consider whether to put it in the plug-in. - line 246: // TODO: Detect the maximum length of messages for different producers. eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/SnapshotType.java (1 line): - line 30: INCREASE // TODO Need to support next version eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/admin/RedisAdmin.java (1 line): - line 45: // TODO: match all the topic with pattern "*" for now. eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshAdminConfiguration.java (1 line): - line 57: private List eventMeshIpv4BlackList = Collections.emptyList(); // TODO implement after merging #4835 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/SessionPusher.java (1 line): - line 116: // TODO uploadTrace eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/Catalog.java (1 line): - line 95: // TODO: support create table, drop table and update table eventmesh-connectors/eventmesh-connector-prometheus/src/main/java/org/apache/eventmesh/connector/prometheus/source/connector/PrometheusSourceConnector.java (1 line): - line 128: // TODO: replace with feature #4481 eventmesh-sdks/eventmesh-sdk-c/src/wemq_thread.c (1 line): - line 4811: //TODO RECONNECT; eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/admin/PulsarAdmin.java (1 line): - line 37: // TODO implement admin functions eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/ConfigurationHandlerV1.java (1 line): - line 39: * TODO The path of endpoints under v1 package shall be changed to {@code /v1/configuration} with Next.js EventMesh Dashboard. eventmesh-sdks/eventmesh-sdk-go/http/producer/http_producer_api.go (1 line): - line 36: // TODO: add OpenMessage support eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java (1 line): - line 127: // TODO ",consumer=" + consumer.getDefaultMQPushConsumer().getMessageModel() + eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java (1 line): - line 30: * TODO: Duplicate with org.apache.eventmesh.storage.redis.cloudevent.CloudEventCodec eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java (1 line): - line 170: // TODO: How to assign values here eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java (1 line): - line 270: // TODO: if startTime is modified eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/FunctionRuntime.java (1 line): - line 222: // TODO: update functionConfigs eventmesh-connectors/eventmesh-connector-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/server/ChatGPTConnectServer.java (1 line): - line 36: // TODO support sink connector eventmesh-sdks/eventmesh-sdk-go/tcp/tcp_client.go (1 line): - line 120: // TODO Handle according to the command