Class: LogStash::Outputs::Awslogs

Inherits:
Base
  • Object
show all
Includes:
PluginMixins::AwsConfig::V2
Defined in:
lib/logstash/outputs/awslogs.rb

Constant Summary collapse

PER_EVENT_OVERHEAD = 
26
MAX_BATCH_SIZE = 
1024 * 1024
MIN_DELAY = 
0.2

Instance Method Summary collapse

Instance Method Details

#multi_receive(events) ⇒ Object 



35
36
37
38
39
40
 
# File 'lib/logstash/outputs/awslogs.rb', line 35

def multi_receive(events)
  send_batches = form_event_batches(events)
  send_batches.each do |batch|
    put_events(batch)
  end
end

#register ⇒ Object 



29
30
31
32
 
# File 'lib/logstash/outputs/awslogs.rb', line 29

def register
  @client = Aws::CloudWatchLogs::Client.new(aws_options_hash)
  @last_flush = Time.now.to_f
end