- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Messages (0.28 sec)
-
pkg/config/analysis/local/context.go
func (i *istiodContext) Report(c config.GroupVersionKind, m diag.Message) { msgs := i.messages[i.currentAnalyzer] if msgs == nil { msgs = &diag.Messages{} i.messages[i.currentAnalyzer] = msgs } msgs.Add(m) } func (i *istiodContext) SetAnalyzer(analyzerName string) { i.currentAnalyzer = analyzerName } func (i *istiodContext) GetMessages(analyzerNames ...string) diag.Messages { result := diag.Messages{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/config/analysis/README.md
if !c.Exists(collections.Gateway, resource.NewName(r.Metadata.FullName.Namespace, gwName)) { // Messages are defined in galley/pkg/config/analysis/msg/messages.yaml // From there, code is generated for each message type, including a constructor function // that you can use to create a new validation message of each type. msg := msg.NewReferencedResourceNotFound(r, "gateway", gwName)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 9.4K bytes - Viewed (0) -
cni/pkg/log/uds.go
return } messages := make([]cniLog, 0, len(cniLogs)) for _, l := range cniLogs { msg, ok := parseCniLog(l) if !ok { continue } messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI // processes interleave. l.mu.Lock() defer l.mu.Unlock() for _, m := range messages { logger := pluginLog
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/xds/v3/model.go
// nolint HttpProtocolOptionsType = "envoy.extensions.upstreams.http.v3.HttpProtocolOptions" ) // GetShortType returns an abbreviated form of a type, useful for logging or human friendly messages func GetShortType(typeURL string) string { return model.GetShortType(typeURL) } // GetMetricType returns the form of a type reported for metrics func GetMetricType(typeURL string) string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/multicluster_analyzers_test.go
result, err := runAnalyzer(sa) if err != nil { t.Fatalf("Error running analysis on testcase %s: %v", tc.name, err) } g.Expect(extractFields(result.Messages)).To(ConsistOf(tc.expected), "%v", prettyPrintMessages(result.Messages)) }) } } func setupMultiClusterEnvironmentForCase(tc mcTestCase, cr local.CollectionReporterFn) (*local.IstiodAnalyzer, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 4.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/webhook.go
istiolog "istio.io/istio/pkg/log" ) type httpServerErrorLogWriter struct{} // Webhook http.Server.ErrorLog handler specifically to filter // http: TLS handshake error from 127.0.0.1:<PORT>: EOF // messages that occur when clients send RST while TLS handshake is still in progress. // httpsReadyClient can trigger this periodically when multiple concurrent probes are hitting this endpoint.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 17:37:53 UTC 2024 - 2.7K bytes - Viewed (0) -
tests/integration/pilot/analysis/analysis_test.go
t.Fatalf("unexpected test failure: can't get virtualservice: %v", err) } status := &x.Status if hasError { if len(status.ValidationMessages) < 1 { return fmt.Errorf("expected validation messages to exist, but got nothing") } found := false for _, validation := range status.ValidationMessages { if validation.Type.Code == msg.ReferencedResourceNotFound.Code() { found = true } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.7K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
return err } return c.RouteDiff() } // nonstrictResolver is an AnyResolver that ignores unknown proto messages type nonstrictResolver struct{} var envoyResolver nonstrictResolver func (m *nonstrictResolver) Resolve(typeURL string) (legacyproto.Message, error) { // See https://github.com/golang/protobuf/issues/747#issuecomment-437463120 mname := typeURL
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/model/xds.go
WorkloadAuthorizationType = APITypePrefix + "istio.security.Authorization" ) // GetShortType returns an abbreviated form of a type, useful for logging or human friendly messages func GetShortType(typeURL string) string { switch typeURL { case ClusterType: return "CDS" case ListenerType: return "LDS" case RouteType: return "RDS" case EndpointType: return "EDS"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/zdsapi/zds.proto
- from now on, ztunnel will expect only AddWorkload and DelWorkload messages. */ // Sent from CNI to ztunnel message WorkloadRequest { oneof payload { AddWorkload add = 1; KeepWorkload keep = 5; DelWorkload del = 2; SnapshotSent snapshot_sent = 3; } } // Sent from ztunnel to CNI message WorkloadResponse { oneof payload {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 2.7K bytes - Viewed (0)