add OutputCachePolicy support

samples/KubernetesIngress.Sample/README.md

@@ -43,16 +43,17 @@ metadata:
   annotations:
     yarp.ingress.kubernetes.io/authorization-policy: authzpolicy
     yarp.ingress.kubernetes.io/rate-limiter-policy: ratelimiterpolicy
+    yarp.ingress.kubernetes.io/output-cache-policy: outputcachepolicy
     yarp.ingress.kubernetes.io/transforms: |
       - PathRemovePrefix: "/apis"
     yarp.ingress.kubernetes.io/route-headers: |
       - Name: the-header-key
-        Values: 
+        Values:
         - the-header-value
         Mode: Contains
         IsCaseSensitive: false
       - Name: another-header-key
-        Values: 
+        Values:
         - another-header-value
         Mode: Contains
         IsCaseSensitive: false
@@ -75,6 +76,7 @@ The table below lists the available annotations.
 |---|---|
 |yarp.ingress.kubernetes.io/authorization-policy|string|
 |yarp.ingress.kubernetes.io/rate-limiter-policy|string|
+|yarp.ingress.kubernetes.io/output-cache-policy|string|
 |yarp.ingress.kubernetes.io/backend-protocol|string|
 |yarp.ingress.kubernetes.io/cors-policy|string|
 |yarp.ingress.kubernetes.io/health-check|[ActivateHealthCheckConfig](https://microsoft.github.io/reverse-proxy/api/Yarp.ReverseProxy.Configuration.ActiveHealthCheckConfig.html)|
@@ -98,6 +100,10 @@ See https://microsoft.github.io/reverse-proxy/articles/rate-limiting.html for a
 
 `yarp.ingress.kubernetes.io/rate-limiter-policy: mypolicy`
 
+#### Output Cache Policy
+
+`yarp.ingress.kubernetes.io/output-cache-policy: mycachepolicy`
+
 #### Backend Protocol
 
 Specifies the protocol of the backend service. Defaults to http.
@@ -196,12 +202,12 @@ See https://microsoft.github.io/reverse-proxy/api/Yarp.ReverseProxy.Configuratio
 ```
 yarp.ingress.kubernetes.io/route-headers: |
   - Name: the-header-key
-    Values: 
+    Values:
     - the-header-value
     Mode: Contains
     IsCaseSensitive: false
   - Name: another-header-key
-    Values: 
+    Values:
     - another-header-value
     Mode: Contains
     IsCaseSensitive: false

src/Kubernetes.Controller/Converters/YarpIngressOptions.cs

@@ -14,6 +14,7 @@ internal sealed class YarpIngressOptions
     public string AuthorizationPolicy { get; set; }
 #if NET7_0_OR_GREATER
     public string RateLimiterPolicy { get; set; }
+    public string OutputCachePolicy { get; set; }
 #endif
     public SessionAffinityConfig SessionAffinity { get; set; }
     public HttpClientConfig HttpClientConfig { get; set; }

src/Kubernetes.Controller/Converters/YarpParser.cs

@@ -142,6 +142,7 @@ private static RouteConfig CreateRoute(YarpIngressContext ingressContext, V1HTTP
             AuthorizationPolicy = ingressContext.Options.AuthorizationPolicy,
 #if NET7_0_OR_GREATER
             RateLimiterPolicy = ingressContext.Options.RateLimiterPolicy,
+            OutputCachePolicy = ingressContext.Options.OutputCachePolicy,
 #endif
 #if NET8_0_OR_GREATER
             Timeout = ingressContext.Options.Timeout,
@@ -234,6 +235,10 @@ private static YarpIngressOptions HandleAnnotations(YarpIngressContext context,
         {
             options.RateLimiterPolicy = rateLimiterPolicy;
         }
+        if (annotations.TryGetValue("yarp.ingress.kubernetes.io/output-cache-policy", out var outputCachePolicy))
+        {
+            options.OutputCachePolicy = outputCachePolicy;
+        }
 #endif
         if (annotations.TryGetValue("yarp.ingress.kubernetes.io/cors-policy", out var corsPolicy))
         {

src/ReverseProxy/Configuration/ConfigProvider/ConfigurationConfigProvider.cs

@@ -149,6 +149,7 @@ private static RouteConfig CreateRoute(IConfigurationSection section)
             AuthorizationPolicy = section[nameof(RouteConfig.AuthorizationPolicy)],
 #if NET7_0_OR_GREATER
             RateLimiterPolicy = section[nameof(RouteConfig.RateLimiterPolicy)],
+            OutputCachePolicy = section[nameof(RouteConfig.OutputCachePolicy)],
 #endif
 #if NET8_0_OR_GREATER
             TimeoutPolicy = section[nameof(RouteConfig.TimeoutPolicy)],

src/ReverseProxy/Configuration/OutputCacheConstants.cs

@@ -0,0 +1,9 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+namespace Yarp.ReverseProxy.Configuration;
+
+internal static class OutputCacheConstants
+{
+    internal const string Default = "Default";
+}

src/ReverseProxy/Configuration/RouteConfig.cs

@@ -51,6 +51,12 @@ public sealed record RouteConfig
     /// Set to "Default" or leave empty to use the global rate limits, if any.
     /// </summary>
     public string? RateLimiterPolicy { get; init; }
+
+    /// <summary>
+    /// The name of the OutputCachePolicy to apply to this route.
+    /// If not set then only the BasePolicy will apply.
+    /// </summary>
+    public string? OutputCachePolicy { get; init; }
 #endif
 #if NET8_0_OR_GREATER
     /// <summary>

src/ReverseProxy/Routing/ProxyEndpointFactory.cs

@@ -14,13 +14,15 @@
 #endif
 #if NET7_0_OR_GREATER
 using Microsoft.AspNetCore.RateLimiting;
+using Microsoft.AspNetCore.OutputCaching;
 #endif
 using Microsoft.AspNetCore.Routing;
 using Microsoft.AspNetCore.Routing.Patterns;
 using Yarp.ReverseProxy.Model;
 using CorsConstants = Yarp.ReverseProxy.Configuration.CorsConstants;
 using AuthorizationConstants = Yarp.ReverseProxy.Configuration.AuthorizationConstants;
 using RateLimitingConstants = Yarp.ReverseProxy.Configuration.RateLimitingConstants;
+using OutputCacheConstants = Yarp.ReverseProxy.Configuration.OutputCacheConstants;
 using TimeoutPolicyConstants = Yarp.ReverseProxy.Configuration.TimeoutPolicyConstants;
 
 namespace Yarp.ReverseProxy.Routing;
@@ -137,6 +139,15 @@ public Endpoint CreateEndpoint(RouteModel route, IReadOnlyList<Action<EndpointBu
         {
             endpointBuilder.Metadata.Add(new EnableRateLimitingAttribute(config.RateLimiterPolicy));
         }
+
+        if (string.Equals(OutputCacheConstants.Default, config.OutputCachePolicy, StringComparison.OrdinalIgnoreCase))
+        {
+            // No-op (middleware applies the default)
+        }
+        else if (!string.IsNullOrEmpty(config.OutputCachePolicy))
+        {
+            endpointBuilder.Metadata.Add(new OutputCacheAttribute { PolicyName = config.OutputCachePolicy });
+        }
 #endif
 #if NET8_0_OR_GREATER
         if (string.Equals(TimeoutPolicyConstants.Disable, config.TimeoutPolicy, StringComparison.OrdinalIgnoreCase))

test/ReverseProxy.Tests/Configuration/ConfigProvider/ConfigurationConfigProviderTests.cs

@@ -347,6 +347,7 @@ public class ConfigurationConfigProviderTests
             ""ClusterId"": ""cluster1"",
             ""AuthorizationPolicy"": ""Default"",
             ""RateLimiterPolicy"": ""Default"",
+            ""OutputCachePolicy"": ""Default"",
             ""CorsPolicy"": ""Default"",
             ""TimeoutPolicy"": ""Default"",
             ""Timeout"": ""00:00:01"",
@@ -393,6 +394,7 @@ public class ConfigurationConfigProviderTests
             ""ClusterId"": ""cluster2"",
             ""AuthorizationPolicy"": null,
             ""RateLimiterPolicy"": null,
+            ""OutputCachePolicy"": null,
             ""CorsPolicy"": null,
             ""Metadata"": null,
             ""Transforms"": null