Files
opensearch-pyd/test_opensearchpy/test_client/test_plugins/test_alerting.py
T
Daniel (dB.) DoubrovkineandGitHub dcb79cc322 Merge .pyi type stubs inline (#563)
* Merged types into .py code.

Signed-off-by: dblock <[email protected]>

* Fix: nox -rs generate.

Signed-off-by: dblock <[email protected]>

* Updated CHANGELOG.

Signed-off-by: dblock <[email protected]>

* Use lowest common python version for lint.

Signed-off-by: dblock <[email protected]>

* Fix: don't typeshed.

Signed-off-by: dblock <[email protected]>

* Removed unneeded comment.

Signed-off-by: dblock <[email protected]>

* Simplify OPENSEARCH_URL.

Signed-off-by: dblock <[email protected]>

* Fix: positional ignore_status used as chunk_size.

Signed-off-by: dblock <[email protected]>

* Fix: parse version string.

Signed-off-by: dblock <[email protected]>

* Remove future annotations for Python 3.6.

Signed-off-by: dblock <[email protected]>

* Fix: types in documentation.

Signed-off-by: dblock <[email protected]>

* Improve CHANGELOG text.

Signed-off-by: dblock <[email protected]>

* Re-added missing separator.

Signed-off-by: dblock <[email protected]>

* Remove duplicate licenses.

Signed-off-by: dblock <[email protected]>

* Get rid of Optional[Any].

Signed-off-by: dblock <[email protected]>

* Fix docs with AsyncOpenSearch.

Signed-off-by: dblock <[email protected]>

* Fix: undo comment.

Signed-off-by: dblock <[email protected]>

---------

Signed-off-by: dblock <[email protected]>
2023-11-06 10:08:19 -08:00

79 lines
2.9 KiB
Python

# -*- coding: utf-8 -*-
# SPDX-License-Identifier: Apache-2.0
#
# The OpenSearch Contributors require contributions made to
# this file be licensed under the Apache-2.0 license or a
# compatible open source license.
#
# Modifications Copyright OpenSearch Contributors. See
# GitHub history for details.
from test_opensearchpy.test_cases import OpenSearchTestCase
class TestAlerting(OpenSearchTestCase):
def test_create_monitor(self) -> None:
# Test Post Method
self.client.alerting.create_monitor({})
self.assert_url_called("POST", "/_plugins/_alerting/monitors")
def test_run_monitor(self) -> None:
self.client.alerting.run_monitor("...")
self.assert_url_called("POST", "/_plugins/_alerting/monitors/.../_execute")
def test_get_monitor(self) -> None:
# Test Get Method
self.client.alerting.get_monitor("...")
self.assert_url_called("GET", "/_plugins/_alerting/monitors/...")
def test_search_monitor(self) -> None:
# Test Search Method
self.client.alerting.search_monitor({})
self.assert_url_called("GET", "/_plugins/_alerting/monitors/_search")
def test_update_monitor(self) -> None:
# Test Update Method
self.client.alerting.update_monitor("...")
self.assert_url_called("PUT", "/_plugins/_alerting/monitors/...")
def test_delete_monitor(self) -> None:
# Test Delete Method
self.client.alerting.delete_monitor("...")
self.assert_url_called("DELETE", "/_plugins/_alerting/monitors/...")
def test_create_destination(self) -> None:
# Test Post Method
self.client.alerting.create_destination({})
self.assert_url_called("POST", "/_plugins/_alerting/destinations")
def test_get_destination(self) -> None:
# Test Get Method
# Get a specific destination
self.client.alerting.get_destination("...")
self.assert_url_called("GET", "/_plugins/_alerting/destinations/...")
# Get all destinations
self.client.alerting.get_destination()
self.assert_url_called("GET", "/_plugins/_alerting/destinations")
def test_update_destination(self) -> None:
# Test Update Method
self.client.alerting.update_destination("...")
self.assert_url_called("PUT", "/_plugins/_alerting/destinations/...")
def test_delete_destination(self) -> None:
# Test Delete Method
self.client.alerting.delete_destination("...")
self.assert_url_called("DELETE", "/_plugins/_alerting/destinations/...")
def test_get_alerts(self) -> None:
self.client.alerting.get_alerts()
self.assert_url_called("GET", "/_plugins/_alerting/monitors/alerts")
def test_acknowledge_alerts(self) -> None:
self.client.alerting.acknowledge_alert("...")
self.assert_url_called(
"POST", "/_plugins/_alerting/monitors/.../_acknowledge/alerts"
)