mirror of
https://github.com/xcat2/confluent.git
synced 2024-11-22 17:43:14 +00:00
Merge branch 'clustertime' of github.com:jjohnson42/confluent into clustertime
This commit is contained in:
commit
41a5eaa464
@ -48,6 +48,10 @@ themselves, see nodeshell(8).
|
||||
`n4: 01 10 00`
|
||||
`n2: 01 10 00`
|
||||
|
||||
|
||||
* If wanting to use literal {} in the command, they must be escaped by doubling:
|
||||
`# noderun n1-n4 "echo {node} | awk '{{print $1}}'"`
|
||||
|
||||
## SEE ALSO
|
||||
|
||||
nodeshell(8)
|
||||
|
@ -27,7 +27,10 @@ as stderr, unlike psh which combines all stdout and stderr into stdout.
|
||||
`n4: hi`
|
||||
|
||||
* Setting a new static ip address temporarily on secondary interface of four nodes:
|
||||
`# nodeshell n1-n4 ifconfig eth1 172.30.93.{n1}`
|
||||
`# nodeshell n1-n4 ifconfig eth1 172.30.93.{n1}`
|
||||
|
||||
* If wanting to use literal {} in the command, they must be escaped by doubling:
|
||||
`# nodeshell n1-n4 "ps | awk '{{print $1}}'"`
|
||||
|
||||
## SEE ALSO
|
||||
|
||||
|
@ -200,7 +200,7 @@ def _rpc_master_del_nodes(tenant, nodes):
|
||||
ConfigManager(tenant).del_nodes(nodes)
|
||||
|
||||
|
||||
def _rpc_del_nodes(tenant, nodes)
|
||||
def _rpc_del_nodes(tenant, nodes):
|
||||
ConfigManager(tenant)._true_del_nodes(nodes)
|
||||
|
||||
|
||||
|
@ -183,8 +183,10 @@ def _expand_expression(nodes, configmanager, inputdata):
|
||||
pernodeexpressions[expanded[0]] = expanded[1]
|
||||
for node in util.natural_sort(pernodeexpressions):
|
||||
yield msg.KeyValueData({'value': pernodeexpressions[node]}, node)
|
||||
except ValueError as e:
|
||||
raise exc.InvalidArgumentException(str(e))
|
||||
except (SyntaxError, ValueError) as e:
|
||||
raise exc.InvalidArgumentException(
|
||||
'Bad confluent expression syntax (must use "{{" and "}}" if not '
|
||||
'desiring confluent expansion): ' + str(e))
|
||||
|
||||
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user