Fix #38623 remove xpack namespace REST API (#38625) (#39036)

* Fix #38623 remove xpack namespace REST API

Except for xpack.usage and xpack.info API's, this moves the last remaining API's out of the xpack namespace

* rename xpack api's inside inside the files as well

* updated yaml tests references to xpack namespaces api's

* update callsApi calls in the IT subclasses

* make sure docs testing does not use xpack namespaced api's

* fix leftover xpack namespaced method names in docs/build.gradle

* found another leftover reference

(cherry picked from commit ccb5d934363c37506b76119ac050a254fa80b5e7)
This commit is contained in:
Martijn Laarman 2019-02-18 12:40:07 +01:00 committed by GitHub
parent 9aa542fb1b
commit 9b4d96534b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
110 changed files with 447 additions and 447 deletions

View File

@ -840,7 +840,7 @@ buildRestTests.setups['sensor_prefab_data'] = '''
'''
buildRestTests.setups['sample_job'] = '''
- do:
xpack.ml.put_job:
ml.put_job:
job_id: "sample_job"
body: >
{
@ -894,7 +894,7 @@ buildRestTests.setups['farequote_data'] = buildRestTests.setups['farequote_index
'''
buildRestTests.setups['farequote_job'] = buildRestTests.setups['farequote_data'] + '''
- do:
xpack.ml.put_job:
ml.put_job:
job_id: "farequote"
body: >
{
@ -914,7 +914,7 @@ buildRestTests.setups['farequote_job'] = buildRestTests.setups['farequote_data']
'''
buildRestTests.setups['farequote_datafeed'] = buildRestTests.setups['farequote_job'] + '''
- do:
xpack.ml.put_datafeed:
ml.put_datafeed:
datafeed_id: "datafeed-farequote"
body: >
{
@ -978,7 +978,7 @@ buildRestTests.setups['server_metrics_data'] = buildRestTests.setups['server_met
'''
buildRestTests.setups['server_metrics_job'] = buildRestTests.setups['server_metrics_data'] + '''
- do:
xpack.ml.put_job:
ml.put_job:
job_id: "total-requests"
body: >
{
@ -1000,7 +1000,7 @@ buildRestTests.setups['server_metrics_job'] = buildRestTests.setups['server_metr
'''
buildRestTests.setups['server_metrics_datafeed'] = buildRestTests.setups['server_metrics_job'] + '''
- do:
xpack.ml.put_datafeed:
ml.put_datafeed:
datafeed_id: "datafeed-total-requests"
body: >
{
@ -1010,22 +1010,22 @@ buildRestTests.setups['server_metrics_datafeed'] = buildRestTests.setups['server
'''
buildRestTests.setups['server_metrics_openjob'] = buildRestTests.setups['server_metrics_datafeed'] + '''
- do:
xpack.ml.open_job:
ml.open_job:
job_id: "total-requests"
'''
buildRestTests.setups['server_metrics_startdf'] = buildRestTests.setups['server_metrics_openjob'] + '''
- do:
xpack.ml.start_datafeed:
ml.start_datafeed:
datafeed_id: "datafeed-total-requests"
'''
buildRestTests.setups['calendar_outages'] = '''
- do:
xpack.ml.put_calendar:
ml.put_calendar:
calendar_id: "planned-outages"
'''
buildRestTests.setups['calendar_outages_addevent'] = buildRestTests.setups['calendar_outages'] + '''
- do:
xpack.ml.post_calendar_events:
ml.post_calendar_events:
calendar_id: "planned-outages"
body: >
{ "description": "event 1", "start_time": "2017-12-01T00:00:00Z", "end_time": "2017-12-02T00:00:00Z", "calendar_id": "planned-outages" }
@ -1034,12 +1034,12 @@ buildRestTests.setups['calendar_outages_addevent'] = buildRestTests.setups['cale
'''
buildRestTests.setups['calendar_outages_openjob'] = buildRestTests.setups['server_metrics_openjob'] + '''
- do:
xpack.ml.put_calendar:
ml.put_calendar:
calendar_id: "planned-outages"
'''
buildRestTests.setups['calendar_outages_addjob'] = buildRestTests.setups['server_metrics_openjob'] + '''
- do:
xpack.ml.put_calendar:
ml.put_calendar:
calendar_id: "planned-outages"
body: >
{
@ -1048,7 +1048,7 @@ buildRestTests.setups['calendar_outages_addjob'] = buildRestTests.setups['server
'''
buildRestTests.setups['calendar_outages_addevent'] = buildRestTests.setups['calendar_outages_addjob'] + '''
- do:
xpack.ml.post_calendar_events:
ml.post_calendar_events:
calendar_id: "planned-outages"
body: >
{ "events" : [

View File

@ -97,7 +97,7 @@ buildRestTests.docs = fileTree(projectDir) {
Map<String, String> setups = buildRestTests.setups
setups['my_inactive_watch'] = '''
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
active: false
body: >
@ -216,7 +216,7 @@ setups['library'] = '''
'''
setups['sample_job'] = '''
- do:
xpack.ml.put_job:
ml.put_job:
job_id: "sample_job"
body: >
{
@ -270,7 +270,7 @@ setups['farequote_data'] = setups['farequote_index'] + '''
'''
setups['farequote_job'] = setups['farequote_data'] + '''
- do:
xpack.ml.put_job:
ml.put_job:
job_id: "farequote"
body: >
{
@ -290,7 +290,7 @@ setups['farequote_job'] = setups['farequote_data'] + '''
'''
setups['farequote_datafeed'] = setups['farequote_job'] + '''
- do:
xpack.ml.put_datafeed:
ml.put_datafeed:
datafeed_id: "datafeed-farequote"
body: >
{
@ -300,7 +300,7 @@ setups['farequote_datafeed'] = setups['farequote_job'] + '''
'''
setups['ml_filter_safe_domains'] = '''
- do:
xpack.ml.put_filter:
ml.put_filter:
filter_id: "safe_domains"
body: >
{
@ -364,7 +364,7 @@ setups['server_metrics_data'] = setups['server_metrics_index'] + '''
'''
setups['server_metrics_job'] = setups['server_metrics_data'] + '''
- do:
xpack.ml.put_job:
ml.put_job:
job_id: "total-requests"
body: >
{
@ -386,7 +386,7 @@ setups['server_metrics_job'] = setups['server_metrics_data'] + '''
'''
setups['server_metrics_datafeed'] = setups['server_metrics_job'] + '''
- do:
xpack.ml.put_datafeed:
ml.put_datafeed:
datafeed_id: "datafeed-total-requests"
body: >
{
@ -396,22 +396,22 @@ setups['server_metrics_datafeed'] = setups['server_metrics_job'] + '''
'''
setups['server_metrics_openjob'] = setups['server_metrics_datafeed'] + '''
- do:
xpack.ml.open_job:
ml.open_job:
job_id: "total-requests"
'''
setups['server_metrics_startdf'] = setups['server_metrics_openjob'] + '''
- do:
xpack.ml.start_datafeed:
ml.start_datafeed:
datafeed_id: "datafeed-total-requests"
'''
setups['calendar_outages'] = '''
- do:
xpack.ml.put_calendar:
ml.put_calendar:
calendar_id: "planned-outages"
'''
setups['calendar_outages_addevent'] = setups['calendar_outages'] + '''
- do:
xpack.ml.post_calendar_events:
ml.post_calendar_events:
calendar_id: "planned-outages"
body: >
{ "description": "event 1", "start_time": "2017-12-01T00:00:00Z", "end_time": "2017-12-02T00:00:00Z", "calendar_id": "planned-outages" }
@ -420,12 +420,12 @@ setups['calendar_outages_addevent'] = setups['calendar_outages'] + '''
'''
setups['calendar_outages_openjob'] = setups['server_metrics_openjob'] + '''
- do:
xpack.ml.put_calendar:
ml.put_calendar:
calendar_id: "planned-outages"
'''
setups['calendar_outages_addjob'] = setups['server_metrics_openjob'] + '''
- do:
xpack.ml.put_calendar:
ml.put_calendar:
calendar_id: "planned-outages"
body: >
{
@ -434,7 +434,7 @@ setups['calendar_outages_addjob'] = setups['server_metrics_openjob'] + '''
'''
setups['calendar_outages_addevent'] = setups['calendar_outages_addjob'] + '''
- do:
xpack.ml.post_calendar_events:
ml.post_calendar_events:
calendar_id: "planned-outages"
body: >
{ "events" : [
@ -473,7 +473,7 @@ setups['sensor_rollup_job'] = '''
node:
type: keyword
- do:
xpack.rollup.put_job:
rollup.put_job:
id: "sensor"
body: >
{
@ -541,7 +541,7 @@ setups['sensor_started_rollup_job'] = '''
{"timestamp": 1516297294000, "temperature": 202, "voltage": 4.0, "node": "c"}
- do:
xpack.rollup.put_job:
rollup.put_job:
id: "sensor"
body: >
{
@ -571,7 +571,7 @@ setups['sensor_started_rollup_job'] = '''
]
}
- do:
xpack.rollup.start_job:
rollup.start_job:
id: "sensor"
'''

View File

@ -79,13 +79,13 @@ public class XDocsClientYamlTestSuiteIT extends XPackRestIT {
if (isWatcherTest()) {
assertBusy(() -> {
ClientYamlTestResponse response =
getAdminExecutionContext().callApi("xpack.watcher.stats", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stats", emptyMap(), emptyList(), emptyMap());
String state = (String) response.evaluate("stats.0.watcher_state");
switch (state) {
case "stopped":
ClientYamlTestResponse startResponse =
getAdminExecutionContext().callApi("xpack.watcher.start", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.start", emptyMap(), emptyList(), emptyMap());
boolean isAcknowledged = (boolean) startResponse.evaluate("acknowledged");
assertThat(isAcknowledged, is(true));
throw new AssertionError("waiting until stopped state reached started state");

View File

@ -35,9 +35,9 @@ public class MlWithSecurityUserRoleIT extends MlWithSecurityIT {
// role
for (ExecutableSection section : testCandidate.getTestSection().getExecutableSections()) {
if (section instanceof DoSection) {
if (((DoSection) section).getApiCallSection().getApi().startsWith("xpack.ml.") &&
((DoSection) section).getApiCallSection().getApi().startsWith("xpack.ml.get_") == false &&
((DoSection) section).getApiCallSection().getApi().equals("xpack.ml.find_file_structure") == false) {
if (((DoSection) section).getApiCallSection().getApi().startsWith("ml.") &&
((DoSection) section).getApiCallSection().getApi().startsWith("ml.get_") == false &&
((DoSection) section).getApiCallSection().getApi().equals("ml.find_file_structure") == false) {
fail("should have failed because of missing role");
}
}

View File

@ -105,13 +105,13 @@ public class XPackRestIT extends ESClientYamlSuiteTestCase {
if (isWatcherTest()) {
assertBusy(() -> {
ClientYamlTestResponse response =
getAdminExecutionContext().callApi("xpack.watcher.stats", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stats", emptyMap(), emptyList(), emptyMap());
String state = (String) response.evaluate("stats.0.watcher_state");
switch (state) {
case "stopped":
ClientYamlTestResponse startResponse =
getAdminExecutionContext().callApi("xpack.watcher.start", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.start", emptyMap(), emptyList(), emptyMap());
boolean isAcknowledged = (boolean) startResponse.evaluate("acknowledged");
assertThat(isAcknowledged, is(true));
throw new AssertionError("waiting until stopped state reached started state");

View File

@ -1,5 +1,5 @@
{
"xpack.graph.explore": {
"graph.explore": {
"documentation": "https://www.elastic.co/guide/en/elasticsearch/reference/current/graph-explore-api.html",
"methods": ["GET", "POST"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.delete": {
"license.delete": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["DELETE"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.get": {
"license.get": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["GET"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.get_basic_status": {
"license.get_basic_status": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["GET"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.get_trial_status": {
"license.get_trial_status": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["GET"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.post": {
"license.post": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["PUT", "POST"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.post_start_basic": {
"license.post_start_basic": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["POST"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.license.post_start_trial": {
"license.post_start_trial": {
"documentation": "https://www.elastic.co/guide/en/x-pack/current/license-management.html",
"methods": ["POST"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.migration.deprecations": {
"migration.deprecations": {
"documentation": "http://www.elastic.co/guide/en/migration/current/migration-api-deprecation.html",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.migration.get_assistance": {
"migration.get_assistance": {
"documentation": "https://www.elastic.co/guide/en/elasticsearch/reference/current/migration-api-assistance.html",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.migration.upgrade": {
"migration.upgrade": {
"documentation": "https://www.elastic.co/guide/en/elasticsearch/reference/current/migration-api-upgrade.html",
"methods": [ "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.delete_job": {
"rollup.delete_job": {
"documentation": "",
"methods": [ "DELETE" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.get_jobs": {
"rollup.get_jobs": {
"documentation": "",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.get_rollup_caps": {
"rollup.get_rollup_caps": {
"documentation": "",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.get_rollup_index_caps": {
"rollup.get_rollup_index_caps": {
"documentation": "",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.put_job": {
"rollup.put_job": {
"documentation": "",
"methods": [ "PUT" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.rollup_search": {
"rollup.rollup_search": {
"documentation": "",
"methods": [ "GET", "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.start_job": {
"rollup.start_job": {
"documentation": "",
"methods": [ "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.rollup.stop_job": {
"rollup.stop_job": {
"documentation": "",
"methods": [ "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.sql.clear_cursor": {
"sql.clear_cursor": {
"documentation": "Clear SQL cursor",
"methods": [ "POST"],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.sql.query": {
"sql.query": {
"documentation": "Execute SQL",
"methods": [ "POST", "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.sql.translate": {
"sql.translate": {
"documentation": "Translate SQL into Elasticsearch queries",
"methods": [ "POST", "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.ack_watch": {
"watcher.ack_watch": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-ack-watch.html",
"methods": [ "PUT", "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.activate_watch": {
"watcher.activate_watch": {
"documentation": "https://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-activate-watch.html",
"methods": [ "PUT", "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.deactivate_watch": {
"watcher.deactivate_watch": {
"documentation": "https://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-deactivate-watch.html",
"methods": [ "PUT", "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.delete_watch": {
"watcher.delete_watch": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-delete-watch.html",
"methods": [ "DELETE" ],

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.execute_watch": {
"watcher.execute_watch": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-execute-watch.html",
"methods": [ "PUT", "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.get_watch": {
"watcher.get_watch": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-get-watch.html",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.put_watch": {
"watcher.put_watch": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-put-watch.html",
"methods": [ "PUT", "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.start": {
"watcher.start": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-start.html",
"methods": [ "POST" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.stats": {
"watcher.stats": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-stats.html",
"methods": [ "GET" ],
"url": {

View File

@ -1,5 +1,5 @@
{
"xpack.watcher.stop": {
"watcher.stop": {
"documentation": "http://www.elastic.co/guide/en/elasticsearch/reference/current/watcher-api-stop.html",
"methods": [ "POST" ],
"url": {

View File

@ -7,7 +7,7 @@ setup:
---
"Test Deprecations":
- do:
xpack.migration.deprecations:
migration.deprecations:
index: "*"
- length: { cluster_settings: 0 }
- length: { node_settings: 0 }
@ -54,7 +54,7 @@ setup:
- do:
warnings:
- Deprecated field [use_dis_max] used, replaced by [Set [tie_breaker] to 1 instead]
xpack.migration.deprecations:
migration.deprecations:
index: "*"
- length: { ml_settings: 1 }
- match: { ml_settings.0.level : warning }

View File

@ -39,7 +39,7 @@ setup:
wait_for_status: green
- do:
xpack.graph.explore:
graph.explore:
index: test_1
body: {"query": {"match": {"keys": 1}},"controls":{"use_significance":false},"vertices":[{"field": "keys","min_doc_count": 1}]}
- length: {failures: 0}

View File

@ -1,7 +1,7 @@
---
teardown:
- do:
xpack.license.post:
license.post:
acknowledge: true
body: |
{"licenses":[{"uid":"3aa62ffe-36e1-4fad-bfdc-9dff8301eb22","type":"trial","issue_date_in_millis":1523456691721,"expiry_date_in_millis":1838816691721,"max_nodes":5,"issued_to":"customer","issuer":"elasticsearch","signature":"AAAABAAAAA2kWNcuc+DT0lrlmYZKAAAAIAo5/x6hrsGh1GqqrJmy4qgmEC7gK0U4zQ6q5ZEMhm4jAAABAEn6fG9y2VxKBu2T3D5hffh56kzOQODCOdhr0y2d17ZSIJMZRqO7ZywPCWNS1aR33GhfIHkTER0ysML0xMH/gXavhyRvMBndJj0UBKzuwpTawSlnxYtcqN8mSBIvJC7Ki+uJ1SpAILC2ZP9fnkRlqwXqBlTwfYn7xnZgu9DKrOWru/ipTPObo7jcePl8VTK6nWFen7/hCFDQTUFZ0jQvd+nq7A1PAcHGNxGfdbMVmAXCXgGWkRfT3clo9/vadgo+isNyh1sPq9mN7gwsvBAKtA1FrpH2EXYYbfOsSpBvUmhYMgErLg1k3/CbS0pCWLKOaX1xTMayosdZOjagU3auZXY=","start_date_in_millis":-1}]}
@ -10,7 +10,7 @@ teardown:
## current license version
- do:
xpack.license.post:
license.post:
acknowledge: true
body: |
{"licenses":[{"uid":"894371dc-9t49-4997-93cb-8o2e3r7fa6a8","type":"trial","issue_date_in_millis":1411948800000,"expiry_date_in_millis":1916956799999,"max_nodes":1,"issued_to":"issuedTo","issuer":"issuer","signature":"AAAAAgAAAA0FWh0T9njItjQ2qammAAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQBZhvozA0trrxhUZ1QbaTsKTna9C5KVQ6pv8yg1pnsBpZXCl8kX1SrgoFn1bXq61IvJwfw5qnmYNiH3hRhTO9EyaCBqaLk8NXZQ6TrRkQSpEnnBwAYUkZeKXsIuBoOk4B4mzwC/r8aMAkzrTiEBtBbog+57cSaU9y37Gkdd+1jXCQrxP+jOEUf7gnXWZvE6oeRroLvCt1fYn09k0CF8kKTbrPTSjC6igZR3uvTHyee74XQ9PRavvHax73T4UOEdQZX/P1ibSQIWKbBRD5YQ1POYVjTayoltTnWLMxfEcAkkATJZLhpBEHST7kZWjrTS6J1dCReJc7a8Vsj/78HXvOIy"}]}
@ -18,14 +18,14 @@ teardown:
- match: { license_status: "valid" }
- do:
xpack.license.get: {}
license.get: {}
## a license object has 11 attributes
- length: { license: 11 }
## bwc for licenses format
- do:
xpack.license.post:
license.post:
acknowledge: true
body: |
{"licenses":[{"uid":"893361dc-9749-4997-93cb-802e3d7fa4a8","type":"gold","issue_date_in_millis":1411948800000,"expiry_date_in_millis":1914278399999,"max_nodes":1,"issued_to":"issued_to","issuer":"issuer","signature":"AAAAAwAAAA2T3vqdBBetKQaBgxipAAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQB7pGFYgawfLm9zzT80LvcLHjy1t/v2uSzCQWKdXXhrwSy4WrAH2uK/+PEiQ7aEpW5erLsyJ5KLA6OEZJDaP7r+mjOPuLt0++l5j4DMn7ybMzOPHXWBc6LETE3+pp0GZPyOmwsDkZSRUegTtciR2R6z+mdnGrhOYM80y08KVWwhdU/DHw41MK7ePo6tq73Nz49y9lDgt9fxA0t4ggEBPbnTDDBVQ25AjauY8sa0M5eg9rDDRayw1KamYWrara8PIGX+2YjhtUeQhmlCPdlxc9wECJ7/knPss5bI3ZoXQR3fyXhjcXNnHEIsblqLrMCal3pLxs7lI+KPYMa2ZYL/am4P"}]}
@ -33,13 +33,13 @@ teardown:
- match: { license_status: "valid" }
- do:
xpack.license.get: {}
license.get: {}
- length: { license: 11 }
## license version: 1.x
- do:
xpack.license.post:
license.post:
acknowledge: true
body: |
{"licenses":[{"uid":"893361dc-9749-4997-93cb-802e3d7fa4a8","type":"subscription","subscription_type":"gold","issue_date_in_millis":1411948800000,"feature":"shield","expiry_date_in_millis":1914278399999,"max_nodes":1,"issued_to":"issuedTo","issuer":"issuer","signature":"AAAAAQAAAA0LVAywwpSH94cyXr4zAAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQA4qscc/URRZVdFoLwgy9dqybYEQLW8YLkiAyPV5XHHHdtk+dtZIepiNEDkUXhSX2waVJlsNRF8/4kqplDfwNoD2TUM8fTgiIfiSiZYGDTGST+yW/5eAveEU5J5v1liBN27bwkqL+V4YAa0Tcm7NKKwjScWKAHiTU3vF8chPkGfCHE0kQgVwPC9RE82pTw0s6/uR4PfLGNFfqPM0uiE5nucfVrtj89JQiO/KA/7ZyFbo7VTNXxZQt7T7rZWBCP9KIjptXzcWuk08Q5S+rSoJNYbFo3HGKtrCVsRz/55rceNtdwKKXu1IwnSeir4I1/KLduQTtFLy0+1th87VS8T88UT"}]}
@ -47,13 +47,13 @@ teardown:
- match: { license_status: "valid" }
- do:
xpack.license.get: {}
license.get: {}
- length: { license: 11 }
## multiple licenses version: 1.x
- do:
xpack.license.post:
license.post:
acknowledge: true
body: |
{"licenses":[{"uid":"893361dc-9749-4997-93cb-802e3d7fa4a8","type":"internal","subscription_type":"none","issue_date_in_millis":1411948800000,"feature":"shield","expiry_date_in_millis":1440892799999,"max_nodes":1,"issued_to":"issuedTo","issuer":"issuer","signature":"AAAAAQAAAA04Q4ky3rFyyWLFkytEAAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQBxMvUMn4h2E4R4TQMijahTxQj4LPQO4f1M79UxX/XkDlGcH+J5pRHx08OtTRPsFL1lED+h+PIXx307Vo+PNDsOxrWvoYZeYBkOLAO3ny9vhQga+52jYhMxIuFrT9xbcSCSNpMhGojgOIPU2WgiopVdVcimo1+Gk8VtklPB1wPwFzfOjOnPgp/Icx3WYpfkeAUUOyWUYiFIBAe4bnz84iF+xwLKbgYk6aHF25ECBtdb/Uruhcm9+jEFpoIEUtCouvvk9C+NJZ4OickV4xpRgaRG2x9PONH8ZN0QGhGYhJGbisoCxuDmlLsyVxqxfMu3n/r7/jdsEJScjAlSrsLDOu6H"},{"uid":"893361dc-9749-4997-93cb-802e3dofh7aa","type":"internal","subscription_type":"none","issue_date_in_millis":1443484800000,"feature":"watcher","expiry_date_in_millis":1914278399999,"max_nodes":1,"issued_to":"issuedTo","issuer":"issuer","signature":"AAAAAQAAAA0Sc90guRIaQEmgLvMnAAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQCQ94dju0pnDZR3Uuypi0ic3aQJ+nvVqe+U8u79Dga5n1qIjcHDh7HvIBJEkF+tnVPlo/PXV/x7BZSwVY1PVErit+6rYix1yuHEgqwxmx/VdRICjCaZM6tk0Ob4dZCPv6Ebn2Mmk89KHC/PwiLPqF6QfwV/Pkpa8k2A3ORJmvYSDvXhe6tCs8dqc4ebrsFxqrZjwWh5CZSpzqqZBFXlngDv2N0hHhpGlueRszD0JJ5dfEL5ZA1DDOrgO9OJVejSHyRqe1L5QRUNdXPVfS+EAG0Dd1cNdJ/sMpYCPnVjbw6iq2/YgM3cuztsXVBY7ij4WnoP3ce7Zjs9TwHn+IqzftC6"}]}
@ -61,19 +61,19 @@ teardown:
- match: { license_status: "valid" }
- do:
xpack.license.get: {}
license.get: {}
- length: { license: 11 }
- match: { license.uid: "893361dc-9749-4997-93cb-802e3dofh7aa" }
---
"Should throw 404 after license deletion":
- do:
xpack.license.delete: {}
license.delete: {}
- match: { acknowledged: true }
- do:
xpack.license.get: {}
license.get: {}
catch: missing
---
@ -81,7 +81,7 @@ teardown:
# VERSION_NO_FEATURE_TYPE license version
- do:
xpack.license.post:
license.post:
acknowledge: true
body: |
{"license": {"uid":"893361dc-9749-4997-93cb-802e3d7fa4a8","type":"gold","issue_date_in_millis":1411948800000,"expiry_date_in_millis":1914278399999,"max_nodes":1,"issued_to":"issued_to","issuer":"issuer","signature":"AAAAAgAAAA3U8+YmnvwC+CWsV/mRAAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQBe8GfzDm6T537Iuuvjetb3xK5dvg0K5NQapv+rczWcQFxgCuzbF8plkgetP1aAGZP4uRESDQPMlOCsx4d0UqqAm9f7GbBQ3l93P+PogInPFeEH9NvOmaAQovmxVM9SE6DsDqlX4cXSO+bgWpXPTd2LmpoQc1fXd6BZ8GeuyYpVHVKp9hVU0tAYjw6HzYOE7+zuO1oJYOxElqy66AnIfkvHrvni+flym3tE7tDTgsDRaz7W3iBhaqiSntEqabEkvHdPHQdSR99XGaEvnHO1paK01/35iZF6OXHsF7CCj+558GRXiVxzueOe7TsGSSt8g7YjZwV9bRCyU7oB4B/nidgI"}}
@ -89,7 +89,7 @@ teardown:
- match: { license_status: "valid" }
- do:
xpack.license.get: {}
license.get: {}
- length: { license: 11 }
---
@ -97,7 +97,7 @@ teardown:
- do:
catch: bad_request
xpack.license.post:
license.post:
acknowledge: true
body: |
{"license":{"uid":"893361dc-9749-4997-93cb-802e3d7fa4a8","type":"basic","issue_date_in_millis":1411948800000,"expiry_date_in_millis":1914278399999,"max_nodes":1,"issued_to":"issuedTo","issuer":"issuer","signature":"AAAAAgAAAA0lKPZ0a7aZquUltho/AAABmC9ZN0hjZDBGYnVyRXpCOW5Bb3FjZDAxOWpSbTVoMVZwUzRxVk1PSmkxakxZdW5IMlhlTHNoN1N2MXMvRFk4d3JTZEx3R3RRZ0pzU3lobWJKZnQvSEFva0ppTHBkWkprZWZSQi9iNmRQNkw1SlpLN0lDalZCS095MXRGN1lIZlpYcVVTTnFrcTE2dzhJZmZrdFQrN3JQeGwxb0U0MXZ0dDJHSERiZTVLOHNzSDByWnpoZEphZHBEZjUrTVBxRENNSXNsWWJjZllaODdzVmEzUjNiWktNWGM5TUhQV2plaUo4Q1JOUml4MXNuL0pSOEhQaVB2azhmUk9QVzhFeTFoM1Q0RnJXSG53MWk2K055c28zSmRnVkF1b2JSQkFLV2VXUmVHNDZ2R3o2VE1qbVNQS2lxOHN5bUErZlNIWkZSVmZIWEtaSU9wTTJENDVvT1NCYklacUYyK2FwRW9xa0t6dldMbmMzSGtQc3FWOTgzZ3ZUcXMvQkt2RUZwMFJnZzlvL2d2bDRWUzh6UG5pdENGWFRreXNKNkE9PQAAAQAALuQ44S3IG6SzolcXVJ6Z4CIXORDrYQ+wdLCeey0XdujTslAOj+k+vNgo6wauc7Uswi01esHu4lb5IgpvKy7RRCbh5bj/z2ubu2qMJqopp9BQyD7VQjVfqmG6seUMJwJ1a5Avvm9r41YPSPcrii3bKK2e1l6jK6N8ibCvnTyY/XkYGCJrBWTSJePDbg6ErbyodrZ37x1StLbPWcNAkmweyHjDJnvYnbeZZO7A3NmubXZjW7Ttf8/YwQyE00PqMcl7fVPY3hkKpAeHf8aaJbqkKYbqZuER3EWJX7ZvLVb1dNdNg8aXRn7YrkQcYwWgptYQpfV+D7yEJ4j5muAEoler"}}
@ -108,7 +108,7 @@ teardown:
- do:
catch: bad_request
xpack.license.post:
license.post:
acknowledge: true
- match: { error.root_cause.0.reason: 'The license must be provided in the request body' }
@ -116,24 +116,24 @@ teardown:
"Current license is trial means not eligle to start trial":
- do:
xpack.license.get_trial_status: {}
license.get_trial_status: {}
- match: { eligible_to_start_trial: false }
- do:
xpack.license.post_start_basic:
license.post_start_basic:
acknowledge: true
- match: { basic_was_started: true }
- do:
xpack.license.get_trial_status: {}
license.get_trial_status: {}
- match: { eligible_to_start_trial: false }
- do:
catch: forbidden
xpack.license.post_start_trial:
license.post_start_trial:
acknowledge: true
- match: { trial_was_started: false }
@ -142,31 +142,31 @@ teardown:
"Trial license cannot be basic":
- do:
catch: bad_request
xpack.license.post_start_trial:
license.post_start_trial:
type: "basic"
acknowledge: true
---
"Can start basic license if do not already have basic":
- do:
xpack.license.get_basic_status: {}
license.get_basic_status: {}
- match: { eligible_to_start_basic: true }
- do:
xpack.license.post_start_basic:
license.post_start_basic:
acknowledge: true
- match: { basic_was_started: true }
- match: { acknowledged: true }
- do:
xpack.license.get_basic_status: {}
license.get_basic_status: {}
- match: { eligible_to_start_basic: false }
- do:
catch: forbidden
xpack.license.post_start_basic: {}
license.post_start_basic: {}
- match: { basic_was_started: false }
- match: { acknowledged: true }
@ -174,7 +174,7 @@ teardown:
---
"Must acknowledge to start basic":
- do:
xpack.license.post_start_basic: {}
license.post_start_basic: {}
- match: { basic_was_started: false }
- match: { acknowledged: false }

View File

@ -15,7 +15,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -41,7 +41,7 @@ setup:
"Test basic delete_job":
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
@ -80,12 +80,12 @@ setup:
upgraded_doc_id: true
- do:
xpack.rollup.delete_job:
rollup.delete_job:
id: foo
- is_true: acknowledged
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
jobs: []
@ -94,7 +94,7 @@ setup:
"Test delete job twice":
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
@ -133,12 +133,12 @@ setup:
upgraded_doc_id: true
- do:
xpack.rollup.delete_job:
rollup.delete_job:
id: foo
- is_true: acknowledged
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
jobs: []
@ -147,7 +147,7 @@ setup:
"Test delete running job":
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
@ -186,13 +186,13 @@ setup:
upgraded_doc_id: true
- do:
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
- do:
catch: request
xpack.rollup.delete_job:
rollup.delete_job:
id: foo
- is_false: acknowledged
- match: { task_failures.0.reason.type: "illegal_state_exception" }
@ -205,5 +205,5 @@ setup:
catch: /the task with id \[does_not_exist\] doesn't exist/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.delete_job:
rollup.delete_job:
id: does_not_exist

View File

@ -18,7 +18,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -42,7 +42,7 @@ setup:
- is_true: acknowledged
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
@ -83,7 +83,7 @@ setup:
"Test get with no jobs":
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: "_all"
- length: { jobs: 0 }
@ -92,7 +92,7 @@ setup:
"Test get missing job":
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
@ -108,7 +108,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -134,7 +134,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: bar
body: >
{
@ -158,7 +158,7 @@ setup:
- is_true: acknowledged
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: "_all"
- length: { jobs: 2 }

View File

@ -36,7 +36,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -62,7 +62,7 @@ setup:
"Verify one job caps":
- do:
xpack.rollup.get_rollup_caps:
rollup.get_rollup_caps:
id: "foo"
- match:
@ -87,7 +87,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -109,7 +109,7 @@ setup:
]
}
- do:
xpack.rollup.get_rollup_caps:
rollup.get_rollup_caps:
id: "foo"
- match:
@ -146,7 +146,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -171,7 +171,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo3
body: >
{
@ -194,7 +194,7 @@ setup:
}
- do:
xpack.rollup.get_rollup_caps:
rollup.get_rollup_caps:
id: "_all"
- match:

View File

@ -36,7 +36,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -62,7 +62,7 @@ setup:
"Verify one job caps by rollup index":
- do:
xpack.rollup.get_rollup_index_caps:
rollup.get_rollup_index_caps:
index: "foo_rollup"
- match:
@ -87,7 +87,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -109,7 +109,7 @@ setup:
]
}
- do:
xpack.rollup.get_rollup_index_caps:
rollup.get_rollup_index_caps:
index: "foo_rollup"
- match:
@ -147,7 +147,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -169,7 +169,7 @@ setup:
]
}
- do:
xpack.rollup.get_rollup_index_caps:
rollup.get_rollup_index_caps:
index: "foo_rollup"
- match:
@ -194,7 +194,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -218,7 +218,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo3
body: >
{
@ -241,7 +241,7 @@ setup:
}
- do:
xpack.rollup.get_rollup_index_caps:
rollup.get_rollup_index_caps:
index: "_all"
- match:
@ -297,7 +297,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -321,7 +321,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo3
body: >
{
@ -344,7 +344,7 @@ setup:
}
- do:
xpack.rollup.get_rollup_index_caps:
rollup.get_rollup_index_caps:
index: "foo_rollup2,foo_rollup"
- match:
@ -396,7 +396,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -420,7 +420,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo3
body: >
{
@ -443,7 +443,7 @@ setup:
}
- do:
xpack.rollup.get_rollup_index_caps:
rollup.get_rollup_index_caps:
index: "*_rollup2"
- match:

View File

@ -18,7 +18,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -42,7 +42,7 @@ setup:
- is_true: acknowledged
- do:
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
@ -86,7 +86,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -113,7 +113,7 @@ setup:
catch: /Cannot create rollup job \[foo\] because job was previously created \(existing metadata\)/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -144,7 +144,7 @@ setup:
catch: /foo/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -174,7 +174,7 @@ setup:
catch: /unknown field \[headers\], parser not found/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -206,7 +206,7 @@ setup:
catch: /Could not find a \[numeric\] or \[date\] field with name \[field_doesnt_exist\] in any of the indices matching the index pattern/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -235,7 +235,7 @@ setup:
catch: /Unsupported metric \[does_not_exist\]/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{

View File

@ -17,7 +17,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -127,7 +127,7 @@ setup:
"Basic Search":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -152,7 +152,7 @@ setup:
"Formatted Date Histo":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -178,7 +178,7 @@ setup:
"Empty aggregation":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
rest_total_hits_as_int: true
index: "foo_rollup"
body:
@ -193,7 +193,7 @@ setup:
"Empty aggregation with new response format":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -210,7 +210,7 @@ setup:
"Search with Metric":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -243,7 +243,7 @@ setup:
"Search with Query":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -280,7 +280,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -388,7 +388,7 @@ setup:
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -423,7 +423,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -531,7 +531,7 @@ setup:
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -568,7 +568,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo2
body: >
{
@ -675,7 +675,7 @@ setup:
"_rollup.version": 1
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
body:
size: 0
@ -710,7 +710,7 @@ setup:
"Wildcards matching single rollup index":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup*"
body:
size: 0
@ -750,7 +750,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: bar
body: >
{
@ -777,7 +777,7 @@ setup:
- do:
catch: /RollupSearch currently only supports searching one rollup index at a time\./
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "*_rollup"
body:
size: 0
@ -798,7 +798,7 @@ setup:
name: rollup_alias
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "rollup_alias"
body:
size: 0
@ -838,7 +838,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: bar
body: >
{
@ -870,7 +870,7 @@ setup:
- do:
catch: /RollupSearch currently only supports searching one rollup index at a time\./
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "rollup_alias"
body:
size: 0
@ -886,7 +886,7 @@ setup:
"Search with typed_keys":
- do:
xpack.rollup.rollup_search:
rollup.rollup_search:
index: "foo_rollup"
typed_keys: true
body:

View File

@ -89,7 +89,7 @@ teardown:
# This index pattern will match both indices, but we only have permission to read one
- do:
headers: { Authorization: "Basic dGVzdF91c2VyOngtcGFjay10ZXN0LXBhc3N3b3Jk" } # test_user
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -115,7 +115,7 @@ teardown:
- do:
headers: { Authorization: "Basic dGVzdF91c2VyOngtcGFjay10ZXN0LXBhc3N3b3Jk" } # test_user
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
@ -135,7 +135,7 @@ teardown:
- do:
headers: { Authorization: "Basic dGVzdF91c2VyOngtcGFjay10ZXN0LXBhc3N3b3Jk" } # test_user
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
jobs.0.stats.documents_processed: 1
@ -250,7 +250,7 @@ teardown:
# Index contains two docs, but we should only be able to see one of them
- do:
headers: { Authorization: "Basic dGVzdF91c2VyOngtcGFjay10ZXN0LXBhc3N3b3Jk" } # test_user
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -275,7 +275,7 @@ teardown:
- do:
headers: { Authorization: "Basic dGVzdF91c2VyOngtcGFjay10ZXN0LXBhc3N3b3Jk" } # test_user
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
@ -295,7 +295,7 @@ teardown:
- do:
headers: { Authorization: "Basic dGVzdF91c2VyOngtcGFjay10ZXN0LXBhc3N3b3Jk" } # test_user
xpack.rollup.get_jobs:
rollup.get_jobs:
id: foo
- match:
jobs.0.stats.documents_processed: 1

View File

@ -15,7 +15,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -44,7 +44,7 @@ setup:
catch: /Task for Rollup Job \[does_not_exist\] not found/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.start_job:
rollup.start_job:
id: does_not_exist
@ -54,7 +54,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
@ -62,6 +62,6 @@ setup:
catch: /Cannot start task for Rollup Job \[foo\] because state was/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.start_job:
rollup.start_job:
id: foo

View File

@ -15,7 +15,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.put_job:
rollup.put_job:
id: foo
body: >
{
@ -44,7 +44,7 @@ setup:
catch: /Task for Rollup Job \[does_not_exist\] not found/
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.stop_job:
rollup.stop_job:
id: does_not_exist
@ -54,21 +54,21 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.stop_job:
rollup.stop_job:
id: foo
- is_true: stopped
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.stop_job:
rollup.stop_job:
id: foo
- is_true: stopped
@ -78,7 +78,7 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.stop_job:
rollup.stop_job:
id: foo
- is_true: stopped
@ -92,14 +92,14 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.stop_job:
rollup.stop_job:
id: foo
wait_for_completion: true
- is_true: stopped
@ -113,14 +113,14 @@ setup:
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.start_job:
rollup.start_job:
id: foo
- is_true: started
- do:
headers:
Authorization: "Basic eF9wYWNrX3Jlc3RfdXNlcjp4LXBhY2stdGVzdC1wYXNzd29yZA==" # run as x_pack_rest_user, i.e. the test setup superuser
xpack.rollup.stop_job:
rollup.stop_job:
id: foo
wait_for_completion: true
timeout: "5s"

View File

@ -26,7 +26,7 @@ setup:
---
"Execute some SQL":
- do:
xpack.sql.query:
sql.query:
format: json
body:
query: "SELECT * FROM test ORDER BY int asc"
@ -42,7 +42,7 @@ setup:
---
"Paging through results":
- do:
xpack.sql.query:
sql.query:
format: json
body:
query: "SELECT * FROM test ORDER BY int asc"
@ -57,7 +57,7 @@ setup:
- set: { cursor: cursor }
- do:
xpack.sql.query:
sql.query:
format: json
body:
cursor: "$cursor"
@ -68,7 +68,7 @@ setup:
- set: { cursor: cursor }
- do:
xpack.sql.query:
sql.query:
format: json
body:
cursor: "$cursor"
@ -79,7 +79,7 @@ setup:
---
"Getting textual representation":
- do:
xpack.sql.query:
sql.query:
format: txt
body:
query: "SELECT * FROM test ORDER BY int asc"
@ -95,7 +95,7 @@ setup:
---
"Clean cursor":
- do:
xpack.sql.query:
sql.query:
format: json
body:
query: "SELECT * FROM test ORDER BY int asc"
@ -108,7 +108,7 @@ setup:
- set: { cursor: cursor}
- do:
xpack.sql.clear_cursor:
sql.clear_cursor:
body:
cursor: "$cursor"
- match: { "succeeded": true }

View File

@ -16,7 +16,7 @@
int: 1
- do:
xpack.sql.translate:
sql.translate:
body:
query: "SELECT * FROM test ORDER BY int asc"
- match:

View File

@ -1,7 +1,7 @@
---
setup:
- do:
xpack.license.post:
license.post:
body: >
{
"license": {
@ -27,7 +27,7 @@ setup:
---
"Upgrade info - all":
- do:
xpack.migration.get_assistance: { index: _all }
migration.get_assistance: { index: _all }
- length: { indices: 0 }
@ -35,13 +35,13 @@ setup:
"Upgrade test - should fail as index is already up to date":
- do:
catch: /illegal_state_exception/
xpack.migration.upgrade: { index: test1 }
migration.upgrade: { index: test1 }
---
"Upgrade test - wait_for_completion:false":
- do:
xpack.migration.upgrade:
migration.upgrade:
index: test1
wait_for_completion: false

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -38,7 +38,7 @@
wait_for_status: yellow
- do:
xpack.watcher.ack_watch:
watcher.ack_watch:
watch_id: "my_watch"
- match: { "status.actions.test_index.ack.state" : "awaits_successful_execution" }
@ -52,7 +52,7 @@
- match: { hits.hits.0._source.status.actions.test_index.ack.state: "awaits_successful_execution" }
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
- match: { found: true }
@ -63,6 +63,6 @@
cluster.health:
wait_for_status: yellow
- do:
xpack.watcher.ack_watch:
watcher.ack_watch:
watch_id: "non-existent-watch"
catch: missing

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -38,14 +38,14 @@
wait_for_status: yellow
- do:
xpack.watcher.ack_watch:
watcher.ack_watch:
watch_id: "my_watch"
action_id: "test_index"
- match: { "status.actions.test_index.ack.state" : "awaits_successful_execution" }
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
- match: { found: true }

View File

@ -7,7 +7,7 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
@ -15,7 +15,7 @@ teardown:
"Ensure that ack status is reset after unsuccessful execution":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -45,7 +45,7 @@ teardown:
}
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -54,18 +54,18 @@ teardown:
- match: { watch_record.status.actions.indexme.ack.state: "ackable" }
- do:
xpack.watcher.ack_watch:
watcher.ack_watch:
watch_id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "acked" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "acked" }
# having a false result will reset the ack state
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -80,12 +80,12 @@ teardown:
- match: { watch_record.status.actions.indexme.ack.state: "awaits_successful_execution" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "awaits_successful_execution" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -97,7 +97,7 @@ teardown:
- match: { watch_record.status.actions.indexme.ack.state: "ackable" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "ackable" }

View File

@ -7,7 +7,7 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
@ -15,7 +15,7 @@ teardown:
"Ensure that ack status is reset after unmet action condition":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -45,7 +45,7 @@ teardown:
}
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -54,18 +54,18 @@ teardown:
- match: { watch_record.status.actions.indexme.ack.state: "ackable" }
- do:
xpack.watcher.ack_watch:
watcher.ack_watch:
watch_id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "acked" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "acked" }
# having a false result will reset the ack state
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -80,12 +80,12 @@ teardown:
- match: { watch_record.status.actions.indexme.ack.state: "awaits_successful_execution" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "awaits_successful_execution" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -97,7 +97,7 @@ teardown:
- match: { watch_record.status.actions.indexme.ack.state: "ackable" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { "status.actions.indexme.ack.state" : "ackable" }

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -34,7 +34,7 @@
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
@ -42,7 +42,7 @@
- match: { status.state.active: true }
- do:
xpack.watcher.deactivate_watch:
watcher.deactivate_watch:
watch_id: "my_watch"
- match: { status.state.active : false }
@ -56,14 +56,14 @@
- match: { hits.hits.0._source.status.state.active: false }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
- match: { status.state.active: false }
- do:
xpack.watcher.activate_watch:
watcher.activate_watch:
watch_id: "my_watch"
- match: { status.state.active : true }
@ -77,7 +77,7 @@
- match: { hits.hits.0._source.status.state.active: true }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
@ -85,7 +85,7 @@
- match: { status.state.active: true }
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
- match: { found: true }
@ -97,11 +97,11 @@
wait_for_status: yellow
- do:
xpack.watcher.activate_watch:
watcher.activate_watch:
watch_id: "non-existent-watch"
catch: missing
- do:
xpack.watcher.deactivate_watch:
watcher.deactivate_watch:
watch_id: "non-existent-watch"
catch: missing

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
---
"Test delete watch api":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -47,7 +47,7 @@ teardown:
- match: { created: true }
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
- match: { found: true }
@ -61,6 +61,6 @@ teardown:
---
"Non existent watch returns 404":
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "non-existent-watch"
catch: missing

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "test_watch"
ignore: 404
---
"Test execute watch api with configured trigger data timestamps":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body: >
{
@ -42,7 +42,7 @@ teardown:
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{
@ -67,7 +67,7 @@ teardown:
"Test execute watch API with user supplied watch":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {
@ -104,7 +104,7 @@ teardown:
"Execute unknown watch results in 404":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "non-existent-watch"
catch: missing
@ -112,7 +112,7 @@ teardown:
"Test execute watch with alternative input":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body: >
{
@ -138,7 +138,7 @@ teardown:
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{

View File

@ -17,7 +17,7 @@ setup:
}
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {
@ -87,7 +87,7 @@ setup:
}
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {
@ -146,7 +146,7 @@ setup:
index: my_test_index
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "test_watch"
ignore: 404
---
"Test execute watch api works with throttling":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body: >
{
@ -41,7 +41,7 @@ teardown:
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{
@ -60,7 +60,7 @@ teardown:
- match: { watch_record.status.state.active: true }
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body: >
{
@ -87,7 +87,7 @@ teardown:
- match: { _id: "test_watch" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{
@ -103,7 +103,7 @@ teardown:
- match: { watch_record.status.execution_state: "executed" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "test_watch"
ignore: 404
---
"Test execute watch api can ignore conditions":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body: >
{
@ -41,7 +41,7 @@ teardown:
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "test_watch"
ignore: 404
---
"Test execute watch api supports action modes":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body: >
{
@ -38,7 +38,7 @@ teardown:
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{
@ -55,7 +55,7 @@ teardown:
- match: { watch_record.result.actions.0.status: "simulated" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
body: >
{

View File

@ -17,7 +17,7 @@ setup:
- set: { nodes.$master.http.publish_address: http_host }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {

View File

@ -2,7 +2,7 @@
"Test execute watch api returns proper error message with watch directly in the body":
- do:
catch: /please wrap watch including field \[trigger\] inside a \"watch\" field/
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger": {
@ -11,7 +11,7 @@
}
- do:
catch: /please wrap watch including field \[input\] inside a \"watch\" field/
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"input": {
@ -22,7 +22,7 @@
}
- do:
catch: /please wrap watch including field \[condition\] inside a \"watch\" field/
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"condition": {
@ -31,7 +31,7 @@
}
- do:
catch: /please wrap watch including field \[actions\] inside a \"watch\" field/
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"actions": {

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
---
"Test get watch api":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -54,7 +54,7 @@ teardown:
- match: { hits.total: 1 }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }

View File

@ -6,7 +6,7 @@
# ensure index exists by creating a different watch
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "other"
body: >
{
@ -38,7 +38,7 @@
- do:
catch: missing
xpack.watcher.get_watch:
watcher.get_watch:
id: "missing_watch"
- match: { found : false}
- match: { _id: "missing_watch" }
@ -56,7 +56,7 @@
- do:
catch: missing
xpack.watcher.get_watch:
watcher.get_watch:
id: "missing_watch"
- match: { found : false}
- match: { _id: "missing_watch" }

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -45,7 +45,7 @@
}
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -44,7 +44,7 @@
- do:
catch: bad_request
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
- match: { error.root_cause.0.type: "action_request_validation_exception" }
- match: { error.root_cause.0.reason: "Validation Failed: 1: request body is missing;" }

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch1"
ignore: 404
---
"Test put watch api with watch level throttle":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch1"
body: >
{
@ -47,7 +47,7 @@ teardown:
- match: { _id: "my_watch1" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch1"
- match: { found : true}
- match: { _id: "my_watch1" }

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch1"
ignore: 404
---
"Test put watch api with action level throttle period":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch1"
body: >
{
@ -47,7 +47,7 @@ teardown:
- match: { _id: "my_watch1" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch1"
- match: { found : true}
- match: { _id: "my_watch1" }

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
---
"Test put inactive watch":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
active: false
body: >
@ -47,7 +47,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true }

View File

@ -6,7 +6,7 @@
- do:
catch: /Configured URL is empty/
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -45,7 +45,7 @@
- do:
catch: /Malformed URL/
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch1"
ignore: 404
---
"Test put watch api with action level condition":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch1"
body: >
{
@ -51,7 +51,7 @@ teardown:
- match: { _id: "my_watch1" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch1"
- match: { found : true }
- match: { _id: "my_watch1" }

View File

@ -7,14 +7,14 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
---
"Test put watch api with index action using doc_id":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -45,7 +45,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true }
- match: { _id: "my_watch" }
@ -53,7 +53,7 @@ teardown:
- match: { watch.actions.test_index.index.doc_id: "test_id1" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.state: "executed" }
- match: { watch_record.status.execution_state: "executed" }
@ -62,7 +62,7 @@ teardown:
---
"Test put watch api with index action using _id field":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -93,7 +93,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true }
- match: { _id: "my_watch" }
@ -101,7 +101,7 @@ teardown:
- match: { watch.input.simple.value: 20 }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.state: "executed" }
- match: { watch_record.status.execution_state: "executed" }
@ -110,7 +110,7 @@ teardown:
---
"Test put watch api with bulk index action using _id field":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -149,7 +149,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true }
- match: { _id: "my_watch" }
@ -159,7 +159,7 @@ teardown:
- match: { watch.input.simple._doc.1.value: 40 }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.state: "executed" }
- match: { watch_record.status.execution_state: "executed" }
@ -169,7 +169,7 @@ teardown:
---
"Test put watch api with bulk index action using _id field in one document":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -207,7 +207,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true }
- match: { _id: "my_watch" }
@ -216,7 +216,7 @@ teardown:
- match: { watch.input.simple._doc.1.value: 60 }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.state: "executed" }
- match: { watch_record.status.execution_state: "executed" }

View File

@ -8,7 +8,7 @@ setup:
"Test getting a watch does not contain the original password":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_with_password"
body: >
{
@ -40,7 +40,7 @@ setup:
}
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "watch_with_password"
- match: { _id: "watch_with_password" }
- match: { watch.input.http.request.auth.basic.password: "::es_redacted::" }
@ -50,7 +50,7 @@ setup:
# version 1
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_without_version_test"
body: >
{
@ -83,7 +83,7 @@ setup:
- do:
catch: bad_request
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_without_version_test"
body: >
{
@ -123,7 +123,7 @@ setup:
# version 1
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_with_seq_no"
body: >
{
@ -161,7 +161,7 @@ setup:
# as if two users in the watch UI tried to update the same watch
- do:
catch: conflict
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_with_seq_no"
if_seq_no: 123034
if_primary_term: $primaryTerm
@ -196,7 +196,7 @@ setup:
- do:
catch: conflict
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_with_seq_no"
if_seq_no: $seqNo
if_primary_term: 234242423
@ -230,7 +230,7 @@ setup:
}
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "watch_with_seq_no"
if_seq_no: $seqNo
if_primary_term: $primaryTerm

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -32,14 +32,14 @@
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { watch.input.simple.foo: "bar" }
# change the simple input fields, then ensure the old
# field does not exist on get
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -66,7 +66,7 @@
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { watch.input.simple.spam: "eggs" }
- is_false: watch.input.simple.foo

View File

@ -18,7 +18,7 @@ setup:
"Test search input includes hits by default":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {
@ -61,7 +61,7 @@ setup:
"Test search transform includes hits by default":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {

View File

@ -4,5 +4,5 @@
cluster.health:
wait_for_status: yellow
- do: {xpack.watcher.start: {}}
- do: {watcher.start: {}}
- match: { acknowledged: true }

View File

@ -1,13 +1,13 @@
---
"Test watcher stats output":
- do: {xpack.watcher.stats: {}}
- do: {watcher.stats: {}}
- match: { "manually_stopped": false }
- match: { "stats.0.watcher_state": "started" }
---
"Test watcher stats supports emit_stacktraces parameter":
- do:
xpack.watcher.stats:
watcher.stats:
metric: "all"
emit_stacktraces: "true"
- match: { "manually_stopped": false }
@ -20,7 +20,7 @@
reason: metrics were fixed in 7.0.0
- do:
xpack.watcher.stats:
watcher.stats:
metric: "current_watches"
- is_false: stats.0.queued_watches
@ -33,7 +33,7 @@
reason: metrics were fixed in 7.0.0
- do:
xpack.watcher.stats:
watcher.stats:
metric: "queued_watches"
- is_false: stats.0.current_watches
@ -50,7 +50,7 @@
warnings:
- 'The pending_watches parameter is deprecated, use queued_watches instead'
xpack.watcher.stats:
watcher.stats:
metric: "pending_watches"
- is_false: stats.0.current_watches
@ -59,7 +59,7 @@
---
"Test watcher stats all watches":
- do:
xpack.watcher.stats:
watcher.stats:
metric: "_all"
- is_true: stats.0.current_watches

View File

@ -4,8 +4,8 @@
cluster.health:
wait_for_status: yellow
- do: {xpack.watcher.stop: {}}
- do: {watcher.stop: {}}
- match: { acknowledged: true }
- do: {xpack.watcher.start: {}}
- do: {watcher.start: {}}
- match: { acknowledged: true }

View File

@ -2,7 +2,7 @@
"Test watcher usage stats output":
- do:
catch: missing
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "usage_stats_watch"
- do: {xpack.usage: {}}
@ -10,7 +10,7 @@
- set: { "watcher.count.total": watch_count_total }
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "usage_stats_watch"
body: >
{

View File

@ -7,7 +7,7 @@
wait_for_status: yellow
- do:
xpack.license.delete: {}
license.delete: {}
- match: { acknowledged: true }
# we don't have a license now
@ -30,7 +30,7 @@
# - is_false: features.monitoring.available TODO fix once licensing is fixed
- do:
xpack.license.post:
license.post:
body: >
{
"license": {
@ -49,7 +49,7 @@
- match: { license_status: "valid" }
- do:
xpack.license.get: {}
license.get: {}
- match: { license.uid: "893361dc-9749-4997-93cb-802e3dofh7aa" }
- match: { license.type: "internal" }
- match: { license.status: "active" }

View File

@ -3,7 +3,7 @@
# no need to put watch, exists already
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -11,7 +11,7 @@
# execute watch
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -41,12 +41,12 @@
# deactivate watch, check with GET API as well
- do:
xpack.watcher.deactivate_watch:
watcher.deactivate_watch:
watch_id: "my_watch"
- match: { status.state.active : false }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -55,12 +55,12 @@
# activate watch again, check with GET API as well
- do:
xpack.watcher.activate_watch:
watcher.activate_watch:
watch_id: "my_watch"
- match: { status.state.active : true }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -70,6 +70,6 @@
---
"Test watcher stats output":
- do:
xpack.watcher.stats: {}
watcher.stats: {}
- match: { "manually_stopped": false }
- match: { "stats.0.watcher_state": "started" }

View File

@ -2,7 +2,7 @@
"CRUD watch APIs":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -23,7 +23,7 @@
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -31,7 +31,7 @@
# execute watch
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -61,12 +61,12 @@
# deactivate watch, check with GET API as well
- do:
xpack.watcher.deactivate_watch:
watcher.deactivate_watch:
watch_id: "my_watch"
- match: { status.state.active : false }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -75,12 +75,12 @@
# activate watch again, check with GET API as well
- do:
xpack.watcher.activate_watch:
watcher.activate_watch:
watch_id: "my_watch"
- match: { status.state.active : true }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -90,6 +90,6 @@
---
"Test watcher stats output":
- do:
xpack.watcher.stats: {}
watcher.stats: {}
- match: { "manually_stopped": false }
- match: { "stats.0.watcher_state": "started" }

View File

@ -3,7 +3,7 @@
# no need to put watch, exists already
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -11,7 +11,7 @@
# execute watch
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
body: >
{
@ -41,12 +41,12 @@
# deactivate watch, check with GET API as well
- do:
xpack.watcher.deactivate_watch:
watcher.deactivate_watch:
watch_id: "my_watch"
- match: { status.state.active : false }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -55,12 +55,12 @@
# activate watch again, check with GET API as well
- do:
xpack.watcher.activate_watch:
watcher.activate_watch:
watch_id: "my_watch"
- match: { status.state.active : true }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { found : true}
- match: { _id: "my_watch" }
@ -69,6 +69,6 @@
---
"Test watcher stats output":
- do:
xpack.watcher.stats: {}
watcher.stats: {}
- match: { "manually_stopped": false }
- match: { "stats.0.watcher_state": "started" }

View File

@ -53,13 +53,13 @@ public class SmokeTestWatcherWithSecurityClientYamlTestSuiteIT extends ESClientY
assertBusy(() -> {
ClientYamlTestResponse response =
getAdminExecutionContext().callApi("xpack.watcher.stats", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stats", emptyMap(), emptyList(), emptyMap());
String state = (String) response.evaluate("stats.0.watcher_state");
switch (state) {
case "stopped":
ClientYamlTestResponse startResponse =
getAdminExecutionContext().callApi("xpack.watcher.start", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.start", emptyMap(), emptyList(), emptyMap());
boolean isAcknowledged = (boolean) startResponse.evaluate("acknowledged");
assertThat(isAcknowledged, is(true));
throw new AssertionError("waiting until stopped state reached started state");
@ -88,7 +88,7 @@ public class SmokeTestWatcherWithSecurityClientYamlTestSuiteIT extends ESClientY
public void stopWatcher() throws Exception {
assertBusy(() -> {
ClientYamlTestResponse response =
getAdminExecutionContext().callApi("xpack.watcher.stats", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stats", emptyMap(), emptyList(), emptyMap());
String state = (String) response.evaluate("stats.0.watcher_state");
switch (state) {
@ -101,7 +101,7 @@ public class SmokeTestWatcherWithSecurityClientYamlTestSuiteIT extends ESClientY
throw new AssertionError("waiting until starting state reached started state to stop");
case "started":
ClientYamlTestResponse stopResponse =
getAdminExecutionContext().callApi("xpack.watcher.stop", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stop", emptyMap(), emptyList(), emptyMap());
boolean isAcknowledged = (boolean) stopResponse.evaluate("acknowledged");
assertThat(isAcknowledged, is(true));
throw new AssertionError("waiting until started state reached stopped state");

View File

@ -5,10 +5,10 @@
- do:
headers: { es-security-runas-user: powerless_user }
catch: forbidden
xpack.watcher.stats: {}
watcher.stats: {}
# there seems to be a bug in the yaml parser we use, where a single element list
# has the END_LIST token skipped...so here we just rerun the same request without
# the impersonation to show it works
- do:
xpack.watcher.stats: {}
watcher.stats: {}
- match: { stats.0.watcher_state: started }

View File

@ -18,7 +18,7 @@ setup:
---
teardown:
- do:
xpack.watcher.delete_watch:
watcher.delete_watch:
id: "my_watch"
ignore: 404
@ -27,7 +27,7 @@ teardown:
- skip:
features: headers
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -63,13 +63,13 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { _id: "my_watch" }
- is_false: watch.status.headers
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
- match: { watch_record.state: "executed" }
@ -83,7 +83,7 @@ teardown:
- skip:
features: headers
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -119,14 +119,14 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { _id: "my_watch" }
- is_false: watch.status.headers
- do:
headers: { es-security-runas-user: x_pack_rest_user }
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
- match: { watch_record.state: "executed" }
@ -140,7 +140,7 @@ teardown:
- do:
# by impersonating this request as powerless user we cannot query the my_test_index
# headers: { es-security-runas-user: powerless_user }
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -176,13 +176,13 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { _id: "my_watch" }
- is_false: watch.status.headers
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
# because we are not allowed to read the index, there wont be any data
@ -193,7 +193,7 @@ teardown:
---
"Test watch search transform is run as user who added the watch":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -227,7 +227,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
@ -242,7 +242,7 @@ teardown:
---
"Test watch search transform does not work without permissions":
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -277,7 +277,7 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
@ -294,7 +294,7 @@ teardown:
- skip:
features: headers
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -318,13 +318,13 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { _id: "my_watch" }
- is_false: watch.status.headers
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
- match: { watch_record.state: "executed" }
@ -343,7 +343,7 @@ teardown:
- skip:
features: headers
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_watch"
body: >
{
@ -367,13 +367,13 @@ teardown:
- match: { _id: "my_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_watch"
- match: { _id: "my_watch" }
- is_false: watch.status.headers
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_watch"
- match: { watch_record.watch_id: "my_watch" }
- match: { watch_record.state: "executed" }

View File

@ -35,13 +35,13 @@ public class WatcherRestIT extends ESClientYamlSuiteTestCase {
public void startWatcher() throws Exception {
assertBusy(() -> {
ClientYamlTestResponse response =
getAdminExecutionContext().callApi("xpack.watcher.stats", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stats", emptyMap(), emptyList(), emptyMap());
String state = (String) response.evaluate("stats.0.watcher_state");
switch (state) {
case "stopped":
ClientYamlTestResponse startResponse =
getAdminExecutionContext().callApi("xpack.watcher.start", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.start", emptyMap(), emptyList(), emptyMap());
boolean isAcknowledged = (boolean) startResponse.evaluate("acknowledged");
assertThat(isAcknowledged, is(true));
throw new AssertionError("waiting until stopped state reached started state");
@ -70,7 +70,7 @@ public class WatcherRestIT extends ESClientYamlSuiteTestCase {
public void stopWatcher() throws Exception {
assertBusy(() -> {
ClientYamlTestResponse response =
getAdminExecutionContext().callApi("xpack.watcher.stats", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stats", emptyMap(), emptyList(), emptyMap());
String state = (String) response.evaluate("stats.0.watcher_state");
switch (state) {
@ -83,7 +83,7 @@ public class WatcherRestIT extends ESClientYamlSuiteTestCase {
throw new AssertionError("waiting until starting state reached started state to stop");
case "started":
ClientYamlTestResponse stopResponse =
getAdminExecutionContext().callApi("xpack.watcher.stop", emptyMap(), emptyList(), emptyMap());
getAdminExecutionContext().callApi("watcher.stop", emptyMap(), emptyList(), emptyMap());
boolean isAcknowledged = (boolean) stopResponse.evaluate("acknowledged");
assertThat(isAcknowledged, is(true));
throw new AssertionError("waiting until started state reached stopped state");

View File

@ -26,7 +26,7 @@
- set: { docs.0.doc._source.port: port }
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body:
trigger:
@ -53,7 +53,7 @@
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: test_watch
body:
record_execution: true

View File

@ -5,7 +5,7 @@
wait_for_status: yellow
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch": {

View File

@ -36,7 +36,7 @@
indices.refresh: {}
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {

View File

@ -3,7 +3,7 @@ setup:
- do:
cluster.health:
wait_for_status: yellow
- do: {xpack.watcher.stats:{}}
- do: {watcher.stats:{}}
- do:
index:
index: idx
@ -51,7 +51,7 @@ setup:
---
"Test search input mustache integration (using request body)":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {
@ -126,7 +126,7 @@ setup:
- match: { acknowledged: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {
@ -172,7 +172,7 @@ setup:
version: " - 6.99.99"
reason: "rest_total_hits_as_int support was added in 7.0"
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {
@ -250,7 +250,7 @@ setup:
- match: { acknowledged: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {

View File

@ -3,7 +3,7 @@ setup:
- do:
cluster.health:
wait_for_status: yellow
- do: {xpack.watcher.stats:{}}
- do: {watcher.stats:{}}
- do:
index:
index: idx
@ -51,7 +51,7 @@ setup:
---
"Test search transform mustache integration (using request body)":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {
@ -110,7 +110,7 @@ setup:
---
"Test search transform mustache integration (using request template)":
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {

View File

@ -12,7 +12,7 @@
refresh: true
body: { foo: bar }
- do: {xpack.watcher.stats:{}}
- do: {watcher.stats:{}}
- match: { "stats.0.watcher_state": "started" }
- match: { "stats.0.watch_count": 0 }
@ -38,7 +38,7 @@
- set: { docs.0.doc._source.port: port }
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "test_watch"
body:
metadata:
@ -73,7 +73,7 @@
- match: { created: true }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "test_watch"
- do:

View File

@ -5,7 +5,7 @@
wait_for_status: green
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_exe_watch"
body: >
{
@ -80,7 +80,7 @@
- match: { _id: "my_exe_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_exe_watch"
- match: { _id: "my_exe_watch" }
@ -88,7 +88,7 @@
- match: { watch.input.chain.inputs.1.second.transform.script.source: "return [ 'hits' : [ 'total' : ctx.payload.first.hits.total ]]" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_exe_watch"
body: >
{
@ -132,7 +132,7 @@
wait_for_status: green
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_exe_watch"
body: >
{
@ -207,7 +207,7 @@
- match: { _id: "my_exe_watch" }
- do:
xpack.watcher.get_watch:
watcher.get_watch:
id: "my_exe_watch"
- match: { _id: "my_exe_watch" }
@ -215,7 +215,7 @@
- match: { watch.input.chain.inputs.1.second.transform.script.source: "return [ 'hits' : [ 'total' : ctx.payload.first.hits.total ]]" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_exe_watch"
body: >
{

View File

@ -5,7 +5,7 @@
wait_for_status: green
- do:
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_logging_watch"
body: >
{
@ -34,7 +34,7 @@
- match: { _id: "my_logging_watch" }
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
id: "my_logging_watch"
- match: { "watch_record.watch_id": "my_logging_watch" }

View File

@ -5,7 +5,7 @@
wait_for_status: green
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"trigger_data" : {

View File

@ -6,7 +6,7 @@
- do:
catch: bad_request
xpack.watcher.put_watch:
watcher.put_watch:
id: "my_exe_watch"
body: >
{
@ -42,7 +42,7 @@
wait_for_status: green
- do:
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch" : {
@ -80,7 +80,7 @@
- do:
catch: bad_request
xpack.watcher.execute_watch:
watcher.execute_watch:
body: >
{
"watch": {

Some files were not shown because too many files have changed in this diff Show More