- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for telemetryAccessLog (3.26 sec)
-
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) -
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) -
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)