Skip to content
Open
Changes from all commits
Commits
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
33 changes: 30 additions & 3 deletions protos/orchestrator_service.proto
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,11 @@ enum OrchestrationStatus {
ORCHESTRATION_STATUS_SUSPENDED = 7;
}

enum ExportStatus {
EXPORT_STATUS_COMPLETED = 0;
EXPORT_STATUS_FAILED = 1;
}

message ParentInstanceInfo {
int32 taskScheduledId = 1;
google.protobuf.StringValue name = 2;
Expand Down Expand Up @@ -220,6 +225,18 @@ message EntityLockGrantedEvent {
string criticalSectionId = 1;
}

message ExportStartedEvent {
}

message ExportCompletedEvent {
ExportStatus exportStatus = 1;
}

message ExportFailedEvent {
ExportStatus exportStatus = 1;
TaskFailureDetails failureDetails = 2;
}

message HistoryEvent {
int32 eventId = 1;
google.protobuf.Timestamp timestamp = 2;
Expand Down Expand Up @@ -251,6 +268,9 @@ message HistoryEvent {
EntityLockRequestedEvent entityLockRequested = 27;
EntityLockGrantedEvent entityLockGranted = 28;
EntityUnlockSentEvent entityUnlockSent = 29;
ExportStartedEvent exportStarted = 30;
ExportCompletedEvent exportCompleted = 31;
ExportFailedEvent exportFailed = 32;
}
}

Expand Down Expand Up @@ -289,6 +309,11 @@ message CompleteOrchestrationAction {
TaskFailureDetails failureDetails = 6;
}

message CompleteExportAction {
ExportStatus exportStatus = 1;
TaskFailureDetails failureDetails = 2;
}

message TerminateOrchestrationAction {
string instanceId = 1;
google.protobuf.StringValue reason = 2;
Expand All @@ -314,6 +339,7 @@ message OrchestratorAction {
CompleteOrchestrationAction completeOrchestration = 6;
TerminateOrchestrationAction terminateOrchestration = 7;
SendEntityMessageAction sendEntityMessage = 8;
CompleteExportAction completeExport = 9;
}
}

Expand Down Expand Up @@ -360,6 +386,7 @@ message CreateInstanceRequest {
map<string, string> tags = 8;
TraceContext parentTraceContext = 9;
google.protobuf.Timestamp requestTime = 10;
bool exportable = 11;
}

message OrchestrationIdReusePolicy {
Expand Down Expand Up @@ -683,14 +710,14 @@ message AbandonEntityTaskResponse {
}

message SkipGracefulOrchestrationTerminationsRequest {
InstanceBatch instanceBatch = 1;
google.protobuf.StringValue reason = 2;
InstanceBatch instanceBatch = 1;
google.protobuf.StringValue reason = 2;
}

message SkipGracefulOrchestrationTerminationsResponse {
// Those instances which could not be terminated because they had locked entities at the time of this termination call,
// are already in a terminal state (completed, failed, terminated, etc.), are not orchestrations, or do not exist (i.e. have been purged)
repeated string unterminatedInstanceIds = 1;
repeated string unterminatedInstanceIds = 1;
}

service TaskHubSidecarService {
Expand Down