| 170 | } |
| 171 | |
| 172 | type TriggerWorkflowRequest struct { |
| 173 | state protoimpl.MessageState |
| 174 | sizeCache protoimpl.SizeCache |
| 175 | unknownFields protoimpl.UnknownFields |
| 176 | |
| 177 | Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` |
| 178 | // (optional) the input data for the workflow |
| 179 | Input string `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"` |
| 180 | // (optional) the parent workflow run id |
| 181 | ParentId *string `protobuf:"bytes,3,opt,name=parent_id,json=parentId,proto3,oneof" json:"parent_id,omitempty"` |
| 182 | // (optional) the parent task external run id |
| 183 | ParentTaskRunExternalId *string `protobuf:"bytes,4,opt,name=parent_task_run_external_id,json=parentTaskRunExternalId,proto3,oneof" json:"parent_task_run_external_id,omitempty"` |
| 184 | // (optional) the index of the child workflow. if this is set, matches on the index or the |
| 185 | // child key will return an existing workflow run if the parent id, parent task run id, and |
| 186 | // child index/key match an existing workflow run. |
| 187 | ChildIndex *int32 `protobuf:"varint,5,opt,name=child_index,json=childIndex,proto3,oneof" json:"child_index,omitempty"` |
| 188 | // (optional) the key for the child. if this is set, matches on the index or the |
| 189 | // child key will return an existing workflow run if the parent id, parent task run id, and |
| 190 | // child index/key match an existing workflow run. |
| 191 | ChildKey *string `protobuf:"bytes,6,opt,name=child_key,json=childKey,proto3,oneof" json:"child_key,omitempty"` |
| 192 | // (optional) additional metadata for the workflow |
| 193 | AdditionalMetadata *string `protobuf:"bytes,7,opt,name=additional_metadata,json=additionalMetadata,proto3,oneof" json:"additional_metadata,omitempty"` |
| 194 | // (optional) desired worker id for the workflow run, |
| 195 | // requires the workflow definition to have a sticky strategy |
| 196 | DesiredWorkerId *string `protobuf:"bytes,8,opt,name=desired_worker_id,json=desiredWorkerId,proto3,oneof" json:"desired_worker_id,omitempty"` |
| 197 | // (optional) override for the priority of the workflow tasks, will set all tasks to this priority |
| 198 | Priority *int32 `protobuf:"varint,9,opt,name=priority,proto3,oneof" json:"priority,omitempty"` |
| 199 | // (optional) the desired worker labels for the workflow run, which will be used to determine which workers can pick up the workflow's tasks. if not set, defaults to an empty set of labels, which means any worker can pick up the tasks. |
| 200 | DesiredWorkerLabels map[string]*DesiredWorkerLabels `protobuf:"bytes,10,rep,name=desired_worker_labels,json=desiredWorkerLabels,proto3" json:"desired_worker_labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` |
| 201 | } |
| 202 | |
| 203 | func (x *TriggerWorkflowRequest) Reset() { |
| 204 | *x = TriggerWorkflowRequest{} |
nothing calls this directly
no outgoing calls
no test coverage detected