feat: pass RPCConfig to proxy.Config (cloudwego#240)

amazingchow · Dec 1, 2021 · e2eb0ca · e2eb0ca
1 parent fde6c57
commit e2eb0ca
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/client/client.go b/client/client.go
@@ -137,6 +137,7 @@ func (kc *kClient) proxyInit(ctx context.Context) (context.Context, error) {
 			Balancer:     kc.opt.Balancer,
 			Pool:         kc.opt.RemoteOpt.ConnPool,
 			FixedTargets: kc.opt.Targets,
+			RPCConfig:    kc.opt.Configs,
 		}
 		if err := kc.opt.Proxy.Configure(&cfg); err != nil {
 			return ctx, err

diff --git a/pkg/proxy/proxy.go b/pkg/proxy/proxy.go
@@ -33,6 +33,7 @@ type Config struct {
 	Balancer     loadbalance.Loadbalancer
 	Pool         remote.ConnPool
 	FixedTargets string // A comma separated list of host ports that user specify to use.
+	RPCConfig    rpcinfo.RPCConfig
 }
 
 // ForwardProxy manages the service discovery, load balance and connection pooling processes.