Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewUDSLogger (0.08 sec)

  1. cni/pkg/log/uds_test.go

    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestUDSLog(t *testing.T) {
    	// Start UDS log server
    	udsSockDir := t.TempDir()
    	udsSock := filepath.Join(udsSockDir, "cni.sock")
    	logger := NewUDSLogger(istiolog.DebugLevel)
    	stop := make(chan struct{})
    	defer close(stop)
    	assert.NoError(t, logger.StartUDSLogServer(udsSock, stop))
    
    	// Configure log to tee to UDS server
    	stdout := os.Stdout
    	r, w, _ := os.Pipe()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 16:26:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. cni/pkg/log/uds.go

    }
    
    type cniLog struct {
    	Level     string         `json:"level"`
    	Time      time.Time      `json:"time"`
    	Msg       string         `json:"msg"`
    	Arbitrary map[string]any `json:"-"`
    }
    
    func NewUDSLogger(level istiolog.Level) *UDSLogger {
    	l := &UDSLogger{}
    	mux := http.NewServeMux()
    	mux.HandleFunc(constants.UDSLogPath, l.handleLog)
    	loggingServer := &http.Server{
    		Handler: mux,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. cni/pkg/cmd/root.go

    		// Start metrics server
    		monitoring.SetupMonitoring(cfg.InstallConfig.MonitoringPort, "/metrics", ctx.Done())
    
    		// Start UDS log server
    		udsLogger := udsLog.NewUDSLogger(log.GetOutputLevel())
    		if err = udsLogger.StartUDSLogServer(filepath.Join(cfg.InstallConfig.CNIAgentRunDir, constants.LogUDSSocketName), ctx.Done()); err != nil {
    			log.Errorf("Failed to start up UDS Log Server: %v", err)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top