Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for setTCPAccessLog (0.22 sec)

  1. pilot/pkg/networking/core/accesslog.go

    	return &AccessLogBuilder{
    		tcpGrpcAccessLog:         tcpGrpcAccessLog(false),
    		httpGrpcAccessLog:        httpGrpcAccessLog(),
    		tcpGrpcListenerAccessLog: tcpGrpcAccessLog(true),
    	}
    }
    
    func (b *AccessLogBuilder) setTCPAccessLog(push *model.PushContext, proxy *model.Proxy, tcp *tcp.TcpProxy, class networking.ListenerClass, svc *model.Service) {
    	mesh := push.Mesh
    	cfgs := push.Telemetry.AccessLogging(push, proxy, class, svc)
    
    	if len(cfgs) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/networkfilter.go

    func setAccessLogAndBuildTCPFilter(push *model.PushContext, node *model.Proxy,
    	config *tcp.TcpProxy, class istionetworking.ListenerClass, svc *model.Service,
    ) *listener.Filter {
    	accessLogBuilder.setTCPAccessLog(push, node, config, class, svc)
    
    	tcpFilter := &listener.Filter{
    		Name:       wellknown.TCPProxy,
    		ConfigType: &listener.Filter_TypedConfig{TypedConfig: protoconv.MessageToAny(config)},
    	}
    	return tcpFilter
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/accesslog_test.go

    			tcp:      &tcp.TcpProxy{},
    			class:    networking.ListenerClassSidecarInbound,
    			expected: &tcp.TcpProxy{},
    		},
    	}
    
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			b.setTCPAccessLog(tc.push, tc.proxy, tc.tcp, tc.class, nil)
    			assert.Equal(t, tc.expected, tc.tcp)
    		})
    	}
    }
    
    func TestSetHttpAccessLog(t *testing.T) {
    	b := newAccessLogBuilder()
    
    	env := newTestEnviroment()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/listener_builder.go

    		IdleTimeout:      parseDuration(node.Metadata.IdleTimeout),
    	}
    
    	filterStack := buildMetricsNetworkFilters(push, node, istionetworking.ListenerClassSidecarOutbound, nil)
    	accessLogBuilder.setTCPAccessLog(push, node, tcpProxy, istionetworking.ListenerClassSidecarOutbound, nil)
    	filterStack = append(filterStack, &listener.Filter{
    		Name:       wellknown.TCPProxy,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 17.9K bytes
    - Viewed (0)
Back to top