wip

pkg/config/legacy/conversion.go

@@ -179,6 +179,11 @@ func transformHeadersFromPluginParams(params map[string]string) v1.HeaderOperati
 				out.Set = make(map[string]string)
 			}
 			out.Set[k] = v
+
+			if out.Delete == nil {
+				out.Delete = make(map[string]bool)
+			}
+			out.Delete[k] = true
 		}
 	}
 	return out

pkg/config/v1/common.go

@@ -127,7 +127,8 @@ type HTTPPluginOptions struct {
 }
 
 type HeaderOperations struct {
-	Set map[string]string `json:"set,omitempty"`
+	Set    map[string]string `json:"set,omitempty"`
+	Delete map[string]bool   `json:"delete,omitempty"`
 }
 
 type HTTPHeader struct {

pkg/plugin/client/http2http.go

@@ -61,6 +61,9 @@ func NewHTTP2HTTPPlugin(_ PluginContext, options v1.ClientPluginOptions) (Plugin
 			for k, v := range p.opts.RequestHeaders.Set {
 				req.Header.Set(k, v)
 			}
+			for k, _ := range p.opts.RequestHeaders.Delete {
+				req.Header.Del(k)
+			}
 		},
 		BufferPool: pool.NewBuffer(32 * 1024),
 		ErrorLog:   stdlog.New(log.NewWriteLogger(log.WarnLevel, 2), "", 0),

pkg/plugin/client/http2https.go

@@ -69,6 +69,9 @@ func NewHTTP2HTTPSPlugin(_ PluginContext, options v1.ClientPluginOptions) (Plugi
 			for k, v := range p.opts.RequestHeaders.Set {
 				req.Header.Set(k, v)
 			}
+			for k, _ := range p.opts.RequestHeaders.Delete {
+				req.Header.Del(k)
+			}
 		},
 		Transport:  tr,
 		BufferPool: pool.NewBuffer(32 * 1024),

pkg/plugin/client/https2http.go

@@ -68,6 +68,9 @@ func NewHTTPS2HTTPPlugin(_ PluginContext, options v1.ClientPluginOptions) (Plugi
 			for k, v := range p.opts.RequestHeaders.Set {
 				req.Header.Set(k, v)
 			}
+			for k, _ := range p.opts.RequestHeaders.Delete {
+				req.Header.Del(k)
+			}
 		},
 		BufferPool: pool.NewBuffer(32 * 1024),
 		ErrorLog:   stdlog.New(log.NewWriteLogger(log.WarnLevel, 2), "", 0),

pkg/plugin/client/https2https.go

@@ -73,6 +73,9 @@ func NewHTTPS2HTTPSPlugin(_ PluginContext, options v1.ClientPluginOptions) (Plug
 			for k, v := range p.opts.RequestHeaders.Set {
 				req.Header.Set(k, v)
 			}
+			for k, _ := range p.opts.RequestHeaders.Delete {
+				req.Header.Del(k)
+			}
 		},
 		Transport:  tr,
 		BufferPool: pool.NewBuffer(32 * 1024),