- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for Mathis (0.07 sec)
-
pkg/test/framework/components/environment/kube/settings.go
// from the provided k8s config files. type ClientFactoryFunc func(kubeConfigs []string) ([]istioKube.CLIClient, error) // Settings provide kube-specific Settings from flags. type Settings struct { // An array of paths to kube config files. Required if the environment is kubernetes. KubeConfig []string // Indicates that the LoadBalancer services can obtain a public IP. If not, NodePort be used as a workaround
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.3K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/value_types_json.go
return err } this.IntVal = &wrapperspb.Int32Value{Value: s} return nil } func (this *IntOrString) MarshalJSONPB(_ *github_com_golang_protobuf_jsonpb.Marshaler) ([]byte, error) { return this.MarshalJSON() } func (this *IntOrString) MarshalJSON() ([]byte, error) { if this.IntVal != nil { return json.Marshal(this.IntVal.GetValue()) } return json.Marshal(this.StrVal.GetValue()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 2.2K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_unspecified.go
return errors.New("not implemented on this platform") } func (m *realDeps) flush(name string) error { return errors.New("not implemented on this platform") } func (m *realDeps) clearEntriesWithComment(name, comment string) error { return errors.New("not implemented on this platform") } func (m *realDeps) clearEntriesWithIP(name string, ip netip.Addr) error { return errors.New("not implemented on this platform") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 1.8K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
// When Pilot exits, the lease will be dropped. This is more likely to lead to a case where // to instances are both considered the leaders. As such, if this is intended to be use for mission-critical // usages (rather than avoiding duplication of work), this may need to be re-evaluated. ReleaseOnCancel: true, } if !l.perRevision { // Function to use to decide whether this leader should steal the existing lock.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0) -
cni/pkg/repair/netns.go
// it might be. // // Instead, we rely directly on the procfs. // This rules out two possible methods: // * use crictl to inspect the pod; this returns the bind-mounted network namespace file. // * /var/lib/cni/results shows the outputs of CNI plugins; this containers the bind-mounted network namespace file. // // Instead, we traverse the procfs. Comments on this method are inline. func getPodNetNs(pod *corev1.Pod) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 04:07:10 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/xds/monitoring.go
"Total number of XDS requests with an expired nonce.", ) // pilot_total_xds_rejects should be used instead. This is for backwards compatibility cdsReject = monitoring.NewGauge( "pilot_xds_cds_reject", "Pilot rejected CDS configs.", ) // pilot_total_xds_rejects should be used instead. This is for backwards compatibility edsReject = monitoring.NewGauge( "pilot_xds_eds_reject", "Pilot rejected EDS.", )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 2.9K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters.go
// Multi-network is not configured (this is the case by default). Just access all endpoints directly. return endpoints } // A new array of endpoints to be returned that will have both local and // remote gateways (if any) filtered := make([]*LocalityEndpoints, 0) // Scale all weights by the lcm of gateways per network and gateways per cluster.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/util/smallset/smallset.go
return f } // Len returns the number of elements in this Set. func (s Set[T]) Len() int { return len(s.items) } // IsEmpty indicates whether the set is the empty set. func (s Set[T]) IsEmpty() bool { return len(s.items) == 0 } // IsNil indicates whether the set is nil. This is different from an empty set. // 'var smallset.Set': nil // smallset.New(): nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/test/framework/resource/settings.go
// os.TempDir() will be used. BaseDir string // The number of times to retry failed tests. // This should not be depended on as a primary means for reducing test flakes. Retries int // If enabled, namespaces will be reused rather than created with dynamic names each time. // This is useful when combined with NoCleanup, to allow quickly iterating on tests. StableNamespaces bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 9.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
ztunClient.Close() // this will retry for a bit, so shouldn't flake mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(0)) } func podAndNetns() (*v1.Pod, *fakeNs) { devNull, err := os.Open(os.DevNull) if err != nil { panic(err) } // we can't close this now, because we need to pass it from the ztunnel server to the client // it would leak, but this is a test, so we don't care
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0)