Skip to content

Commit

Permalink
remove service info in MakeListener
Browse files Browse the repository at this point in the history
Signed-off-by: Teju Nareddy <[email protected]>
  • Loading branch information
nareddyt committed Nov 10, 2023
1 parent b658d8c commit 00bb51e
Showing 1 changed file with 14 additions and 13 deletions.
27 changes: 14 additions & 13 deletions src/go/configgenerator/listener_generator.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ import (
"github.com/GoogleCloudPlatform/esp-v2/src/go/configgenerator/filtergen"
"github.com/GoogleCloudPlatform/esp-v2/src/go/configgenerator/routegen"
sc "github.com/GoogleCloudPlatform/esp-v2/src/go/configinfo"
"github.com/GoogleCloudPlatform/esp-v2/src/go/options"
"github.com/GoogleCloudPlatform/esp-v2/src/go/util"
corepb "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
listenerpb "github.com/envoyproxy/go-control-plane/envoy/config/listener/v3"
Expand Down Expand Up @@ -47,7 +48,7 @@ func MakeListeners(serviceInfo *sc.ServiceInfo, scParams filtergen.ServiceContro
return nil, err
}

listener, err := MakeListener(serviceInfo, filterGens, connectionManager, routeGens)
listener, err := MakeListener(serviceInfo.Options, filterGens, connectionManager, routeGens)
if err != nil {
return nil, err
}
Expand Down Expand Up @@ -87,13 +88,13 @@ func MakeHttpFilterConfigs(filterGenerators []filtergen.FilterGenerator) ([]*hcm
// MakeListener provides a dynamic listener for Envoy.
// Allows dependency injection of FilterGenerator and RouteGenerator for
// internal use.
func MakeListener(serviceInfo *sc.ServiceInfo, httpFilterGenerators []filtergen.FilterGenerator, connectionManagerGen filtergen.FilterGenerator, routeGenerators []routegen.RouteGenerator) (*listenerpb.Listener, error) {
func MakeListener(opts options.ConfigGeneratorOptions, httpFilterGenerators []filtergen.FilterGenerator, connectionManagerGen filtergen.FilterGenerator, routeGenerators []routegen.RouteGenerator) (*listenerpb.Listener, error) {
httpFilterConfigs, err := MakeHttpFilterConfigs(httpFilterGenerators)
if err != nil {
return nil, err
}

routeConfig, err := MakeRouteConfig(serviceInfo.Options, httpFilterGenerators, routeGenerators)
routeConfig, err := MakeRouteConfig(opts, httpFilterGenerators, routeGenerators)
if err != nil {
return nil, fmt.Errorf("makeHttpConnectionManagerRouteConfig got err: %s", err)
}
Expand Down Expand Up @@ -125,13 +126,13 @@ func MakeListener(serviceInfo *sc.ServiceInfo, httpFilterGenerators []filtergen.
},
}

if serviceInfo.Options.SslServerCertPath != "" {
if opts.SslServerCertPath != "" {
transportSocket, err := util.CreateDownstreamTransportSocket(
serviceInfo.Options.SslServerCertPath,
serviceInfo.Options.SslServerRootCertPath,
serviceInfo.Options.SslMinimumProtocol,
serviceInfo.Options.SslMaximumProtocol,
serviceInfo.Options.SslServerCipherSuites,
opts.SslServerCertPath,
opts.SslServerRootCertPath,
opts.SslMinimumProtocol,
opts.SslMaximumProtocol,
opts.SslServerCipherSuites,
)
if err != nil {
return nil, err
Expand All @@ -144,19 +145,19 @@ func MakeListener(serviceInfo *sc.ServiceInfo, httpFilterGenerators []filtergen.
Address: &corepb.Address{
Address: &corepb.Address_SocketAddress{
SocketAddress: &corepb.SocketAddress{
Address: serviceInfo.Options.ListenerAddress,
Address: opts.ListenerAddress,
PortSpecifier: &corepb.SocketAddress_PortValue{
PortValue: uint32(serviceInfo.Options.ListenerPort),
PortValue: uint32(opts.ListenerPort),
},
},
},
},
FilterChains: []*listenerpb.FilterChain{filterChain},
}

if serviceInfo.Options.ConnectionBufferLimitBytes >= 0 {
if opts.ConnectionBufferLimitBytes >= 0 {
listener.PerConnectionBufferLimitBytes = &wrapperspb.UInt32Value{
Value: uint32(serviceInfo.Options.ConnectionBufferLimitBytes),
Value: uint32(opts.ConnectionBufferLimitBytes),
}
}

Expand Down

0 comments on commit 00bb51e

Please sign in to comment.