Skip to content

Commit

Permalink
Add api nested dir (temporalio#65)
Browse files Browse the repository at this point in the history
  • Loading branch information
alexshtin authored Jul 8, 2020
1 parent 218a721 commit 0cb3c3a
Show file tree
Hide file tree
Showing 23 changed files with 367 additions and 367 deletions.
2 changes: 1 addition & 1 deletion Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ gogo-grpc: clean $(PROTO_OUT)
$(foreach PROTO_DIR,$(PROTO_DIRS),protoc --proto_path=$(PROTO_IMPORT) --gogoslick_out=Mgoogle/protobuf/wrappers.proto=github.com/gogo/protobuf/types,Mgoogle/protobuf/timestamp.proto=github.com/gogo/protobuf/types,plugins=grpc,paths=source_relative:$(PROTO_OUT) $(PROTO_DIR)*.proto;)

fix-path:
mv -f $(PROTO_OUT)/temporal/* $(PROTO_OUT) && rm -rf $(PROTO_OUT)/temporal
mv -f $(PROTO_OUT)/temporal/api/* $(PROTO_OUT) && rm -rf $(PROTO_OUT)/temporal

# Plugins & tools

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,17 +22,17 @@

syntax = "proto3";

package temporal.common.v1;
package temporal.api.common.v1;

option go_package = "go.temporal.io/temporal-proto/common/v1;common";
option java_package = "io.temporal.common.v1";
option go_package = "go.temporal.io/api/common/v1;common";
option java_package = "io.temporal.api.common.v1";
option java_multiple_files = true;
option java_outer_classname = "MessageProto";

import "temporal/enums/v1/common.proto";
import "temporal/api/enums/v1/common.proto";

message DataBlob {
temporal.enums.v1.EncodingType encoding_type = 1;
temporal.api.enums.v1.EncodingType encoding_type = 1;
bytes data = 2;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,26 +22,26 @@

syntax = "proto3";

package temporal.decision.v1;
package temporal.api.decision.v1;

option go_package = "go.temporal.io/temporal-proto/decision/v1;decision";
option java_package = "io.temporal.decision.v1";
option go_package = "go.temporal.io/api/decision/v1;decision";
option java_package = "io.temporal.api.decision.v1";
option java_multiple_files = true;
option java_outer_classname = "MessageProto";

import "temporal/enums/v1/workflow.proto";
import "temporal/enums/v1/decision_type.proto";
import "temporal/common/v1/message.proto";
import "temporal/failure/v1/message.proto";
import "temporal/taskqueue/v1/message.proto";
import "temporal/api/enums/v1/workflow.proto";
import "temporal/api/enums/v1/decision_type.proto";
import "temporal/api/common/v1/message.proto";
import "temporal/api/failure/v1/message.proto";
import "temporal/api/taskqueue/v1/message.proto";

message ScheduleActivityTaskDecisionAttributes {
string activity_id = 1;
temporal.common.v1.ActivityType activity_type = 2;
temporal.api.common.v1.ActivityType activity_type = 2;
string namespace = 3;
temporal.taskqueue.v1.TaskQueue task_queue = 4;
temporal.common.v1.Header header = 5;
temporal.common.v1.Payloads input = 6;
temporal.api.taskqueue.v1.TaskQueue task_queue = 4;
temporal.api.common.v1.Header header = 5;
temporal.api.common.v1.Payloads input = 6;
// Indicates how long the caller is willing to wait for an activity completion.
// Limits for how long retries are happening. Either this or start_to_close_timeout_seconds must be specified.
// When not specified defaults to the workflow execution timeout.
Expand All @@ -58,7 +58,7 @@ message ScheduleActivityTaskDecisionAttributes {
// Activities are provided by a default retry policy controlled through the service dynamic configuration.
// Retries are happening up to schedule_to_close_timeout.
// To disable retries set retry_policy.maximum_attempts to 1.
temporal.common.v1.RetryPolicy retry_policy = 11;
temporal.api.common.v1.RetryPolicy retry_policy = 11;
}

message RequestCancelActivityTaskDecisionAttributes {
Expand All @@ -71,19 +71,19 @@ message StartTimerDecisionAttributes {
}

message CompleteWorkflowExecutionDecisionAttributes {
temporal.common.v1.Payloads result = 1;
temporal.api.common.v1.Payloads result = 1;
}

message FailWorkflowExecutionDecisionAttributes {
temporal.failure.v1.Failure failure = 1;
temporal.api.failure.v1.Failure failure = 1;
}

message CancelTimerDecisionAttributes {
string timer_id = 1;
}

message CancelWorkflowExecutionDecisionAttributes {
temporal.common.v1.Payloads details = 1;
temporal.api.common.v1.Payloads details = 1;
}

message RequestCancelExternalWorkflowExecutionDecisionAttributes {
Expand All @@ -96,70 +96,70 @@ message RequestCancelExternalWorkflowExecutionDecisionAttributes {

message SignalExternalWorkflowExecutionDecisionAttributes {
string namespace = 1;
temporal.common.v1.WorkflowExecution execution = 2;
temporal.api.common.v1.WorkflowExecution execution = 2;
string signal_name = 3;
temporal.common.v1.Payloads input = 4;
temporal.api.common.v1.Payloads input = 4;
string control = 5;
bool child_workflow_only = 6;
}

message UpsertWorkflowSearchAttributesDecisionAttributes {
temporal.common.v1.SearchAttributes search_attributes = 1;
temporal.api.common.v1.SearchAttributes search_attributes = 1;
}

message RecordMarkerDecisionAttributes {
string marker_name = 1;
map<string, temporal.common.v1.Payloads> details = 2;
temporal.common.v1.Header header = 3;
temporal.failure.v1.Failure failure = 4;
map<string, temporal.api.common.v1.Payloads> details = 2;
temporal.api.common.v1.Header header = 3;
temporal.api.failure.v1.Failure failure = 4;
}

message ContinueAsNewWorkflowExecutionDecisionAttributes {
temporal.common.v1.WorkflowType workflow_type = 1;
temporal.taskqueue.v1.TaskQueue task_queue = 2;
temporal.common.v1.Payloads input = 3;
temporal.api.common.v1.WorkflowType workflow_type = 1;
temporal.api.taskqueue.v1.TaskQueue task_queue = 2;
temporal.api.common.v1.Payloads input = 3;
// workflowExecutionTimeout is omitted as it shouldn'be overridden from within a workflow
// Timeout of a single workflow run
int32 workflow_run_timeout_seconds = 4;
// Timeout of a single workflow task
int32 workflow_task_timeout_seconds = 5;
int32 backoff_start_interval_in_seconds = 6;
temporal.common.v1.RetryPolicy retry_policy = 7;
temporal.enums.v1.ContinueAsNewInitiator initiator = 8;
temporal.failure.v1.Failure failure = 9;
temporal.common.v1.Payloads last_completion_result = 10;
temporal.api.common.v1.RetryPolicy retry_policy = 7;
temporal.api.enums.v1.ContinueAsNewInitiator initiator = 8;
temporal.api.failure.v1.Failure failure = 9;
temporal.api.common.v1.Payloads last_completion_result = 10;
string cron_schedule = 11;
temporal.common.v1.Header header = 12;
temporal.common.v1.Memo memo = 13;
temporal.common.v1.SearchAttributes search_attributes = 14;
temporal.api.common.v1.Header header = 12;
temporal.api.common.v1.Memo memo = 13;
temporal.api.common.v1.SearchAttributes search_attributes = 14;
}

message StartChildWorkflowExecutionDecisionAttributes {
string namespace = 1;
string workflow_id = 2;
temporal.common.v1.WorkflowType workflow_type = 3;
temporal.taskqueue.v1.TaskQueue task_queue = 4;
temporal.common.v1.Payloads input = 5;
temporal.api.common.v1.WorkflowType workflow_type = 3;
temporal.api.taskqueue.v1.TaskQueue task_queue = 4;
temporal.api.common.v1.Payloads input = 5;
// Total workflow execution timeout including retries and continue as new
int32 workflow_execution_timeout_seconds = 6;
// Timeout of a single workflow run
int32 workflow_run_timeout_seconds = 7;
// Timeout of a single workflow task
int32 workflow_task_timeout_seconds = 8;
// Default: PARENT_CLOSE_POLICY_TERMINATE.
temporal.enums.v1.ParentClosePolicy parent_close_policy = 9;
temporal.api.enums.v1.ParentClosePolicy parent_close_policy = 9;
string control = 10;
// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
temporal.enums.v1.WorkflowIdReusePolicy workflow_id_reuse_policy = 11;
temporal.common.v1.RetryPolicy retry_policy = 12;
temporal.api.enums.v1.WorkflowIdReusePolicy workflow_id_reuse_policy = 11;
temporal.api.common.v1.RetryPolicy retry_policy = 12;
string cron_schedule = 13;
temporal.common.v1.Header header = 14;
temporal.common.v1.Memo memo = 15;
temporal.common.v1.SearchAttributes search_attributes = 16;
temporal.api.common.v1.Header header = 14;
temporal.api.common.v1.Memo memo = 15;
temporal.api.common.v1.SearchAttributes search_attributes = 16;
}

message Decision {
temporal.enums.v1.DecisionType decision_type = 1;
temporal.api.enums.v1.DecisionType decision_type = 1;
oneof attributes {
ScheduleActivityTaskDecisionAttributes schedule_activity_task_decision_attributes = 2;
StartTimerDecisionAttributes start_timer_decision_attributes = 3;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "CommonProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "DecisionTypeProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "EventTypeProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "FailedCauseProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "NamespaceProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "QueryProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "TaskQueueProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@

syntax = "proto3";

package temporal.enums.v1;
package temporal.api.enums.v1;

option go_package = "go.temporal.io/temporal-proto/enums/v1;enums";
option java_package = "io.temporal.enums.v1";
option go_package = "go.temporal.io/api/enums/v1;enums";
option java_package = "io.temporal.api.enums.v1";
option java_multiple_files = true;
option java_outer_classname = "WorkflowProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,10 @@ syntax = "proto3";

// These error details extend failures defined in https://github.com/googleapis/googleapis/blob/master/google/rpc/error_details.proto

package temporal.errordetails.v1;
package temporal.api.errordetails.v1;

option go_package = "go.temporal.io/temporal-proto/errordetails/v1;errordetails";
option java_package = "io.temporal.errordetails.v1";
option go_package = "go.temporal.io/api/errordetails/v1;errordetails";
option java_package = "io.temporal.api.errordetails.v1";
option java_multiple_files = true;
option java_outer_classname = "MessageProto";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,29 +22,29 @@

syntax = "proto3";

package temporal.failure.v1;
package temporal.api.failure.v1;

option go_package = "go.temporal.io/temporal-proto/failure/v1;failure";
option java_package = "io.temporal.failure.v1";
option go_package = "go.temporal.io/api/failure/v1;failure";
option java_package = "io.temporal.api.failure.v1";
option java_multiple_files = true;
option java_outer_classname = "MessageProto";

import "temporal/common/v1/message.proto";
import "temporal/enums/v1/workflow.proto";
import "temporal/api/common/v1/message.proto";
import "temporal/api/enums/v1/workflow.proto";

message ApplicationFailureInfo {
string type = 1;
bool non_retryable = 2;
temporal.common.v1.Payloads details = 3;
temporal.api.common.v1.Payloads details = 3;
}

message TimeoutFailureInfo {
temporal.enums.v1.TimeoutType timeout_type = 1;
temporal.common.v1.Payloads last_heartbeat_details = 2;
temporal.api.enums.v1.TimeoutType timeout_type = 1;
temporal.api.common.v1.Payloads last_heartbeat_details = 2;
}

message CanceledFailureInfo {
temporal.common.v1.Payloads details = 1;
temporal.api.common.v1.Payloads details = 1;
}

message TerminatedFailureInfo {
Expand All @@ -55,25 +55,25 @@ message ServerFailureInfo {
}

message ResetWorkflowFailureInfo {
temporal.common.v1.Payloads last_heartbeat_details = 1;
temporal.api.common.v1.Payloads last_heartbeat_details = 1;
}

message ActivityFailureInfo {
int64 scheduled_event_id = 1;
int64 started_event_id = 2;
string identity = 3;
temporal.common.v1.ActivityType activity_type = 4;
temporal.api.common.v1.ActivityType activity_type = 4;
string activity_id = 5;
temporal.enums.v1.RetryStatus retry_status = 6;
temporal.api.enums.v1.RetryStatus retry_status = 6;
}

message ChildWorkflowExecutionFailureInfo {
string namespace = 1;
temporal.common.v1.WorkflowExecution workflow_execution = 2;
temporal.common.v1.WorkflowType workflow_type = 3;
temporal.api.common.v1.WorkflowExecution workflow_execution = 2;
temporal.api.common.v1.WorkflowType workflow_type = 3;
int64 initiated_event_id = 4;
int64 started_event_id = 5;
temporal.enums.v1.RetryStatus retry_status = 6;
temporal.api.enums.v1.RetryStatus retry_status = 6;
}

message Failure {
Expand Down
Loading

0 comments on commit 0cb3c3a

Please sign in to comment.