add

in lib/es/bulk_queue.rb [42:64]

• 18 lines of code
• 3 McCabe index (conditional complexity)

    def add(operation, payload = nil)
      unless will_fit?(operation, payload)
        log = <<~LOG.squish
          Operation failed to add to bulk queue. Current operation count is 
          Operation payload was 
        LOG
        @system_logger.error(log)
        raise Errors::BulkQueueOverflowError
      end

      operation_size = bytesize(operation)
      payload_size = bytesize(payload)

      @current_op_count += 1
      @current_buffer_size += operation_size
      @current_buffer_size += payload_size
      @current_data_size += payload_size

      @buffer << operation

      @buffer << payload if payload
    end