# Licensed to Elasticsearch B.V. under one or more contributor # license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright # ownership. Elasticsearch B.V. licenses this file to you under # the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, # software distributed under the License is distributed on an # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. from .utils import NamespacedClient, query_params class LicenseClient(NamespacedClient): @query_params() def delete(self, params=None, headers=None): """ Deletes licensing information for the cluster ``_ """ return self.transport.perform_request( "DELETE", "/_license", params=params, headers=headers ) @query_params("accept_enterprise", "local") def get(self, params=None, headers=None): """ Retrieves licensing information for the cluster ``_ :arg accept_enterprise: If the active license is an enterprise license, return type as 'enterprise' (default: false) :arg local: Return local information, do not retrieve the state from master node (default: false) """ return self.transport.perform_request( "GET", "/_license", params=params, headers=headers ) @query_params() def get_basic_status(self, params=None, headers=None): """ Retrieves information about the status of the basic license. ``_ """ return self.transport.perform_request( "GET", "/_license/basic_status", params=params, headers=headers ) @query_params() def get_trial_status(self, params=None, headers=None): """ Retrieves information about the status of the trial license. ``_ """ return self.transport.perform_request( "GET", "/_license/trial_status", params=params, headers=headers ) @query_params("acknowledge") def post(self, body=None, params=None, headers=None): """ Updates the license for the cluster. ``_ :arg body: licenses to be installed :arg acknowledge: whether the user has acknowledged acknowledge messages (default: false) """ return self.transport.perform_request( "PUT", "/_license", params=params, headers=headers, body=body ) @query_params("acknowledge") def post_start_basic(self, params=None, headers=None): """ Starts an indefinite basic license. ``_ :arg acknowledge: whether the user has acknowledged acknowledge messages (default: false) """ return self.transport.perform_request( "POST", "/_license/start_basic", params=params, headers=headers ) @query_params("acknowledge", "doc_type") def post_start_trial(self, params=None, headers=None): """ starts a limited time trial license. ``_ :arg acknowledge: whether the user has acknowledged acknowledge messages (default: false) :arg doc_type: The type of trial license to generate (default: "trial") """ # type is a reserved word so it cannot be used, use doc_type instead if "doc_type" in params: params["type"] = params.pop("doc_type") return self.transport.perform_request( "POST", "/_license/start_trial", params=params, headers=headers )