- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 155 for Messages (0.08 sec)
-
pilot/test/xdstest/extract.go
} return res } func SilentlyUnmarshalAny[T any](a *anypb.Any) *T { dst := any(new(T)).(proto.Message) if err := a.UnmarshalTo(dst); err != nil { var z *T return z } return any(dst).(*T) } func UnmarshalAny[T any](t test.Failer, a *anypb.Any) *T { dst := any(new(T)).(proto.Message) if err := a.UnmarshalTo(dst); err != nil { t.Fatalf("failed to unmarshal to %T: %v", dst, err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 13.9K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
func (c *Controller) matchesFilter(pod *corev1.Pod) bool { // Helper function; checks that a container's termination message matches filter matchTerminationMessage := func(state *corev1.ContainerStateTerminated) bool { // If we are filtering on init container termination message and the termination message of 'state' does not match, exit trimmedTerminationMessage := strings.TrimSpace(c.cfg.InitTerminationMsg)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver.go
return nil, err } if resp.StatusCode < 200 || resp.StatusCode >= 300 { message := strconv.Quote(string(body)) if len(message) > 100 { message = message[:100] return nil, fmt.Errorf("status %d, message %s(truncated)", resp.StatusCode, message) } return nil, fmt.Errorf("status %d, message %s", resp.StatusCode, message) } return body, nil } for i := 0; i < retry; i++ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0) -
pilot/pkg/grpc/grpc.go
if s.Code() == codes.Canceled || s.Code() == codes.DeadlineExceeded { return true } if s.Code() == codes.Unavailable && containsExpectedMessage(s.Message()) { return true } } // If this is not a gRPCStatus we should just error message. if strings.Contains(err.Error(), "stream terminated by RST_STREAM with error code: NO_ERROR") { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 04:27:50 UTC 2024 - 4.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/externalcontrolplane/externalcontrolplane.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 16:48:42 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/config/analysis/analyzers/virtualservice/destinationrules.go
return true }) } func (d *DestinationRuleAnalyzer) analyzeVirtualService(r *resource.Instance, ctx analysis.Context, destHostsAndSubsets map[hostAndSubset]bool, ) { vs := r.Message.(*v1alpha3.VirtualService) ns := r.Metadata.FullName.Namespace for _, ad := range getRouteDestinations(vs) { if !d.checkDestinationSubset(ns, ad.Destination, destHostsAndSubsets) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 15:18:05 UTC 2023 - 4.1K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/util/intstr/generated.proto
// accept a name or number. // TODO: Rename to Int32OrString // // +protobuf=true // +protobuf.options.(gogoproto.goproto_stringer)=false // +k8s:openapi-gen=true message IntOrString { optional int64 type = 1; optional int32 intVal = 2; optional string strVal = 3;
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 1.3K bytes - Viewed (0) -
istioctl/pkg/util/common.go
type CommandParseError struct { Err error } func (c CommandParseError) Error() string { return c.Err.Error() } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.6K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
} } } } func applyDelta(message model.Resources, resp *discovery.DeltaDiscoveryResponse) model.Resources { deleted := sets.New(resp.RemovedResources...) byName := map[string]*discovery.Resource{} for _, v := range resp.Resources { byName[v.Name] = v } res := model.Resources{} for _, m := range message { if deleted.Contains(m.Name) { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
tests/integration/security/filebased_tls_origination/destination_rule_tls_test.go
) // TestDestinationRuleTls tests that MUTUAL tls mode is respected in DestinationRule. // This sets up a client and server with appropriate cert config and ensures we can successfully send a message. func TestDestinationRuleTls(t *testing.T) { framework. NewTest(t). Run(func(t framework.TestContext) { ns := appNS
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.1K bytes - Viewed (0)