-
Notifications
You must be signed in to change notification settings - Fork 4
/
mqadmin_completion
112 lines (103 loc) · 3.77 KB
/
mqadmin_completion
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
##rocketmq命令行提示及自动填充工具
##search.jerry@gmail.com
_mqadmin(){
COMPREPLY=()
local opts curl command
opts="updateTopic deleteTopic updateSubGroup deleteSubGroup updateBrokerConfig topicRoute topicStatus brokerStatus queryMsgById queryMsgByKey queryMsgByOffset printMsg producerConnection consumerConnection consumerProgress consumerStatus cloneGroupOffset clusterList updateKvConfig deleteKvConfig wipeWritePerm resetOffsetByTime updateOrderConf cleanExpiredCQ startMonitoring checkMsg statsAll syncDocs help"
command=${COMP_WORDS[1]} #指令
curl=${COMP_WORDS[COMP_CWORD]}
case "${command}" in
updateTopic)
COMPREPLY=( $(compgen -W "-t --brokerAddr --clusterName --namesrvAddr --order --perm --readQueueNums --hasUnitSub --unit --writeQueueNums" -- ${curl}) )
;;
deleteTopic)
COMPREPLY=( $(compgen -W "-t -c --namesrvAddr" -- ${curl}) )
;;
updateSubGroup)
COMPREPLY=( $(compgen -W "-g --brokerAddr --clusterName --consumeBroadcastEnable --brokerId --consumeFromMinEnable --namesrvAddr --retryQueueNums --retryMaxTimes --consumeEnable --whichBrokerWhenConsumeSlowly" -- ${curl}) )
;;
deleteSubGroup)
COMPREPLY=( $(compgen -W "-g --brokerAddr --clusterName --namesrvAddr" -- ${curl}) )
;;
updateBrokerConfig)
COMPREPLY=( $(compgen -W "-k -v --brokerAddr --clusterName --namesrvAddr" -- ${curl}) )
;;
topicRoute)
COMPREPLY=( $(compgen -W "-t --namesrvAddr" -- ${curl}) )
;;
topicStatus)
COMPREPLY=( $(compgen -W "-t --namesrvAddr" -- ${curl}) )
;;
brokerStatus)
COMPREPLY=( $(compgen -W "-b --namesrvAddr" -- ${curl}) )
;;
queryMsgById)
COMPREPLY=( $(compgen -W "-i --clientId --consumerGroup --namesrvAddr" -- ${curl}) )
;;
queryMsgByKey)
COMPREPLY=( $(compgen -W "-k -t --namesrvAddr" -- ${curl}) )
;;
queryMsgByOffset)
COMPREPLY=( $(compgen -W "-b -i -o -t --namesrvAddr" -- ${curl}) )
;;
printMsg)
COMPREPLY=( $(compgen -W "-t --beginTimestamp --charsetName --endTimestamp --subExpression --namesrvAddr" -- ${curl}) )
;;
producerConnection)
COMPREPLY=( $(compgen -W "-g -t --namesrvAddr" -- ${curl}) )
;;
consumerConnection)
COMPREPLY=( $(compgen -W "-g --namesrvAddr" -- ${curl}) )
;;
consumerProgress)
COMPREPLY=( $(compgen -W "--groupName --namesrvAddr" -- ${curl}) )
;;
consumerStatus)
COMPREPLY=( $(compgen -W "-g --clientId --jstack --namesrvAddr" -- ${curl}) )
;;
cloneGroupOffset)
COMPREPLY=( $(compgen -W "-d -s --offline --srcGroup --topic --namesrvAddr" -- ${curl}) )
;;
clusterList)
COMPREPLY=( $(compgen -W "--moreStats --namesrvAddr" -- ${curl}) )
;;
updateKvConfig)
COMPREPLY=( $(compgen -W "-k -s --value --namesrvAddr" -- ${curl}) )
;;
deleteKvConfig)
COMPREPLY=( $(compgen -W "-k -s --namesrvAddr" -- ${curl}) )
;;
wipeWritePerm)
COMPREPLY=( $(compgen -W "-b --namesrvAddr" -- ${curl}) )
;;
resetOffsetByTime)
COMPREPLY=( $(compgen -W "-g -s -t --force --namesrvAddr" -- ${curl}) )
;;
updateOrderConf)
COMPREPLY=( $(compgen -W "-m -t --orderConf --namesrvAddr" -- ${curl}) )
;;
cleanExpiredCQ)
COMPREPLY=( $(compgen -W "--brokerAddr --cluster --namesrvAddr" -- ${curl}) )
;;
startMonitoring)
COMPREPLY=( $(compgen -W "--namesrvAddr" -- ${curl}) )
;;
checkMsg)
COMPREPLY=( $(compgen -W "-l -p -s -z --namesrvAddr" -- ${curl}) )
;;
statsAll)
COMPREPLY=( $(compgen -W "--activeTopic --namesrvAddr" -- ${curl}) )
;;
syncDocs)
OMPREPLY=( $(compgen -W "-u -p --namesrvAddr" -- ${curl}) )
;;
help)
COMPREPLY=( $(compgen -W "${opts}" ${curl}) )
;;
*)
COMPREPLY=( $(compgen -W "${opts}" ${curl}) )
;;
esac
return 0
}
complete -F _mqadmin mqadmin