class SendElasticSearch

Defined in:

deliver/send_elasticsearch.cr

Class Method Summary

Instance Method Summary

Instance methods inherited from class Deliver

apply_all(endpoints : Array(Endpoint)) apply_all, apply_filters(endpoints : Array(Endpoint)) apply_filters, apply_matchers(endpoints : Array(Endpoint)) apply_matchers, filters : Array(String) filters, headers : Hash(String, String) headers, matchers : Array(String) matchers, proxy : String proxy, run run, undeliverable_count : Int32 undeliverable_count

Constructor methods inherited from class Deliver

new(options : Hash(String, YAML::Any)) new

Class Method Detail

def self.normalize_endpoint(es_endpoint : String) : URI #

http:// with no port means the local/dev cluster shape, where 9200 is the useful default. https:// does not: managed clusters (AWS OpenSearch Service, Elastic Cloud) and anything behind a TLS reverse proxy listen on 443, so forcing 9200 there rewrote a working endpoint into an unreachable one and the export failed with a connection error the user had no way to explain. An explicit port always wins.


[View source]

Instance Method Detail

def run(endpoints : Array(Endpoint), es_endpoint : String) #

[View source]