- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 304 for Tstruct (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
stopCh := make(chan struct{}) controller, controllerCompletedCh := startAPFController(t, stopCh, apfConfiguration, serverConcurrency, plName, plConcurrency) headerMatcher := headerMatcher{} rquestTimesOutPath := "/request/time-out-as-designed" reqHandlerCompletedCh, callerRoundTripDoneCh := make(chan struct{}), make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
logger, _ := ktesting.NewTestContext(t) stopCh := make(chan struct{}) defer close(stopCh) manager, informers := testNewReplicaSetControllerFromClient(t, clientset.NewForConfigOrDie(&restclient.Config{Host: "", ContentConfig: restclient.ContentConfig{GroupVersion: &schema.GroupVersion{Group: "", Version: "v1"}}}), stopCh, BurstReplicas) testCases := []struct { name string rss []*apps.ReplicaSet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
runtime: runtime, } nested.workerChannelFn = func(uid types.UID, in chan struct{}) <-chan struct{} { ch := make(chan struct{}) go func() { defer close(ch) // TODO: this is an eager loop, we might want to lazily read from in only once // ch is empty for range in { w.waitForPod(uid) w.tick() ch <- struct{}{} } }() return ch } return w, processed }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
src/strings/strings_test.go
for i := 0; i < len(a); i++ { if a[i] != b[i] { return false } } return true } var abcd = "abcd" var faces = "☺☻☹" var commas = "1,2,3,4" var dots = "1....2....3....4" type IndexTest struct { s string sep string out int } var indexTests = []IndexTest{ {"", "", 0}, {"", "a", -1}, {"", "foo", -1}, {"fo", "foo", -1}, {"foo", "foo", 0}, {"oofofoofooo", "f", 2},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 12:58:37 UTC 2024 - 53K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go
} func intQuantity(i int64, exponent Scale, format Format) Quantity { return Quantity{i: int64Amount{value: i, scale: exponent}, Format: format} } func TestDec(t *testing.T) { table := []struct { got infDecAmount expect string }{ {dec(1, 0), "1"}, {dec(1, 1), "10"}, {dec(5, 2), "500"}, {dec(8, 3), "8000"}, {dec(2, 0), "2"}, {dec(1, -1), "0.1"}, {dec(3, -2), "0.03"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:10 UTC 2024 - 49.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/types.go
ServerAddress string `json:"serverAddress" protobuf:"bytes,2,opt,name=serverAddress"` } // GroupVersion contains the "group/version" and "version" string of a version. // It is made a struct to keep extensibility. type GroupVersionForDiscovery struct { // groupVersion specifies the API group and version in the form "group/version" GroupVersion string `json:"groupVersion" protobuf:"bytes,1,opt,name=groupVersion"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 10:52:25 UTC 2024 - 79.2K bytes - Viewed (1) -
pkg/apis/admissionregistration/types.go
// ValidatingAdmissionPolicy type TypeChecking struct { // The type checking warnings for each expression. // +optional // +listType=atomic ExpressionWarnings []ExpressionWarning } // ExpressionWarning is a warning information that targets a specific expression. type ExpressionWarning struct { // The path to the field that refers the expression.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 20:14:19 UTC 2024 - 52.6K bytes - Viewed (0) -
src/bytes/bytes_test.go
// slices before invoking the functions. var abcd = "abcd" var faces = "☺☻☹" var commas = "1,2,3,4" var dots = "1....2....3....4" type BinOpTest struct { a string b string i int } func TestEqual(t *testing.T) { // Run the tests and check for allocation at the same time. allocs := testing.AllocsPerRun(10, func() { for _, tt := range compareTests {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 12:58:37 UTC 2024 - 56.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
} verifyAttachedVolume(t, attachedVolumes, generatedVolumeName1, string(volumeName), nodeName, devicePath, true /* expectedMountedByNode */, false /* expectNonZeroDetachRequestedTime */) } // Populates data struct with one volume/node entry. // Calls DeleteVolumeNode() to delete volume/node. // Verifies no volume/node entries exists. func Test_DeleteVolumeNode_Positive_VolumeExistsNodeExists(t *testing.T) { // Arrange
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
plugin/pkg/admission/resourcequota/admission_test.go
return createHandlerWithConfig(kubeClient, informerFactory, nil, stopCh) } func createHandlerWithConfig(kubeClient kubernetes.Interface, informerFactory informers.SharedInformerFactory, config *resourcequotaapi.Configuration, stopCh chan struct{}) (*resourcequota.QuotaAdmission, error) { if config == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0)