-
Notifications
You must be signed in to change notification settings - Fork 36
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Support exporting history for replay
- Loading branch information
1 parent
f5ada55
commit b385f4c
Showing
3 changed files
with
159 additions
and
119 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,146 +1,147 @@ | ||
| package common | ||
|
|
||
| const ( | ||
| // Shared flag definitions | ||
| FlagEnvDefinition = "Name of the environment to read environmental variables from." | ||
| FlagAddrDefinition = "The host and port (formatted as host:port) for the Temporal Frontend Service." | ||
| FlagNSAliasDefinition = "Identifies a Namespace in the Temporal Workflow." | ||
| FlagMetadataDefinition = "Contains gRPC metadata to send with requests (Format: key=value). Values must be in a valid JSON format." | ||
| FlagTLSCertPathDefinition = "Path to x509 certificate." | ||
| FlagTLSKeyPathDefinition = "Path to private certificate key." | ||
| FlagTLSCaPathDefinition = "Path to server CA certificate." | ||
| FlagTLSDisableHVDefinition = "Disables TLS host name verification if already enabled." | ||
| FlagTLSServerNameDefinition = "Provides an override for the target TLS server name." | ||
| FlagEnvDefinition = "Name of the environment to read environmental variables from." | ||
| FlagAddrDefinition = "The host and port (formatted as host:port) for the Temporal Frontend Service." | ||
| FlagNSAliasDefinition = "Identifies a Namespace in the Temporal Workflow." | ||
| FlagMetadataDefinition = "Contains gRPC metadata to send with requests (Format: key=value). Values must be in a valid JSON format." | ||
| FlagTLSCertPathDefinition = "Path to x509 certificate." | ||
| FlagTLSKeyPathDefinition = "Path to private certificate key." | ||
| FlagTLSCaPathDefinition = "Path to server CA certificate." | ||
| FlagTLSDisableHVDefinition = "Disables TLS host name verification if already enabled." | ||
| FlagTLSServerNameDefinition = "Provides an override for the target TLS server name." | ||
| FlagContextTimeoutDefinition = "An optional timeout for the context of an RPC call (in seconds)." | ||
| FlagCodecEndpointDefinition = "Endpoint for a remote Codec Server." | ||
| FlagCodecAuthDefinition = "Sets the authorization header on requests to the Codec Server." | ||
| FlagArchiveDefinition = "List archived Workflow Executions.\nCurrently an experimental feature." | ||
| FlagCodecEndpointDefinition = "Endpoint for a remote Codec Server." | ||
| FlagCodecAuthDefinition = "Sets the authorization header on requests to the Codec Server." | ||
| FlagArchiveDefinition = "List archived Workflow Executions.\nCurrently an experimental feature." | ||
|
|
||
| // Execution flags | ||
| FlagWorkflowId = "Workflow Id" | ||
| FlagRunIdDefinition = "Run Id" | ||
| FlagJobIDDefinition = "Batch Job Id" | ||
| FlagWorkflowId = "Workflow Id" | ||
| FlagRunIdDefinition = "Run Id" | ||
| FlagJobIDDefinition = "Batch Job Id" | ||
| FlagScheduleIDDefinition = "Schedule Id" | ||
|
|
||
| // ShowWorkflow flags | ||
| FlagOutputFilenameDefinition = "Serializes Event History to a file." | ||
| FlagMaxFieldLengthDefinition = "Maximum length for each attribute field." | ||
| FlagOutputFilenameDefinition = "Serializes Event History to a file." | ||
| FlagMaxFieldLengthDefinition = "Maximum length for each attribute field." | ||
| FlagResetPointsOnlyDefinition = "Only show Workflow Events that are eligible for reset." | ||
| FlagFollowAliasDefinition = "Follow the progress of a Workflow Execution." | ||
| FlagFollowAliasDefinition = "Follow the progress of a Workflow Execution." | ||
| FlagExportPathDefinition = "Export Workflow Execution history suited for replay." | ||
|
|
||
| // StartWorkflow flags | ||
| FlagWFTypeDefinition = "Workflow type name." | ||
| FlagTaskQueueDefinition = "Task Queue" | ||
| FlagWorkflowRunTimeoutDefinition = "Timeout (in seconds) of a single Workflow run." | ||
| FlagWFTypeDefinition = "Workflow type name." | ||
| FlagTaskQueueDefinition = "Task Queue" | ||
| FlagWorkflowRunTimeoutDefinition = "Timeout (in seconds) of a single Workflow run." | ||
| FlagWorkflowExecutionTimeoutDefinition = "Timeout (in seconds) for a WorkflowExecution, including retries and continue-as-new tasks." | ||
| FlagWorkflowTaskTimeoutDefinition = "Start-to-close timeout for a Workflow Task (in seconds)." | ||
| FlagCronScheduleDefinition = "Optional Cron Schedule for the Workflow. Cron spec is formatted as: \n" + | ||
| "\t┌───────────── minute (0 - 59) \n" + | ||
| "\t│ ┌───────────── hour (0 - 23) \n" + | ||
| "\t│ │ ┌───────────── day of the month (1 - 31) \n" + | ||
| "\t│ │ │ ┌───────────── month (1 - 12) \n" + | ||
| "\t│ │ │ │ ┌───────────── day of the week (0 - 6) (Sunday to Saturday) \n" + | ||
| "\t│ │ │ │ │ \n" + | ||
| "\t* * * * *" | ||
| FlagWorkflowTaskTimeoutDefinition = "Start-to-close timeout for a Workflow Task (in seconds)." | ||
| FlagCronScheduleDefinition = "Optional Cron Schedule for the Workflow. Cron spec is formatted as: \n" + | ||
| "\t┌───────────── minute (0 - 59) \n" + | ||
| "\t│ ┌───────────── hour (0 - 23) \n" + | ||
| "\t│ │ ┌───────────── day of the month (1 - 31) \n" + | ||
| "\t│ │ │ ┌───────────── month (1 - 12) \n" + | ||
| "\t│ │ │ │ ┌───────────── day of the week (0 - 6) (Sunday to Saturday) \n" + | ||
| "\t│ │ │ │ │ \n" + | ||
| "\t* * * * *" | ||
| FlagWorkflowIdReusePolicyDefinition = "Allows the same Workflow Id to be used in a new Workflow Execution. " + | ||
| "Options: AllowDuplicate, AllowDuplicateFailedOnly, RejectDuplicate, TerminateIfRunning." | ||
| FlagInputDefinition = "Optional JSON input to provide to the Workflow.\nPass \"null\" for null values." | ||
| "Options: AllowDuplicate, AllowDuplicateFailedOnly, RejectDuplicate, TerminateIfRunning." | ||
| FlagInputDefinition = "Optional JSON input to provide to the Workflow.\nPass \"null\" for null values." | ||
| FlagInputFileDefinition = "Passes optional input for the Workflow from a JSON file.\n" + | ||
| "If there are multiple JSON files, concatenate them and separate by space or newline.\n" + | ||
| "Input from the command line will overwrite file input." | ||
| "If there are multiple JSON files, concatenate them and separate by space or newline.\n" + | ||
| "Input from the command line will overwrite file input." | ||
| FlagSearchAttributeDefinition = "Passes Search Attribute in key=value format. Use valid JSON formats for value." | ||
| FlagMemoDefinition = "Passes a memo in key=value format. Use valid JSON formats for value." | ||
| FlagMemoFileDefinition = "Passes a memo as file input, with each line following key=value format. Use valid JSON formats for value." | ||
| FlagMemoDefinition = "Passes a memo in key=value format. Use valid JSON formats for value." | ||
| FlagMemoFileDefinition = "Passes a memo as file input, with each line following key=value format. Use valid JSON formats for value." | ||
|
|
||
| // Other Workflow flags | ||
| FlagResetPointsUsage = "Only show auto-reset points." | ||
| FlagPrintRawUsage = "Print properties as they are stored." | ||
| QueryFlagTypeUsage = "The Query type you want to run." | ||
| FlagWorkflowSignalUsage = "Signal Workflow Execution by Id." | ||
| FlagQueryDefinition = "Signal Workflow Executions by List Filter. See https://docs.temporal.io/concepts/what-is-a-list-filter/." | ||
| FlagSignalName = "Signal Name" | ||
| FlagInputSignal = "Input for the Signal (JSON)." | ||
| FlagInputFileSignal = "Input for the Signal from file (JSON)." | ||
| FlagReasonSignal = "Reason for signaling with List Filter." | ||
| FlagCancelWorkflow = "Cancel Workflow Execution by Id." | ||
| FlagReasonCancel = "Reason for canceling with List Filter." | ||
| FlagWorkflowIDTerminate = "Terminate Workflow Execution by Id." | ||
| FlagQueryTerminate = "Terminate Workflow Executions by List Filter. See https://docs.temporal.io/concepts/what-is-a-list-filter/." | ||
| FlagReasonTerminate = "Reason for termination." | ||
| FlagEventIDDefinition = "The Event Id for any Event after WorkflowTaskStarted you want to reset to (exclusive). It can be WorkflowTaskCompleted, WorkflowTaskFailed or others." | ||
| FlagReasonReset = "Reason to reset." | ||
| FlagQueryResetBatch = "Visibility Query of Search Attributes describing the Workflow Executions to reset. See https://docs.temporal.io/docs/tctl/workflow/list#--query." | ||
| FlagInputFileReset = "Input file that specifies Workflow Executions to reset. Each line contains one Workflow Id as the base Run and, optionally, a Run Id." | ||
| FlagExcludeFileDefinition = "Input file that specifies Workflow Executions to exclude from resetting." | ||
| FlagInputSeparatorDefinition = "Separator for the input file. The default is a tab (\t)." | ||
| FlagReasonResetBatch = "Reason for resetting the Workflow Executions." | ||
| FlagParallelismDefinition = "Number of goroutines to run in parallel. Each goroutine processes one line for every second." | ||
| FlagSkipCurrentOpenDefinition = "Skip a Workflow Execution if the current Run is open for the same Workflow Id as the base Run." | ||
| FlagSkipBaseDefinition = "Skip a Workflow Execution if the base Run is not the current Run." | ||
| FlagResetPointsUsage = "Only show auto-reset points." | ||
| FlagPrintRawUsage = "Print properties as they are stored." | ||
| QueryFlagTypeUsage = "The Query type you want to run." | ||
| FlagWorkflowSignalUsage = "Signal Workflow Execution by Id." | ||
| FlagQueryDefinition = "Signal Workflow Executions by List Filter. See https://docs.temporal.io/concepts/what-is-a-list-filter/." | ||
| FlagSignalName = "Signal Name" | ||
| FlagInputSignal = "Input for the Signal (JSON)." | ||
| FlagInputFileSignal = "Input for the Signal from file (JSON)." | ||
| FlagReasonSignal = "Reason for signaling with List Filter." | ||
| FlagCancelWorkflow = "Cancel Workflow Execution by Id." | ||
| FlagReasonCancel = "Reason for canceling with List Filter." | ||
| FlagWorkflowIDTerminate = "Terminate Workflow Execution by Id." | ||
| FlagQueryTerminate = "Terminate Workflow Executions by List Filter. See https://docs.temporal.io/concepts/what-is-a-list-filter/." | ||
| FlagReasonTerminate = "Reason for termination." | ||
| FlagEventIDDefinition = "The Event Id for any Event after WorkflowTaskStarted you want to reset to (exclusive). It can be WorkflowTaskCompleted, WorkflowTaskFailed or others." | ||
| FlagReasonReset = "Reason to reset." | ||
| FlagQueryResetBatch = "Visibility Query of Search Attributes describing the Workflow Executions to reset. See https://docs.temporal.io/docs/tctl/workflow/list#--query." | ||
| FlagInputFileReset = "Input file that specifies Workflow Executions to reset. Each line contains one Workflow Id as the base Run and, optionally, a Run Id." | ||
| FlagExcludeFileDefinition = "Input file that specifies Workflow Executions to exclude from resetting." | ||
| FlagInputSeparatorDefinition = "Separator for the input file. The default is a tab (\t)." | ||
| FlagReasonResetBatch = "Reason for resetting the Workflow Executions." | ||
| FlagParallelismDefinition = "Number of goroutines to run in parallel. Each goroutine processes one line for every second." | ||
| FlagSkipCurrentOpenDefinition = "Skip a Workflow Execution if the current Run is open for the same Workflow Id as the base Run." | ||
| FlagSkipBaseDefinition = "Skip a Workflow Execution if the base Run is not the current Run." | ||
| FlagNonDeterministicDefinition = "Reset Workflow Execution only if its last Event is WorkflowTaskFailed with a nondeterministic error." | ||
| FlagDryRunDefinition = "Simulate reset without resetting any Workflow Executions." | ||
| FlagDepthDefinition = "Number of Child Workflows to expand, -1 to expand all Child Workflows." | ||
| FlagConcurrencyDefinition = "Request concurrency." | ||
| FlagNoFoldDefinition = "Disable folding. All Child Workflows within the set depth will be fetched and displayed." | ||
|
|
||
| FlagDryRunDefinition = "Simulate reset without resetting any Workflow Executions." | ||
| FlagDepthDefinition = "Number of Child Workflows to expand, -1 to expand all Child Workflows." | ||
| FlagConcurrencyDefinition = "Request concurrency." | ||
| FlagNoFoldDefinition = "Disable folding. All Child Workflows within the set depth will be fetched and displayed." | ||
|
|
||
| // Stack trace query flag definitions | ||
| FlagInputSTQDefinition = "Optional Query input, in JSON format. For multiple parameters, concatenate them and separate by space." | ||
| FlagInputFileSTQDefinition = "Passes optional Query input from a JSON file.\nIf there are multiple JSON, concatenate them and separate by space or newline.\n" + "Input from the command line will overwrite file input." | ||
| FlagInputSTQDefinition = "Optional Query input, in JSON format. For multiple parameters, concatenate them and separate by space." | ||
| FlagInputFileSTQDefinition = "Passes optional Query input from a JSON file.\nIf there are multiple JSON, concatenate them and separate by space or newline.\n" + "Input from the command line will overwrite file input." | ||
| FlagQueryRejectConditionDefinition = "Optional flag for rejecting Queries based on Workflow state. Valid values are \"not_open\" and \"not_completed_cleanly\"." | ||
|
|
||
| // Pagination flag definitions | ||
| FlagLimitDefinition = "Number of items to print." | ||
| FlagPagerDefinition = "Sets the pager for Temporal CLI to use.\nOptions: less, more, favoritePager." | ||
| FlagLimitDefinition = "Number of items to print." | ||
| FlagPagerDefinition = "Sets the pager for Temporal CLI to use.\nOptions: less, more, favoritePager." | ||
| FlagNoPagerDefinition = "Disables the interactive pager." | ||
| FlagFieldsDefinition = "Customize fields to print. Set to 'long' to automatically print more of main fields." | ||
| FlagFieldsDefinition = "Customize fields to print. Set to 'long' to automatically print more of main fields." | ||
|
|
||
| // Activity flag definitions | ||
| FlagWorkflowIDDefinition = "Identifies the Workflow that the Activity is running on." | ||
| FlagRunIDDefinition = "Identifies the current Workflow Run." | ||
| FlagWorkflowIDDefinition = "Identifies the Workflow that the Activity is running on." | ||
| FlagRunIDDefinition = "Identifies the current Workflow Run." | ||
| FlagActivityCompleteDefinition = "Identifies the Activity to be completed." | ||
| FlagResultDefinition = "Set the result value of Activity completion." | ||
| FlagIdentityDefinition = "Specify operator's identity." | ||
| FlagActivityFailDefinition = "Identifies the Activity to fail." | ||
| FlagReasonDefinition = "Reason to fail the Activity." | ||
| FlagDetailDefinition = "Detail to fail the Activity." | ||
| FlagResultDefinition = "Set the result value of Activity completion." | ||
| FlagIdentityDefinition = "Specify operator's identity." | ||
| FlagActivityFailDefinition = "Identifies the Activity to fail." | ||
| FlagReasonDefinition = "Reason to fail the Activity." | ||
| FlagDetailDefinition = "Detail to fail the Activity." | ||
|
|
||
| // Batch flag definitions | ||
| FlagReasonBatchDefinition = "Reason to stop the Batch job." | ||
|
|
||
| // Cluster flag definition | ||
| FlagClusterAddressDefinition = "Frontend address of the remote Cluster." | ||
| FlagClusterAddressDefinition = "Frontend address of the remote Cluster." | ||
| FlagClusterEnableConnectionDefinition = "Enable cross-cluster connection." | ||
| FlagNameDefinition = "Frontend address of the remote Cluster." | ||
| FlagNameDefinition = "Frontend address of the remote Cluster." | ||
|
|
||
| // Schedule flag definition | ||
| FlagOverlapPolicyDefinition = "Overlap policy: Skip, BufferOne, BufferAll, CancelOther, TerminateOther, AllowAll." | ||
| FlagCalenderDefinition = `Calendar specification in JSON, e.g. {"dayOfWeek":"Fri","hour":"17","minute":"5"}` | ||
| FlagCronScheduleShortDefinition = `Calendar specification as cron string, e.g. "30 2 * * 5" or "@daily".` | ||
| FlagIntervalDefinition = "Interval duration, e.g. 90m, or 90m/13m to include phase offset." | ||
| FlagStartTimeDefinition = "Overall schedule start time." | ||
| FlagEndTimeDefinition = "Overall schedule end time." | ||
| FlagJitterDefinition = "Jitter duration." | ||
| FlagTimeZoneDefinition = "Time zone (IANA name)." | ||
| FlagNotesDefinition = "Initial value of notes field." | ||
| FlagPauseDefinition = "Initial value of paused state." | ||
| FlagRemainingActionsDefinition = "Total number of actions allowed." | ||
| FlagCatchupWindowDefinition = "Maximum allowed catch-up time if server is down." | ||
| FlagPauseOnFailureDefinition = "Pause schedule after any workflow failure." | ||
| FlagOverlapPolicyDefinition = "Overlap policy: Skip, BufferOne, BufferAll, CancelOther, TerminateOther, AllowAll." | ||
| FlagCalenderDefinition = `Calendar specification in JSON, e.g. {"dayOfWeek":"Fri","hour":"17","minute":"5"}` | ||
| FlagCronScheduleShortDefinition = `Calendar specification as cron string, e.g. "30 2 * * 5" or "@daily".` | ||
| FlagIntervalDefinition = "Interval duration, e.g. 90m, or 90m/13m to include phase offset." | ||
| FlagStartTimeDefinition = "Overall schedule start time." | ||
| FlagEndTimeDefinition = "Overall schedule end time." | ||
| FlagJitterDefinition = "Jitter duration." | ||
| FlagTimeZoneDefinition = "Time zone (IANA name)." | ||
| FlagNotesDefinition = "Initial value of notes field." | ||
| FlagPauseDefinition = "Initial value of paused state." | ||
| FlagRemainingActionsDefinition = "Total number of actions allowed." | ||
| FlagCatchupWindowDefinition = "Maximum allowed catch-up time if server is down." | ||
| FlagPauseOnFailureDefinition = "Pause schedule after any workflow failure." | ||
| FlagSearchAttributeScheduleDefinition = "Set Search Attribute on a schedule. Format: key=value. Use valid JSON formats for value." | ||
| FlagMemoScheduleDefinition = "Set a memo on a schedule. Format: key=value. Use valid JSON formats for value." | ||
| FlagMemoFileScheduleDefinition = "Set a memo from a file. Each line should follow the format key=value. Use valid JSON formats for value." | ||
| FlagPauseScheduleDefinition = "Pauses the Schedule." | ||
| FlagUnpauseDefinition = "Unpauses the Schedule." | ||
| FlagReasonScheduleDefinition = "Free-form text to describe reason for pause/unpause." | ||
| FlagBackfillStartTime = "Backfill start time." | ||
| FlagBackfillEndTime = "Backfill end time." | ||
| FlagPrintRawDefinition = "Print raw data as json (prefer this over -o json for scripting)." | ||
| FlagMemoScheduleDefinition = "Set a memo on a schedule. Format: key=value. Use valid JSON formats for value." | ||
| FlagMemoFileScheduleDefinition = "Set a memo from a file. Each line should follow the format key=value. Use valid JSON formats for value." | ||
| FlagPauseScheduleDefinition = "Pauses the Schedule." | ||
| FlagUnpauseDefinition = "Unpauses the Schedule." | ||
| FlagReasonScheduleDefinition = "Free-form text to describe reason for pause/unpause." | ||
| FlagBackfillStartTime = "Backfill start time." | ||
| FlagBackfillEndTime = "Backfill end time." | ||
| FlagPrintRawDefinition = "Print raw data as json (prefer this over -o json for scripting)." | ||
|
|
||
| // Search Attribute flags | ||
| FlagNameSearchAttribute = "Search Attribute name." | ||
| FlagYesDefinition = "Confirm all prompts." | ||
| FlagYesDefinition = "Confirm all prompts." | ||
|
|
||
| // Task Queue flags | ||
| FlagTaskQueueName = "Task Queue name." | ||
| FlagTaskQueueName = "Task Queue name." | ||
| FlagTaskQueueTypeDefinition = "Task Queue type [workflow|activity]" | ||
| ) | ||
| ) |
Oops, something went wrong.