Skip to content
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

support send medata to config server #885

Open
wants to merge 15 commits into
base: main
Choose a base branch
from

Conversation

dragonYang200
Copy link
Contributor

  • 新增支持火山top网关加签算法BytedanceSign.h/BytedanceSign.cpp
  • 新增元数据上报接口
  • 心跳上报接口新增agent_machine_id字段
  • 新增ConfigServiceClientBase基类,用以扩展字节火山configServer api调用接口

@yyuuttaaoo yyuuttaaoo requested review from henryzhx8, yyuuttaaoo, Takuka0311, liuhaoyang and messixukejia and removed request for henryzhx8 May 30, 2023 04:18
core/config_manager/ConfigManager.cpp Outdated Show resolved Hide resolved
config_server/protocol/agent.proto Outdated Show resolved Hide resolved
core/app_config/AppConfigBase.cpp Outdated Show resolved Hide resolved
core/config_manager/ConfigManager.cpp Outdated Show resolved Hide resolved
else if (port < 1 || port > 65535)
LOG_WARNING(sLogger, ("ilogtail_configserver_address", "illegal port")("port", port));
else
mConfigServerAddresses.push_back(ConfigServerAddress(host, port));
}

mConfigServerAvailable = true;
LoadStringParameter(mGatewayService, confJson, "gateway_service", "GATEWAY_SERVICE");
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

下面这些参数需要确认下是否火山特有的,如果是的话建议放到VolcengineConfigServiceClient init中,因为这些都是client的内部参数

image
AppConfigti提供一个解析接口,供clinet调用

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

读取ilogtail_config.json文件内容需要在GetStringParameter这个接口里面额外额外实现吗?还是在LoadAppConfig的时候用一个变量将ilogtail_config.json文件内容保存下来

core/config_manager/ConfigManagerBase.h Show resolved Hide resolved
@@ -83,6 +83,7 @@ message HeartBeatRequest {
int32 interval = 8; // Agent's heartbeat interval
repeated ConfigInfo pipeline_configs = 9; // Information about the current PIPELINE_CONFIG held by the Agent
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

文档、changelog

core/app_config/AppConfigBase.cpp Outdated Show resolved Hide resolved
core/config_manager/ConfigManagerBase.h Outdated Show resolved Hide resolved
core/config_manager/ConfigManagerBase.h Outdated Show resolved Hide resolved
core/config_manager/ConfigServiceClient.cpp Show resolved Hide resolved
config_server/protocol/agent.proto Show resolved Hide resolved
config_server/protocol/agent.proto Outdated Show resolved Hide resolved
config_server/protocol/agent.proto Outdated Show resolved Hide resolved
core/app_config/AppConfigBase.cpp Outdated Show resolved Hide resolved
}
LOG_WARNING(sLogger, ("FlushCredential", "success"));
try {
mConfigServiceClient->SignHeader(request);
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

SignHeader FlushCredential 为什么对异常的处理方式不一样?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

5 participants