- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for MATCH (0.03 sec)
-
pilot/pkg/networking/core/listener_waypoint.go
chains = append(chains, tcpChain, httpChain) portMapper.Map[portString] = match.ToMatcher(match.NewAppProtocol(match.ProtocolMatch{ TCP: match.ToChain(tcpName), HTTP: match.ToChain(httpName), })) } else if port.Protocol.IsHTTP() { // Otherwise, just insert HTTP/TCP chains = append(chains, httpChain) portMapper.Map[portString] = match.ToChain(httpChain.Name) } else { chains = append(chains, tcpChain)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
func sortHTTPRoutes(routes []*istio.HTTPRoute) { sort.SliceStable(routes, func(i, j int) bool { if len(routes[i].Match) == 0 { return false } else if len(routes[j].Match) == 0 { return true } // Only look at match[0], we always generate only one match m1, m2 := routes[i].Match[0], routes[j].Match[0] r1, r2 := getURIRank(m1), getURIRank(m2) len1, len2 := getURILength(m1), getURILength(m2) switch {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging_test.go
AccessLogging: []*tpb.AccessLogging{ { Match: &tpb.AccessLogging_LogSelector{ Mode: tpb.WorkloadMode_CLIENT, }, Providers: []*tpb.ProviderRef{ { Name: "envoy", }, }, }, }, } clientDisabled := &tpb.Telemetry{ AccessLogging: []*tpb.AccessLogging{ { Match: &tpb.AccessLogging_LogSelector{ Mode: tpb.WorkloadMode_CLIENT,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 54K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
Tracing: []*tpb.Tracing{ { Match: &tpb.Tracing_TracingSelector{ Mode: tpb.WorkloadMode_CLIENT, }, Providers: []*tpb.ProviderRef{ { Name: "stackdriver", }, }, RandomSamplingPercentage: &wrappers.DoubleValue{Value: 99.9}, }, }, } serverSideDisabled := &tpb.Telemetry{ Tracing: []*tpb.Tracing{ { Match: &tpb.Tracing_TracingSelector{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/config/analysis/analyzers/analyzers_test.go
{msg.VirtualServiceUnreachableRule, "VirtualService duplicate-match"}, {msg.VirtualServiceUnreachableRule, "VirtualService foo/sample-foo-cluster01"}, {msg.VirtualServiceIneffectiveMatch, "VirtualService almost-duplicate-match"}, {msg.VirtualServiceIneffectiveMatch, "VirtualService duplicate-match"}, {msg.VirtualServiceUnreachableRule, "VirtualService duplicate-tcp-match"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 07:22:31 UTC 2024 - 42.6K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
// service, we should not translate Gateway ports to target ports. For example, if I have a Service // on port 80 with target port 8080, with the label. Gateways on port 80 would *not* match. Instead, // only Gateways on port 8080 would be used. This prevents ambiguities when there are multiple // Services on port 80 referring to different target ports. Long term, this will be replaced by
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
Resource("examples"). Name(name). VersionedParams(&options, scheme.ParameterCodec). Do(ctx). Into(result) return } // List takes label and field selectors, and returns the list of Examples that match those selectors. func (c *examples) List(ctx context.Context, opts metav1.ListOptions) (*v1.ExampleList, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 8.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go
Name(name). VersionedParams(&options, scheme.ParameterCodec). Do(ctx). Into(result) return } // List takes label and field selectors, and returns the list of CustomResourceDefinitions that match those selectors. func (c *customResourceDefinitions) List(ctx context.Context, opts v1.ListOptions) (*v1beta1.CustomResourceDefinitionList, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go
Name(name). VersionedParams(&options, scheme.ParameterCodec). Do(ctx). Into(result) return } // List takes label and field selectors, and returns the list of CustomResourceDefinitions that match those selectors. func (c *customResourceDefinitions) List(ctx context.Context, opts metav1.ListOptions) (*v1.CustomResourceDefinitionList, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
schemas collection.Schemas // domainSuffix for the config metadata domainSuffix string // revision for this control plane instance. We will only read configs that match this revision. revision string // kinds keeps track of all cache handlers for known types kinds map[config.GroupVersionKind]kclient.Untyped kindsMu sync.RWMutex queue queue.Instance
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0)