Class: Wavefront::Writer::Api
- Defined in:
- lib/wavefront-sdk/writers/api.rb
Overview
Send points direct to Wavefront’s API. This requires an endpoint, a token, and HTTPS egress.
Instance Attribute Summary
Attributes inherited from Core
#calling_class, #conn, #creds, #logger, #opts, #summary
Instance Method Summary collapse
Methods inherited from Core
#chunk_size, #do_write, #hash_to_wf, #initialize, #log_invalid_point, #prefix_points, #respond, #screen_points, #valid_point?, #write
Methods included from Validators
#uuid?, #wf_alert_id?, #wf_alert_severity?, #wf_apitoken_id?, #wf_cloudintegration_id?, #wf_dashboard_id?, #wf_derivedmetric_id?, #wf_distribution?, #wf_distribution_count?, #wf_distribution_interval?, #wf_distribution_values?, #wf_epoch?, #wf_event_id?, #wf_granularity?, #wf_integration_id?, #wf_link_id?, #wf_link_template?, #wf_maintenance_window_id?, #wf_message_id?, #wf_metric_name?, #wf_ms_ts?, #wf_name?, #wf_notificant_id?, #wf_permission?, #wf_point?, #wf_point_tag?, #wf_point_tags?, #wf_proxy_id?, #wf_savedsearch_entity?, #wf_savedsearch_id?, #wf_serviceaccount_id?, #wf_source_id?, #wf_string?, #wf_tag?, #wf_ts?, #wf_user_id?, #wf_usergroup_id?, #wf_value?, #wf_version?, #wf_webhook_id?
Constructor Details
This class inherits a constructor from Wavefront::Writer::Core
Instance Method Details
#api_path ⇒ Object
17 18 19 |
# File 'lib/wavefront-sdk/writers/api.rb', line 17 def api_path '/report' end |
#open ⇒ Object
13 14 15 |
# File 'lib/wavefront-sdk/writers/api.rb', line 13 def open @conn = Wavefront::ApiCaller.new(self, creds, opts) end |
#send_point(body) ⇒ Object
33 34 35 36 37 38 39 40 41 42 |
# File 'lib/wavefront-sdk/writers/api.rb', line 33 def send_point(body) _send_point(body) summary.sent += body.size true rescue StandardError => e summary.unsent += body.size logger.log('WARNING: failed to send point(s).') logger.log(e.to_s, :debug) false end |
#validate_credentials(creds) ⇒ Object
21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/wavefront-sdk/writers/api.rb', line 21 def validate_credentials(creds) unless creds.key?(:endpoint) raise(Wavefront::Exception::CredentialError, 'credentials must contain API endpoint') end return true if creds.key?(:token) raise(Wavefront::Exception::CredentialError, 'credentials must contain API token') end |