- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for gotSock (0.21 sec)
-
pkg/kubelet/server/stats/summary_windows_test.go
limitations under the License. */ package stats import ( "context" "testing" "time" fuzz "github.com/google/gofuzz" "github.com/stretchr/testify/assert" gomock "go.uber.org/mock/gomock" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" "k8s.io/kubernetes/pkg/kubelet/cm"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 4.4K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
}() drwm3 := NewDRWMutex(ds, "simplelock") // fmt.Println("Trying to acquire write lock, waiting...") ctx3, cancel3 := context.WithCancel(context.Background()) locked = drwm3.GetLock(ctx3, cancel3, id, source, Options{Timeout: duration}) if locked { // fmt.Println("Write lock acquired, waiting...") time.Sleep(testDrwMutexAcquireTimeout) drwm3.Unlock(context.Background()) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
pkg/kubelet/eviction/memory_threshold_notifier_test.go
See the License for the specific language governing permissions and limitations under the License. */ package eviction import ( "fmt" "strings" "sync" "testing" "time" gomock "go.uber.org/mock/gomock" "k8s.io/apimachinery/pkg/api/resource" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" evictionapi "k8s.io/kubernetes/pkg/kubelet/eviction/api" ) const testCgroupPath = "/sys/fs/cgroups/memory"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator_test.go
limitations under the License. */ package stats import ( "errors" "fmt" "testing" "time" "github.com/stretchr/testify/assert" "go.uber.org/mock/gomock" csipbv1 "github.com/container-storage-interface/spec/lib/go/csi" k8sv1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/resource" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1alpha1_test.go
See the License for the specific language governing permissions and limitations under the License. */ package podresources import ( "context" "testing" "go.uber.org/mock/gomock" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" podresourcesv1 "k8s.io/kubelet/pkg/apis/podresources/v1" "k8s.io/kubelet/pkg/apis/podresources/v1alpha1"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3.9K bytes - Viewed (0) -
pkg/kubelet/metrics/collectors/volume_stats_test.go
See the License for the specific language governing permissions and limitations under the License. */ package collectors import ( "context" "strings" "testing" "go.uber.org/mock/gomock" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/component-base/metrics/testutil" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" statstest "k8s.io/kubernetes/pkg/kubelet/server/stats/testing" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.5K bytes - Viewed (1) -
pkg/kubelet/cm/container_manager_linux_test.go
} func TestGetCapacity(t *testing.T) { ephemeralStorageFromCapacity := int64(2000) ephemeralStorageFromCadvisor := int64(8000) mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockCtrlError := gomock.NewController(t) defer mockCtrlError.Finish() mockCadvisor := cadvisortest.NewMockInterface(mockCtrl) rootfs := cadvisorapiv2.FsInfo{ Capacity: 8000, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/kubelet/runonce_test.go
package kubelet import ( "context" "os" "path/filepath" "testing" "time" cadvisorapi "github.com/google/cadvisor/info/v1" cadvisorapiv2 "github.com/google/cadvisor/info/v2" "go.uber.org/mock/gomock" "k8s.io/mount-utils" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/tools/record"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
src/internal/trace/testdata/tests/go122-annotations.test
ProcStart dt=505 p=1 p_seq=1 GoStart dt=303 g=7 g_seq=1 HeapAlloc dt=646 heapalloc_value=1892352 HeapAlloc dt=149 heapalloc_value=1900544 GoBlock dt=146 reason_string=12 stack=24 GoStart dt=14 g=6 g_seq=1 HeapAlloc dt=16 heapalloc_value=1908736 GoBlock dt=347 reason_string=12 stack=25 EventBatch gen=1 m=167928 time=28113086279032 size=10 ProcStart dt=451 p=2 p_seq=1 GoStart dt=188 g=8 g_seq=1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 8.7K bytes - Viewed (0) -
cmd/license-update.go
duration = time.Second } time.Sleep(duration) } }() } func licenceUpdaterLoop(ctx context.Context, objAPI ObjectLayer) { ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel() licenseUpdateTimer := time.NewTimer(licUpdateCycle) defer licenseUpdateTimer.Stop() for { select { case <-ctx.Done(): return case <-licenseUpdateTimer.C:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 3.3K bytes - Viewed (0)