49 lines
1.6 KiB
Python
49 lines
1.6 KiB
Python
# Copyright (c) 2021 Wind River Systems, Inc.
|
|
#
|
|
# The right to copy, distribute, modify, or otherwise make use
|
|
# of this software may be licensed only pursuant to the terms
|
|
# of an applicable Wind River license agreement.
|
|
#
|
|
|
|
import json
|
|
|
|
from oslo_log import log as logging
|
|
|
|
from sysinv.common import constants
|
|
from sysinv.common.rest_api import get_token
|
|
from sysinv.common.rest_api import rest_api_request
|
|
|
|
# well-known dcmanager upgrade completed events
|
|
DC_EVENT_PLATFORM_UPGRADE_COMPLETED = 'platform-upgrade-completed'
|
|
DC_EVENT_K8S_UPGRADE_COMPLETED = 'k8s-upgrade-completed'
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
def notify_dcmanager(events):
|
|
"""Send list of upgrade completion events to dcmanager."""
|
|
try:
|
|
token = get_token(constants.SYSTEM_CONTROLLER_REGION)
|
|
api_url = token.get_service_url("dcmanager", "dcmanager")
|
|
api_cmd_headers = {
|
|
'Content-type': 'application/json',
|
|
'User-Agent': 'sysinv/1.0',
|
|
}
|
|
api_cmd = api_url + '/notifications'
|
|
api_cmd_payload = json.dumps({'events': events})
|
|
rest_api_request(token, "POST", api_cmd, api_cmd_headers,
|
|
api_cmd_payload)
|
|
except Exception:
|
|
LOG.exception("Failed to notify dcmanager of events: %s" % events)
|
|
|
|
|
|
def notify_dcmanager_platform_upgrade_completed():
|
|
"""Send the platform-upgrade-completed event to dcmanager."""
|
|
notify_dcmanager([DC_EVENT_PLATFORM_UPGRADE_COMPLETED])
|
|
|
|
|
|
def notify_dcmanager_kubernetes_upgrade_completed():
|
|
"""Send the k8s-upgrade-completed event to dcmanager."""
|
|
notify_dcmanager([DC_EVENT_K8S_UPGRADE_COMPLETED])
|