Skip to content

feature: add temporal control-plane connect service #75

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.

Sign up for GitHub

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

Open
rustatian wants to merge 2 commits into
base: master
Choose a base branch
from
Open

feature: add temporal control-plane connect service #75

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
ab59c18
feature: add temporal control-plane connect service
rustatian Jun 10, 2026
cb450a3
fix: use full go_package import paths for centrifugo protos
rustatian Jun 10, 2026
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
2 changes: 1 addition & 1 deletion roadrunner/api/centrifugo/api/v1/api.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ syntax = "proto3";

package centrifugal.centrifugo.api;

option go_package = "centrifugo/api/v1";
option go_package = "github.com/roadrunner-server/api-go/v6/centrifugo/api/v1;apiV1";
option php_metadata_namespace = "RoadRunner\\Centrifugal\\API\\DTO\\V1\\GPBMetadata";
option php_namespace = "RoadRunner\\Centrifugal\\API\\DTO\\V1";

Expand Down
2 changes: 1 addition & 1 deletion roadrunner/api/centrifugo/proxy/v1/proxy.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ syntax = "proto3";

package centrifugal.centrifugo.proxy;

option go_package = "centrifugo/proxy/v1";
option go_package = "github.com/roadrunner-server/api-go/v6/centrifugo/proxy/v1;proxyV1";
option php_metadata_namespace = "RoadRunner\\Centrifugal\\Proxy\\DTO\\V1\\GPBMetadata";
option php_namespace = "RoadRunner\\Centrifugal\\Proxy\\DTO\\V1";

Expand Down
57 changes: 57 additions & 0 deletions roadrunner/api/temporal/v1/service.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,57 @@
syntax = "proto3";

package temporal.v1;

import "temporal/v1/temporal.proto";

option go_package = "github.com/roadrunner-server/api-go/v6/temporal/v1;temporalV1";
option php_metadata_namespace = "RoadRunner\\Temporal\\DTO\\V1\\GPBMetadata";
option php_namespace = "RoadRunner\\Temporal\\DTO\\V1";

// RecordHeartbeatRequest is sent by an activity to record its current progress.
message RecordHeartbeatRequest {
// value of the binary "TaskToken" field of the "ActivityInfo" struct
// retrieved inside the activity
bytes task_token = 1;
// progress recorded along with the heartbeat
bytes details = 2;
}

message RecordHeartbeatResponse {
// the activity was requested to cancel
bool canceled = 1;
// the activity was paused
bool paused = 2;
}

message GetNamesRequest {}

message NamesList {
repeated string names = 1;
}

message UpdateAPIKeyRequest {
string api_key = 1;
}

message UpdateAPIKeyResponse {
bool ok = 1;
}

// TemporalService exposes the temporal plugin control RPCs: activity
// heartbeats, registered workflow/activity introspection, workflow replay
// tooling, and API key rotation.
service TemporalService {
rpc RecordActivityHeartbeat(RecordHeartbeatRequest) returns (RecordHeartbeatResponse);
rpc GetActivityNames(GetNamesRequest) returns (NamesList) {
option idempotency_level = NO_SIDE_EFFECTS;
}
rpc GetWorkflowNames(GetNamesRequest) returns (NamesList) {
option idempotency_level = NO_SIDE_EFFECTS;
}
rpc ReplayWorkflow(ReplayRequest) returns (ReplayResponse);
rpc DownloadWorkflowHistory(ReplayRequest) returns (ReplayResponse);
rpc ReplayFromJSON(ReplayRequest) returns (ReplayResponse);
rpc ReplayWorkflowHistory(History) returns (ReplayResponse);
rpc UpdateAPIKey(UpdateAPIKeyRequest) returns (UpdateAPIKeyResponse);
}
Loading