-
Notifications
You must be signed in to change notification settings - Fork 402
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add a default content key for the service_kafka plugin #1754
Add a default content key for the service_kafka plugin #1754
Conversation
这个action怎么老是报错
|
为了国内开发方便替换了dockerfile:1.5的镜像地址,但这样git action就不太稳定,容易TLS握手超时 |
本次代码评审主要涉及添加新的依赖、引入新的变量、修改锁的使用、增加和修改函数功能、调整配置处理逻辑、更新测试用例以适应代码结构和逻辑的变化,以及一系列的代码优化和重构,特别是增加了对配置管理和指标统计的处理,加强了模块间的解耦和代码的可维护性。 Link: https://code.alibaba-inc.com/sls/ilogtail/codereview/18705573 * add setpipelineforitems for process queues (#1769) * add metric for runner (#1766) * fix deadlock in full drain mode on config update (#1776) * remove InputStream (#1777) * fix: do not use gtid if gtid is disabled (#1781) Fixed an issue where the input_canal plugin used GTID as the sync method even when gtid_enabled was set to false. This led to syncing from the beginning due to receiving an empty GTID set. Syncing from the beginning is usually undesirable as it consumes significant CPU resources on the server side and deviates from the default plugin behavior. This commit ensures that the plugin respects the gtid_enabled switch and the gtid_mode query result. * fix: gometric v2 not started and shared extensions (#1782) * fix metrics v2 type assertion and shared extension initialiazation * restore go mod * test: calculate incremental unittest coverage (#1783) * fix: given more time to fix ut failed of flusher_prometheus (#1784) * Flusher supports new metricstore endpoint, which optimizes time series data storage and query (#1731) * rename self monitor metrics (#1779) * c++ part * go part * fix go bug * rename cpp metrics * rename go metrics * change parameters name * delete unused metrics * change name * delete node id * change name * fix build * change name * 1. support honor_timestamps, 2. support honor_labels, apply global mTags to MetricEvent in relabel phase 3. optimization relabel, manage MetricEvent tags directly (#1742) * update: remove enable-compression config temporarily (#1785) * update: check pipeline queue before scrape, try again after 1 second if is not valid to push (#1757) * Add a default content key for the service_kafka plugin (#1754) * add K8s meta self metrics (#1765) * support k8s meta to collect more resources * feat: reload pipeline config independently (#1713) * feat: reload Go pipeline config independently * fix unittest * fix unittest * fix * fix * fix * fix * fix * unittest * fix * fix * fix * fix * fix * self telemetry * fix * fix * fix * fix * fix * fix * fix * fix * fix * fix * fix * fix * fix * test: calculate incremental unittest coverage * fix * fix * fix * fix * fix conflict * fix log * feat: prometheus self monitor metrics (#1796) * feat:iLogtail renamed to LoongCollector and directory layout changes (#1791) ```plaintext / └── /opt/loongcollector/ ├── loongcollector ├── libPluginAdapter.so ├── libPluginBase.so ├── ca-bundle.crt ├── plugins │ └── custom plugins ├── dump (used exclusively by the service_http_server input plugin) ├── thirdparty │ ├── jvm │ └── telegraf ├── conf/ │ ├── scripts │ ├── apsara_log_conf.json │ ├── plugin_logger.xml │ ├── user_defined_id │ ├── authorization.json │ ├── pipelineconfig/ │ │ ├── local/ │ │ │ └── collect_stdout.json │ │ └── remote/ │ │ └── collect_file.json │ └── instanceconfig/ │ ├── local/ │ │ ├── ebpf.json │ │ └── loongcollector_config.json │ └── remote/ │ ├── region.json │ └── resource.json ├── data/ │ ├── file_check_point │ ├── exactly_once_checkpoint/ │ ├── go_plugin_checkpoint/ │ ├── docker_path_config.json │ ├── send_buffer_file_xxxxxxxxxxxx │ └── backtrace.dat ├── log/ │ ├── loongcollector.log │ ├── loongcollector.log.1 │ ├── go_plugin.log │ ├── go_plugin.log.1 │ ├── logger_initialization.log │ └── snapshot/ └── run/ ├── loongcollector.pid ├── inotify_watcher_dirs └── app_info.json ``` * Support concurrency isolation between different sender queues (#1786) * Merge remote-tracking branch 'upstream/main' into HEAD * Internal code adaptation to ConcurrencyLimiter changes
#1748