Skip to content

Commit 0d676c6

Browse files
authored
Service discovery (#59)
This is the initial pass at service discovery in `Blueprint`. The basic premise is tp have a service complete a handshake and open a bi-directional stream `blueprint`. The service then pushes status updates to `blueprint`.
1 parent 42737ae commit 0d676c6

File tree

56 files changed

+1390
-507
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

56 files changed

+1390
-507
lines changed

.vscode/launch.json

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,18 @@
3737
"CMD": "make_cluster"
3838
}
3939
},
40+
{
41+
"name": "Blueprint CMD: Cluster Stats",
42+
"type": "go",
43+
"request": "launch",
44+
"mode": "auto",
45+
"program": "tools/blueprint-client/main.go",
46+
"cwd": "${workspaceFolder}",
47+
"debugAdapter": "dlv-dap",
48+
"env": {
49+
"CMD": "cluster_stats"
50+
}
51+
},
4052
{
4153
"name": "Blueprint CMD: Set Test",
4254
"type": "go",

api/buf.lock

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@ deps:
99
- remote: buf.build
1010
owner: googleapis
1111
repository: googleapis
12-
commit: 553fd4b4b3a640be9b69a3fa0c17b383
13-
digest: shake256:e30e3247f84b7ff9d09941ce391eb4b6f04734e1e5fae796bfc471f167e6f90813630cc39397ee46b8bc0ea7d6935c416d15c219cc5732d9778cbfdf73a1ed6e
12+
commit: acd896313c55464b993332136ded1b6e
13+
digest: shake256:66626d5e4d9c8ecf25cd72bdbfbbf62b9a68e9e9c33dab6b9b39a53a67063eeba6b8493247dd6d6240b1ac1c32eb2dc311484e67dd7d271884a960c2e5ce8c9a
1414
- remote: buf.build
1515
owner: srikrsna
1616
repository: protoc-gen-gotag

api/core/consensus/fsm/v1/fsm.pb.go

Lines changed: 3 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

api/core/consensus/raft/v1/service.pb.go

Lines changed: 10 additions & 10 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

api/core/control_plane/networking/v1/service.pb.go

Lines changed: 18 additions & 18 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

api/core/message_broker/actors/v1/consumer.pb.go

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

api/core/message_broker/actors/v1/consumer.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ service Consumer {
1010
rpc Consume(ConsumeRequest) returns (stream ConsumeResponse) {}
1111
}
1212

13-
message ConsumeRequest {
13+
message ConsumeRequest {
1414
CloudEvent message = 1;
1515
}
1616

api/core/message_broker/actors/v1/models.pb.go

Lines changed: 9 additions & 9 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

api/core/message_broker/actors/v1/producer.pb.go

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

api/core/registry/key_value/v1/models.pb.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)