Module: Elasticsearch::API::Connector::Actions
- Included in:
- ConnectorClient
- Defined in:
- lib/elasticsearch/api/namespace/connector.rb,
lib/elasticsearch/api/actions/connector/get.rb,
lib/elasticsearch/api/actions/connector/put.rb,
lib/elasticsearch/api/actions/connector/list.rb,
lib/elasticsearch/api/actions/connector/post.rb,
lib/elasticsearch/api/actions/connector/delete.rb,
lib/elasticsearch/api/actions/connector/check_in.rb,
lib/elasticsearch/api/actions/connector/last_sync.rb,
lib/elasticsearch/api/actions/connector/secret_get.rb,
lib/elasticsearch/api/actions/connector/secret_put.rb,
lib/elasticsearch/api/actions/connector/secret_post.rb,
lib/elasticsearch/api/actions/connector/update_name.rb,
lib/elasticsearch/api/actions/connector/sync_job_get.rb,
lib/elasticsearch/api/actions/connector/update_error.rb,
lib/elasticsearch/api/actions/connector/secret_delete.rb,
lib/elasticsearch/api/actions/connector/sync_job_list.rb,
lib/elasticsearch/api/actions/connector/sync_job_post.rb,
lib/elasticsearch/api/actions/connector/update_native.rb,
lib/elasticsearch/api/actions/connector/update_status.rb,
lib/elasticsearch/api/actions/connector/sync_job_claim.rb,
lib/elasticsearch/api/actions/connector/sync_job_error.rb,
lib/elasticsearch/api/actions/connector/sync_job_cancel.rb,
lib/elasticsearch/api/actions/connector/sync_job_delete.rb,
lib/elasticsearch/api/actions/connector/update_features.rb,
lib/elasticsearch/api/actions/connector/update_pipeline.rb,
lib/elasticsearch/api/actions/connector/update_filtering.rb,
lib/elasticsearch/api/actions/connector/sync_job_check_in.rb,
lib/elasticsearch/api/actions/connector/update_api_key_id.rb,
lib/elasticsearch/api/actions/connector/update_index_name.rb,
lib/elasticsearch/api/actions/connector/update_scheduling.rb,
lib/elasticsearch/api/actions/connector/update_service_type.rb,
lib/elasticsearch/api/actions/connector/update_configuration.rb,
lib/elasticsearch/api/actions/connector/sync_job_update_stats.rb,
lib/elasticsearch/api/actions/connector/update_active_filtering.rb,
lib/elasticsearch/api/actions/connector/update_filtering_validation.rb
Instance Method Summary collapse
-
#check_in(arguments = {}) ⇒ Object
Updates the last_seen timestamp in the connector document.
-
#delete(arguments = {}) ⇒ Object
Deletes a connector.
-
#get(arguments = {}) ⇒ Object
Returns the details about a connector.
-
#last_sync(arguments = {}) ⇒ Object
Updates the stats of last sync in the connector document.
-
#list(arguments = {}) ⇒ Object
Lists all connectors.
-
#post(arguments = {}) ⇒ Object
Creates a connector.
-
#put(arguments = {}) ⇒ Object
Creates or updates a connector.
-
#secret_delete(arguments = {}) ⇒ Object
Deletes a connector secret.
-
#secret_get(arguments = {}) ⇒ Object
Retrieves a secret stored by Connectors.
-
#secret_post(arguments = {}) ⇒ Object
Creates a secret for a Connector.
-
#secret_put(arguments = {}) ⇒ Object
Creates or updates a secret for a Connector.
-
#sync_job_cancel(arguments = {}) ⇒ Object
Cancels a connector sync job.
-
#sync_job_check_in(arguments = {}) ⇒ Object
Checks in a connector sync job (refreshes ‘last_seen’).
-
#sync_job_claim(arguments = {}) ⇒ Object
Claims a connector sync job.
-
#sync_job_delete(arguments = {}) ⇒ Object
Deletes a connector sync job.
-
#sync_job_error(arguments = {}) ⇒ Object
Sets an error for a connector sync job.
-
#sync_job_get(arguments = {}) ⇒ Object
Returns the details about a connector sync job.
-
#sync_job_list(arguments = {}) ⇒ Object
Lists all connector sync jobs.
-
#sync_job_post(arguments = {}) ⇒ Object
Creates a connector sync job.
-
#sync_job_update_stats(arguments = {}) ⇒ Object
Updates the stats fields in the connector sync job document.
-
#update_active_filtering(arguments = {}) ⇒ Object
Activates the draft filtering rules if they are in a validated state.
-
#update_api_key_id(arguments = {}) ⇒ Object
Updates the API key id and/or API key secret id fields in the connector document.
-
#update_configuration(arguments = {}) ⇒ Object
Updates the connector configuration.
-
#update_error(arguments = {}) ⇒ Object
Updates the error field in the connector document.
-
#update_features(arguments = {}) ⇒ Object
Updates the connector features in the connector document.
-
#update_filtering(arguments = {}) ⇒ Object
Updates the filtering field in the connector document.
-
#update_filtering_validation(arguments = {}) ⇒ Object
Updates the validation info of the draft filtering rules.
-
#update_index_name(arguments = {}) ⇒ Object
Updates the index name of the connector.
-
#update_name(arguments = {}) ⇒ Object
Updates the name and/or description fields in the connector document.
-
#update_native(arguments = {}) ⇒ Object
Updates the is_native flag of the connector.
-
#update_pipeline(arguments = {}) ⇒ Object
Updates the pipeline field in the connector document.
-
#update_scheduling(arguments = {}) ⇒ Object
Updates the scheduling field in the connector document.
-
#update_service_type(arguments = {}) ⇒ Object
Updates the service type of the connector.
-
#update_status(arguments = {}) ⇒ Object
Updates the status of the connector.
Instance Method Details
#check_in(arguments = {}) ⇒ Object
Updates the last_seen timestamp in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/elasticsearch/api/actions/connector/check_in.rb', line 36 def check_in(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.check_in' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_check_in" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#delete(arguments = {}) ⇒ Object
Deletes a connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
# File 'lib/elasticsearch/api/actions/connector/delete.rb', line 37 def delete(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.delete' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_DELETE path = "_connector/#{Utils.__listify(_connector_id)}" params = Utils.process_params(arguments) Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#get(arguments = {}) ⇒ Object
Returns the details about a connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/elasticsearch/api/actions/connector/get.rb', line 36 def get(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.get' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_GET path = "_connector/#{Utils.__listify(_connector_id)}" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#last_sync(arguments = {}) ⇒ Object
Updates the stats of last sync in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/last_sync.rb', line 37 def last_sync(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.last_sync' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_last_sync" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#list(arguments = {}) ⇒ Object
Lists all connectors. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/elasticsearch/api/actions/connector/list.rb', line 41 def list(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.list' } arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil method = Elasticsearch::API::HTTP_GET path = '_connector' params = Utils.process_params(arguments) Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#post(arguments = {}) ⇒ Object
Creates a connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/elasticsearch/api/actions/connector/post.rb', line 36 def post(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.post' } arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) method = Elasticsearch::API::HTTP_POST path = '_connector' params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#put(arguments = {}) ⇒ Object
Creates or updates a connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/elasticsearch/api/actions/connector/put.rb', line 37 def put(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.put' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = if _connector_id "_connector/#{Utils.__listify(_connector_id)}" else '_connector' end params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#secret_delete(arguments = {}) ⇒ Object
Deletes a connector secret. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/elasticsearch/api/actions/connector/secret_delete.rb', line 36 def secret_delete(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.secret_delete' } defined_params = [:id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'id' missing" unless arguments[:id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _id = arguments.delete(:id) method = Elasticsearch::API::HTTP_DELETE path = "_connector/_secret/#{Utils.__listify(_id)}" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#secret_get(arguments = {}) ⇒ Object
Retrieves a secret stored by Connectors. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/elasticsearch/api/actions/connector/secret_get.rb', line 36 def secret_get(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.secret_get' } defined_params = [:id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'id' missing" unless arguments[:id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _id = arguments.delete(:id) method = Elasticsearch::API::HTTP_GET path = "_connector/_secret/#{Utils.__listify(_id)}" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#secret_post(arguments = {}) ⇒ Object
Creates a secret for a Connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/elasticsearch/api/actions/connector/secret_post.rb', line 36 def secret_post(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.secret_post' } raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) method = Elasticsearch::API::HTTP_POST path = '_connector/_secret' params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#secret_put(arguments = {}) ⇒ Object
Creates or updates a secret for a Connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/secret_put.rb', line 37 def secret_put(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.secret_put' } defined_params = [:id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'id' missing" unless arguments[:id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _id = arguments.delete(:id) method = Elasticsearch::API::HTTP_PUT path = "_connector/_secret/#{Utils.__listify(_id)}" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_cancel(arguments = {}) ⇒ Object
Cancels a connector sync job. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_cancel.rb', line 36 def sync_job_cancel(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_cancel' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}/_cancel" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_check_in(arguments = {}) ⇒ Object
Checks in a connector sync job (refreshes ‘last_seen’). This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_check_in.rb', line 36 def sync_job_check_in(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_check_in' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}/_check_in" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_claim(arguments = {}) ⇒ Object
Claims a connector sync job. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_claim.rb', line 37 def sync_job_claim(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_claim' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}/_claim" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_delete(arguments = {}) ⇒ Object
Deletes a connector sync job. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_delete.rb', line 36 def sync_job_delete(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_delete' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_DELETE path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_error(arguments = {}) ⇒ Object
Sets an error for a connector sync job. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_error.rb', line 37 def sync_job_error(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_error' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}/_error" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_get(arguments = {}) ⇒ Object
Returns the details about a connector sync job. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_get.rb', line 36 def sync_job_get(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_get' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_GET path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_list(arguments = {}) ⇒ Object
Lists all connector sync jobs. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_list.rb', line 40 def sync_job_list(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_list' } arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil method = Elasticsearch::API::HTTP_GET path = '_connector/_sync_job' params = Utils.process_params(arguments) Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_post(arguments = {}) ⇒ Object
Creates a connector sync job. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_post.rb', line 36 def sync_job_post(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_post' } raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) method = Elasticsearch::API::HTTP_POST path = '_connector/_sync_job' params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#sync_job_update_stats(arguments = {}) ⇒ Object
Updates the stats fields in the connector sync job document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
# File 'lib/elasticsearch/api/actions/connector/sync_job_update_stats.rb', line 37 def sync_job_update_stats(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.sync_job_update_stats' } defined_params = [:connector_sync_job_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] unless arguments[:connector_sync_job_id] raise ArgumentError, "Required argument 'connector_sync_job_id' missing" end arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_sync_job_id = arguments.delete(:connector_sync_job_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/_sync_job/#{Utils.__listify(_connector_sync_job_id)}/_stats" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_active_filtering(arguments = {}) ⇒ Object
Activates the draft filtering rules if they are in a validated state. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
# File 'lib/elasticsearch/api/actions/connector/update_active_filtering.rb', line 36 def update_active_filtering(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_active_filtering' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = nil _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_filtering/_activate" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_api_key_id(arguments = {}) ⇒ Object
Updates the API key id and/or API key secret id fields in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_api_key_id.rb', line 37 def update_api_key_id(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_api_key_id' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_api_key_id" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_configuration(arguments = {}) ⇒ Object
Updates the connector configuration. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_configuration.rb', line 37 def update_configuration(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_configuration' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_configuration" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_error(arguments = {}) ⇒ Object
Updates the error field in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_error.rb', line 37 def update_error(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_error' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_error" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_features(arguments = {}) ⇒ Object
Updates the connector features in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_features.rb', line 37 def update_features(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_features' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_features" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_filtering(arguments = {}) ⇒ Object
Updates the filtering field in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_filtering.rb', line 37 def update_filtering(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_filtering' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_filtering" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_filtering_validation(arguments = {}) ⇒ Object
Updates the validation info of the draft filtering rules. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_filtering_validation.rb', line 37 def update_filtering_validation(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_filtering_validation' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_filtering/_validation" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_index_name(arguments = {}) ⇒ Object
Updates the index name of the connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_index_name.rb', line 37 def update_index_name(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_index_name' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_index_name" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_name(arguments = {}) ⇒ Object
Updates the name and/or description fields in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_name.rb', line 37 def update_name(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_name' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_name" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_native(arguments = {}) ⇒ Object
Updates the is_native flag of the connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_native.rb', line 37 def update_native(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_native' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_native" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_pipeline(arguments = {}) ⇒ Object
Updates the pipeline field in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_pipeline.rb', line 37 def update_pipeline(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_pipeline' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_pipeline" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_scheduling(arguments = {}) ⇒ Object
Updates the scheduling field in the connector document. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_scheduling.rb', line 37 def update_scheduling(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_scheduling' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_scheduling" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_service_type(arguments = {}) ⇒ Object
Updates the service type of the connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_service_type.rb', line 37 def update_service_type(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_service_type' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_service_type" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |
#update_status(arguments = {}) ⇒ Object
Updates the status of the connector. This functionality is Experimental and may be changed or removed completely in a future release. Elastic will take a best effort approach to fix any issues, but experimental features are not subject to the support SLA of official GA features.
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/elasticsearch/api/actions/connector/update_status.rb', line 37 def update_status(arguments = {}) request_opts = { endpoint: arguments[:endpoint] || 'connector.update_status' } defined_params = [:connector_id].each_with_object({}) do |variable, set_variables| set_variables[variable] = arguments[variable] if arguments.key?(variable) end request_opts[:defined_params] = defined_params unless defined_params.empty? raise ArgumentError, "Required argument 'body' missing" unless arguments[:body] raise ArgumentError, "Required argument 'connector_id' missing" unless arguments[:connector_id] arguments = arguments.clone headers = arguments.delete(:headers) || {} body = arguments.delete(:body) _connector_id = arguments.delete(:connector_id) method = Elasticsearch::API::HTTP_PUT path = "_connector/#{Utils.__listify(_connector_id)}/_status" params = {} Elasticsearch::API::Response.new( perform_request(method, path, params, body, headers, request_opts) ) end |