Revision 7699c3af
| b/daemons/ganeti-masterd | ||
|---|---|---|
| 299 | 299 |
op = opcodes.OpQueryClusterInfo() |
| 300 | 300 |
return self._Query(op) |
| 301 | 301 |
|
| 302 |
elif method == luxi.REQ_QUERY_TAGS: |
|
| 303 |
kind, name = args |
|
| 304 |
logging.info("Received tags query request")
|
|
| 305 |
op = opcodes.OpGetTags(kind=kind, name=name) |
|
| 306 |
return self._Query(op) |
|
| 307 |
|
|
| 302 | 308 |
elif method == luxi.REQ_QUEUE_SET_DRAIN_FLAG: |
| 303 | 309 |
drain_flag = args |
| 304 | 310 |
logging.info("Received queue drain flag change request to %s",
|
| b/lib/cli.py | ||
|---|---|---|
| 252 | 252 |
ARGS_ONE_NODE = [ArgNode(min=1, max=1)] |
| 253 | 253 |
|
| 254 | 254 |
|
| 255 |
|
|
| 256 | 255 |
def _ExtractTagsObject(opts, args): |
| 257 | 256 |
"""Extract the tag type object. |
| 258 | 257 |
|
| ... | ... | |
| 313 | 312 |
|
| 314 | 313 |
""" |
| 315 | 314 |
kind, name = _ExtractTagsObject(opts, args) |
| 316 |
op = opcodes.OpGetTags(kind=kind, name=name)
|
|
| 317 |
result = SubmitOpCode(op)
|
|
| 315 |
cl = GetClient()
|
|
| 316 |
result = cl.QueryTags(kind, name)
|
|
| 318 | 317 |
result = list(result) |
| 319 | 318 |
result.sort() |
| 320 | 319 |
for tag in result: |
| b/lib/luxi.py | ||
|---|---|---|
| 56 | 56 |
REQ_QUERY_EXPORTS = "QueryExports" |
| 57 | 57 |
REQ_QUERY_CONFIG_VALUES = "QueryConfigValues" |
| 58 | 58 |
REQ_QUERY_CLUSTER_INFO = "QueryClusterInfo" |
| 59 |
REQ_QUERY_TAGS = "QueryTags" |
|
| 59 | 60 |
REQ_QUEUE_SET_DRAIN_FLAG = "SetDrainFlag" |
| 60 | 61 |
REQ_SET_WATCHER_PAUSE = "SetWatcherPause" |
| 61 | 62 |
|
| ... | ... | |
| 384 | 385 |
def QueryConfigValues(self, fields): |
| 385 | 386 |
return self.CallMethod(REQ_QUERY_CONFIG_VALUES, fields) |
| 386 | 387 |
|
| 388 |
def QueryTags(self, kind, name): |
|
| 389 |
return self.CallMethod(REQ_QUERY_TAGS, (kind, name)) |
|
| 390 |
|
|
| 387 | 391 |
|
| 388 | 392 |
# TODO: class Server(object) |
Also available in: Unified diff