- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 64 for gotSock (0.37 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) -
src/cmd/trace/testdata/go122.test
GoBlock dt=2 reason_string=15 stack=27 GoStart dt=2 g=1 g_seq=8 GoCreate dt=8 new_g=20 new_stack=23 stack=24 GoBlock dt=3 reason_string=12 stack=25 GoStart dt=2 g=20 g_seq=1 GoUnblock dt=3 g=1 g_seq=9 stack=26 GoBlock dt=1 reason_string=15 stack=27 GoStart dt=2 g=1 g_seq=10 GoCreate dt=6 new_g=21 new_stack=23 stack=24 GoBlock dt=3 reason_string=12 stack=25 GoStart dt=1 g=21 g_seq=1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 166K bytes - Viewed (0) -
internal/s3select/sql/value_test.go
t.Run(tt.name, func(t *testing.T) { v := Value{ value: tt.fields.value, } gotVal, gotOk := v.bytesToBool() if gotVal != tt.wantVal { t.Errorf("bytesToBool() gotVal = %v, want %v", gotVal, tt.wantVal) } if gotOk != tt.wantOk { t.Errorf("bytesToBool() gotOk = %v, want %v", gotOk, tt.wantOk) } }) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 06 16:56:10 UTC 2023 - 12.5K 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) -
internal/lsync/lrwmutex.go
func (lm *LRWMutex) Lock() { const isWriteLock = true lm.lockLoop(context.Background(), lm.id, lm.source, math.MaxInt64, isWriteLock) } // GetLock tries to get a write lock on lm before the timeout occurs. func (lm *LRWMutex) GetLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) { const isWriteLock = true return lm.lockLoop(ctx, id, source, timeout, isWriteLock) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K 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)