21
prompterFactory PrompterFactory,
22
taskBlobEncoder TaskBlobEncoder,
24
>
return []*cli.Command{
25
>
{
26
>
Name: "execution",
27
>
Aliases: []string{"e", "w", "workflow"},
28
>
Usage: "Run admin operation on an execution (workflow)",
29
>
Subcommands: newAdminExecutionCommands(clientFactory, prompterFactory),
30
>
},
31
>
{
32
>
Name: "shard",
33
>
Aliases: []string{"s"},
34
>
Usage: "Run admin operation on specific shard",
35
>
Subcommands: newAdminShardManagementCommands(clientFactory, taskCategoryRegistry),
36
>
},
37
>
{
38
>
Name: "history-host",
39
>
Aliases: []string{"hh"},
40
>
Usage: "Run admin operation on history host",
41
>
Subcommands: newAdminHistoryHostCommands(clientFactory),
42
>
},
43
>
{
44
>
Name: "taskqueue",
45
>
Aliases: []string{"tq"},
46
>
Usage: "Run admin operation on taskQueue",
47
>
Subcommands: newAdminTaskQueueCommands(clientFactory),
48
>
},
49
>
{
50
>
Name: "membership",
51
>
Aliases: []string{"m"},
52
>
Usage: "Run admin operation on membership",
53
>
Subcommands: newAdminMembershipCommands(clientFactory),
54
>
},
55
>
{
56
>
Name: "dlq",
57
>
Usage: "Run admin operation on DLQ",
58
>
Subcommands: newAdminDLQCommands(dlqServiceProvider, taskCategoryRegistry),
59
>
Flags: []cli.Flag{
60
>
&cli.StringFlag{
61
>
Name: FlagDLQVersion,
62
>
Usage: "Version of DLQ to manage, options: v1, v2",
63
>
Value: "v2",
64
>
},
65
>
},
66
>
},
67
>
{
68
>
Name: "schedule",
69
>
Aliases: []string{"sch"},
70
>
Usage: "Run admin operation on a schedule",
71
>
Subcommands: newAdminScheduleCommands(clientFactory),
72
>
},
73
>
{
74
>
Name: "decode",
75
>
Usage: "Decode payload",
76
>
Subcommands: newDecodeCommands(taskBlobEncoder),
77
>
},
78
>
}
79
>
}
80
81
>
func newAdminExecutionCommands(clientFactory ClientFactory, prompterFactory PrompterFactory) []*cli.Command {
tdbg_commands.go
82
>
return []*cli.Command{
83
>
{
84
>
Name: "import",
85
>
Usage: "import workflow history to database",
86
>
Flags: []cli.Flag{
87
>
&cli.StringFlag{
88
>
Name: FlagWorkflowID,
89
>
Aliases: FlagWorkflowIDAlias,
90
>
Usage: "Workflow ID",
91
>
},
92
>
&cli.StringFlag{
93
>
Name: FlagRunID,
94
>
Aliases: FlagRunIDAlias,
95
>
Usage: "Run ID",
96
>
},
97
>
&cli.StringFlag{
98
>
Name: FlagInputFilename,
99
>
Usage: "input file",
100
>
}},
101
>
Action: func(c *cli.Context) error {
102
return AdminImportWorkflow(c, clientFactory)
103
},