Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for mysql_proxy (0.26 sec)

  1. pilot/pkg/features/xds.go

    var (
    	// EnableMysqlFilter enables injection of `envoy.filters.network.mysql_proxy` in the filter chain.
    	// Pilot injects this outbound filter if the service port name is `mysql`.
    	EnableMysqlFilter = env.Register(
    		"PILOT_ENABLE_MYSQL_FILTER",
    		false,
    		"EnableMysqlFilter enables injection of `envoy.filters.network.mysql_proxy` in the filter chain.",
    	).Get()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 24 06:18:36 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  2. pkg/wellknown/wellknown.go

    	// ThriftProxy network filter
    	ThriftProxy = "envoy.filters.network.thrift_proxy"
    	// RedisProxy network filter
    	RedisProxy = "envoy.filters.network.redis_proxy"
    	// MySQLProxy network filter
    	MySQLProxy = "envoy.filters.network.mysql_proxy"
    	// ExternalAuthorization network filter
    	ExternalAuthorization = "envoy.filters.network.ext_authz"
    	// RoleBasedAccessControl network filter
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 11 15:29:30 UTC 2023
    - 4K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/networkfilter.go

    // buildMySQLFilter builds an outbound Envoy MySQLProxy filter.
    func buildMySQLFilter(statPrefix string) *listener.Filter {
    	mySQLProxy := &mysql.MySQLProxy{
    		StatPrefix: statPrefix, // MySQL stats are prefixed with mysql.<statPrefix> by Envoy.
    	}
    
    	out := &listener.Filter{
    		Name:       wellknown.MySQLProxy,
    		ConfigType: &listener.Filter_TypedConfig{TypedConfig: protoconv.MessageToAny(mySQLProxy)},
    	}
    
    	return out
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pkg/config/xds/filter_types.gen.go

    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/kafka_mesh/v3alpha"
    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/mysql_proxy/v3"
    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/postgres_proxy/v3alpha"
    	_ "github.com/envoyproxy/go-control-plane/contrib/envoy/extensions/filters/network/rocketmq_proxy/v3"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Jun 02 02:48:23 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  5. pkg/adsc/adsc.go

    			} else {
    				routes = append(routes, fmt.Sprintf("%d", port))
    			}
    		case wellknown.MongoProxy:
    			// ignore for now
    		case wellknown.RedisProxy:
    			// ignore for now
    		case wellknown.MySQLProxy:
    			// ignore for now
    		default:
    			adscLog.Infof(protomarshal.ToJSONWithIndent(l, "  "))
    		}
    	}
    
    	adscLog.Infof("LDS: http=%d tcp=%d size=%d", len(lh), len(lt), ldsSize)
    	if adscLog.DebugEnabled() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 05 22:18:49 UTC 2024
    - 35K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/listener_test.go

    }
    
    func isMysqlListener(listener *listener.Listener) bool {
    	if len(listener.FilterChains) > 0 && len(listener.FilterChains[0].Filters) > 0 {
    		return listener.FilterChains[0].Filters[0].Name == wellknown.MySQLProxy
    	}
    	return false
    }
    
    func hasListenerOrFilterChainForPort(listeners []*listener.Listener, port uint32) bool {
    	for _, l := range listeners {
    		if port == l.Address.GetSocketAddress().GetPortValue() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
Back to top