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 config server v2 provider(HeartBeat、FetchPipelineConfig、FetchProcessConfig) #1710

Open
wants to merge 56 commits into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from 23 commits
Commits
Show all changes
56 commits
Select commit Hold shift + click to select a range
d9becf2
Support config server v2 provider(HeartBeat、FetchPipelineConfig、Fetch…
ww67652 Aug 21, 2024
10032e8
Merge branch 'alibaba:main' into main
ww67652 Aug 21, 2024
23bfe88
Update file due to changes of 'Process ->Instance' in proto
ww67652 Aug 22, 2024
4dc3434
change the structure of project
ww67652 Aug 22, 2024
d482825
fix:fix the slow sql while creating agent
ww67652 Aug 22, 2024
e3eb7b7
Merge remote-tracking branch 'origin/main'
ww67652 Aug 25, 2024
ccbdc2d
add: Implement support for multiple data sources
ww67652 Aug 26, 2024
838836c
add: Support interaction between user and config-server.
ww67652 Sep 4, 2024
f6aac54
Merge remote-tracking branch 'origin/main'
ww67652 Sep 4, 2024
065744e
fix: Optimized the error handling logic and added error chaining for …
ww67652 Sep 4, 2024
f4f3a20
Merge remote-tracking branch 'origin/main'
ww67652 Sep 4, 2024
56355f1
fix: fix the error of error handler
ww67652 Sep 4, 2024
fec3d7f
fix: fix the bug in backend code
ww67652 Sep 9, 2024
4c7e8b6
init frontend and finish backend
ww67652 Sep 10, 2024
e8237b6
fix:fix the bug in backend and post a demo request with protobuf from…
ww67652 Sep 10, 2024
097b052
fix:fix the bug in backend and post a demo request with protobuf from…
ww67652 Sep 10, 2024
e6810cb
add : add features and functions
ww67652 Sep 15, 2024
10f9102
add : Implemented regular checks on the correspondence between config…
ww67652 Sep 15, 2024
173211c
add: finish basic function
ww67652 Sep 15, 2024
96f9876
finish:finish the all project
ww67652 Sep 16, 2024
db4c001
finish:add document
ww67652 Sep 16, 2024
dd9d368
finish:add document
ww67652 Sep 16, 2024
beee4b6
finish:add document
ww67652 Sep 16, 2024
9b51d72
modify the directory structure
ww67652 Sep 19, 2024
fb2f913
add necessary document
ww67652 Sep 20, 2024
51f12d3
Optimize container startup logic
ww67652 Sep 20, 2024
81fc239
Rollback: Merge exception caused by incorrect file modifications
ww67652 Sep 20, 2024
47c1a1a
update: service for v2 protocol (ConfigService)
ww67652 Sep 29, 2024
2c21809
update: add deployment for v2 protocol (ConfigServer)
ww67652 Sep 29, 2024
9acea84
update: add ui for v2 protocol (ConfigServer)
ww67652 Sep 29, 2024
9772c47
update: add docs for config-server v2
ww67652 Sep 29, 2024
754ef22
update: delete agent config in docker-compose.yml
ww67652 Sep 30, 2024
ab9cbf5
update: change directory structure
ww67652 Sep 30, 2024
ea7aad0
Merge branch 'deployment'
ww67652 Sep 30, 2024
712931e
Merge branch 'ui'
ww67652 Sep 30, 2024
946d27d
update: change directory structure
ww67652 Sep 30, 2024
6349b70
merge:merge service
ww67652 Sep 30, 2024
5bf0644
update: simplify the handler code
ww67652 Oct 16, 2024
73b355f
update: update server2agent logic
ww67652 Oct 19, 2024
6404b66
update: update proto file
ww67652 Oct 19, 2024
d85e5b4
update: add decodeBase64 fix:service bug
ww67652 Oct 20, 2024
f9ed609
fix:fix the bug in frontend
ww67652 Oct 20, 2024
6536768
clean: clean useless code
ww67652 Oct 21, 2024
56bb076
Add key annotations for main logic
ww67652 Oct 27, 2024
f12b42c
feat: support for agent hostid
ww67652 Oct 27, 2024
177466b
feat: Join the default group upon backend startup
ww67652 Oct 27, 2024
6da8c47
feat: support for http status
ww67652 Oct 27, 2024
f2dada2
feat: add two api about status query
ww67652 Oct 28, 2024
1779fa9
modify the image tag in deployment
ww67652 Oct 28, 2024
7b9d7b2
modify the image tag in deployment
ww67652 Oct 28, 2024
52f6f70
feat: Distinguish between test API and logs based on the environment …
ww67652 Oct 28, 2024
a97e48c
test: add test cases
ww67652 Oct 30, 2024
a4c51c1
refactor config-server directory
ww67652 Oct 30, 2024
b2f1eb6
feat: Delete instance related functions and modify directory structure
ww67652 Oct 30, 2024
4a30f99
feat: sync agent.pb
ww67652 Oct 30, 2024
b397a48
fix: solve conflict
ww67652 Oct 30, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
209 changes: 209 additions & 0 deletions config_server/protocol/v2/user.proto
Original file line number Diff line number Diff line change
@@ -0,0 +1,209 @@
syntax = "proto3";
package config_server.proto.v2;
option go_package = "/;protov2";
import "agent.proto";


message Agent{
uint64 capabilities = 1; // Bitmask of flags defined by AgentCapabilities enum
bytes instance_id = 2; // Required, Agent's unique identification, consistent throughout the process lifecycle
string agent_type = 3; // Required, Agent's type(ilogtail, ..)
AgentAttributes attributes = 4; // Agent's basic attributes
string running_status = 5; // Human readable running status
int64 startup_time = 6; // Required, Agent's startup time
uint64 flags = 7; // Predefined command flag
bytes opaque = 8; // Opaque data for extension
}

// API: /User/CreateAgentGroup

message CreateAgentGroupRequest {
bytes request_id = 1;
AgentGroupTag agent_group = 2;
}

message CreateAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/UpdateAgentGroup

message UpdateAgentGroupRequest {
bytes request_id = 1;
AgentGroupTag agent_group = 2;
}

message UpdateAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/DeleteAgentGroup/

message DeleteAgentGroupRequest {
bytes request_id = 1;
string group_name = 2;
}

message DeleteAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/GetAgentGroup/

message GetAgentGroupRequest {
bytes request_id = 1;
string group_name = 2;
}

message GetAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
AgentGroupTag agent_group = 3;
}

