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

支持 subpath 路由 #2026

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

Conversation

KayzzzZ
Copy link
Collaborator

@KayzzzZ KayzzzZ commented Jan 8, 2025

No description provided.

core/plugin/flusher/sls/SLSClientManager.h Show resolved Hide resolved
core/plugin/flusher/sls/SLSClientManager.cpp Outdated Show resolved Hide resolved
core/plugin/flusher/sls/SLSClientManager.cpp Outdated Show resolved Hide resolved
core/plugin/flusher/sls/FlusherSLS.h Outdated Show resolved Hide resolved
core/plugin/flusher/sls/FlusherSLS.cpp Outdated Show resolved Hide resolved
core/plugin/flusher/sls/FlusherSLS.cpp Outdated Show resolved Hide resolved
@@ -294,16 +294,57 @@ bool FlusherSLS::Init(const Json::Value& config, Json::Value& optionalGoPipeline
mContext->GetRegion());
}

// TelemetryType
string telemetryType;
if (!GetOptionalStringParam(config, "TelemetryType", telemetryType, errorMsg)) {
Copy link
Collaborator

Choose a reason for hiding this comment

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

298-347这段逻辑 处理顺序是 log、metric、arms。

Copy link
Collaborator Author

Choose a reason for hiding this comment

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

ok

logData,
bufferMeta.rawsize(),
bufferMeta.has_shardhashkey() ? bufferMeta.shardhashkey() : "",
bufferMeta.subpath());
Copy link
Collaborator

Choose a reason for hiding this comment

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

同理,log、metric、apm的顺序

Copy link
Collaborator Author

Choose a reason for hiding this comment

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

ok

Copy link
Collaborator Author

Choose a reason for hiding this comment

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

已修改

const std::string& subPath) const {

optional<uint64_t> seqId;
if (item->mExactlyOnceCheckpoint) {
Copy link
Collaborator

Choose a reason for hiding this comment

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

跟exactly无关,忽略即可

@@ -80,6 +80,8 @@ static sls_logs::EndpointMode GetEndpointMode(EndpointMode mode) {
static const string kAKErrorMsg = "can not get valid access key";
#endif

static const string kNoSubpathErrorMsg = "subpath not set";
Copy link
Collaborator

@messixukejia messixukejia Jan 9, 2025

Choose a reason for hiding this comment

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

diskbuffer需要有E2E覆盖,可以找笃敏交流下

Copy link
Collaborator Author

Choose a reason for hiding this comment

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

ok

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.

3 participants