Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for telemetryAccessLog (3.26 sec)

  1. pilot/pkg/model/telemetry_logging.go

    // This is to ensure this stays in sync as new handlers are added
    // STOP. DO NOT UPDATE THIS WITHOUT UPDATING telemetryAccessLog.
    const telemetryAccessLogHandled = 14
    
    func telemetryAccessLog(push *PushContext, fp *meshconfig.MeshConfig_ExtensionProvider) *accesslog.AccessLog {
    	var al *accesslog.AccessLog
    	switch prov := fp.Provider.(type) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 23K bytes
    - Viewed (0)
  2. pilot/pkg/model/telemetry.go

    		if fp == nil {
    			log.Debugf("fail to fetch provider %s", p)
    			continue
    		}
    		cfg := LoggingConfig{
    			Provider: fp,
    			Filter:   v.Filter,
    			Disabled: v.Disabled,
    		}
    
    		al := telemetryAccessLog(push, fp)
    		if al == nil {
    			// stackdriver will be handled in HTTPFilters/TCPFilters
    			continue
    		}
    		cfg.AccessLog = al
    		cfgs = append(cfgs, cfg)
    	}
    
    	t.computedLoggingConfig[key] = cfgs
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 18:14:09 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  3. pilot/pkg/model/telemetry_logging_test.go

    				})},
    			},
    		},
    	} {
    		t.Run(tc.name, func(t *testing.T) {
    			push := tc.ctx
    			if push == nil {
    				push = NewPushContext()
    			}
    			push.Mesh = tc.meshConfig
    
    			got := telemetryAccessLog(push, tc.fp)
    			if got == nil {
    				t.Fatalf("get nil accesslog")
    			}
    			assert.Equal(t, tc.expected, got)
    		})
    	}
    }
    
    func TestAccessLogJSONFormatters(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:30 UTC 2024
    - 54K bytes
    - Viewed (0)
Back to top