// API: /User/ListAgentGroups/

message ListAgentGroupsRequest {
bytes request_id = 1;
}

message ListAgentGroupsResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;

repeated AgentGroupTag agent_groups = 4;
}

// API: /User/CreatePipelineConfig
// API: /User/CreateInstanceConfig
message CreateConfigRequest {
bytes request_id = 1;
ConfigDetail config_detail = 2;
}

message CreateConfigResponse {
bytes request_id = 1;
CommonResponse commonResponse =2;
}

// API: /User/UpdatePipelineConfig
// API: /User/UpdateInstanceConfig
message UpdateConfigRequest {
bytes request_id = 1;
ConfigDetail config_detail = 2;
}

message UpdateConfigResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/DeletePipelineConfig
// API: /User/DeleteInstanceConfig
message DeleteConfigRequest {
bytes request_id = 1;
string config_name = 2;
}

message DeleteConfigResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/GetPipelineConfig
// API: /User/GetInstanceConfig
message GetConfigRequest {
bytes request_id = 1;
string config_name = 2;
}

message GetConfigResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;

ConfigDetail config_detail = 3;
}

// API: /User/ListPipelineConfigs
// API: /User/ListInstanceConfigs
message ListConfigsRequest {
bytes request_id = 1;
}

message ListConfigsResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;

repeated ConfigDetail config_details = 3;
}

// API: /User/ApplyPipelineConfigToAgentGroup
// API: /User/ApplyInstanceConfigToAgentGroup
message ApplyConfigToAgentGroupRequest {
bytes request_id = 1;
string config_name = 2;
string group_name = 3;
}

message ApplyConfigToAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/RemovePipelineConfigFromAgentGroup/
// API: /User/RemoveInstanceConfigFromAgentGroup/
message RemoveConfigFromAgentGroupRequest {
bytes request_id = 1;
string config_name = 2;
string group_name = 3;
}

message RemoveConfigFromAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;
}

// API: /User/GetAppliedInstanceConfigsForAgentGroup/
// API: /User/GetAppliedPipelineConfigsForAgentGroup/
message GetAppliedConfigsForAgentGroupRequest {
bytes request_id = 1;
string group_name = 2;
}

message GetAppliedConfigsForAgentGroupResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;

repeated string config_names = 4;
}

// API: /User/GetAppliedAgentGroupsWithPipelineConfig/
// API: /User/GetAppliedAgentGroupsWithInstanceConfig/
message GetAppliedAgentGroupsRequest {
bytes request_id = 1;
string config_name = 2;
}

message GetAppliedAgentGroupsResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;

repeated string agent_group_names = 3;
}

// API: /User/ListAgents/

message ListAgentsRequest {
bytes request_id = 1;
string group_name = 2;
}

message ListAgentsResponse {
bytes request_id = 1;
CommonResponse commonResponse=2;

repeated Agent agents = 3;
}
88 changes: 44 additions & 44 deletions config_server/service/proto/agent.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading
Loading