Method: Fluent::SendmailInput#sent

Defined in:
lib/fluent/plugin/in_sendmail.rb

#sent(es, deliveryid, time, to_line) ⇒ Object 



115
116
117
118
119
120
121
122
123
124
125
 
# File 'lib/fluent/plugin/in_sendmail.rb', line 115

def sent(es, deliveryid, time, to_line)
  from_line = @delivers[deliveryid].from_line
  record = from_line.merge(to_line)
  es.add(time, record)
  nrcpts = @delivers[deliveryid].nrcpts
  @delivers[deliveryid].nrcpts -= to_line["to"].length
  # all done
  if @delivers[deliveryid].nrcpts <= 0
    @delivers.delete(deliveryid)
  end
end