Method: LogStash::Outputs::Application_insights::Upload_pipe#commit

Defined in:

lib/logstash/outputs/application_insights/upload_pipe.rb

#commit ⇒ Object

# File 'lib/logstash/outputs/application_insights/upload_pipe.rb', line 155

def commit
  unless @uploaded_block_ids.empty?
    @action = :commit
    @recoverable = [ :invalid_storage_key, :io_failure, :service_unavailable ]
    success =  storage_io_block {
      @info = "#{@action.to_s} #{@storage_account_name}/#{@container_name}/#{@blob_name}, events: #{@uploaded_events_count}, size: #{@uploaded_bytesize}, blocks: #{@uploaded_block_numbers}, delay: #{Time.now.utc - @oldest_event_time}"
      # assume that exceptions can be raised due to this method:

      @client.blobClient.commit_blob_blocks( @container_name, @blob_name, @uploaded_block_ids ) unless @configuration[:disable_blob_upload]
      @log_state = :committed
    }
    if success
      # next stage

      state_table_update
    else
      @storage_recovery.recover_later( context_to_tuple, :commit, @storage_account_name )
    end
  end
end