- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for utilstore (0.21 sec)
-
pkg/kubelet/checkpointmanager/checkpoint_manager.go
} // CheckpointManager provides the interface to manage checkpoint type CheckpointManager interface { // CreateCheckpoint persists checkpoint in CheckpointStore. checkpointKey is the key for utilstore to locate checkpoint. // For file backed utilstore, checkpointKey is the file name to write the checkpoint data. CreateCheckpoint(checkpointKey string, checkpoint Checkpoint) error // GetCheckpoint retrieves checkpoint from CheckpointStore.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 24 13:51:34 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/kubelet/checkpointmanager/checkpoint_manager_test.go
"sort" "testing" "github.com/stretchr/testify/assert" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/checksum" utilstore "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/testing" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/testing/example_checkpoint_formats/v1" ) var testStore *utilstore.MemStore type FakeCheckpoint interface { Checkpoint GetData() ([]*PortMapping, bool) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 12 06:41:04 UTC 2018 - 6.6K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
utilfeature "k8s.io/apiserver/pkg/util/feature" runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/features" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" utilstore "k8s.io/kubernetes/pkg/kubelet/util/store" "k8s.io/kubernetes/pkg/registry/core/service/allocator" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) // length for the user namespace to create (65536).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
tests/docker-compose.yml
- MSSQL_DB=gorm - MSSQL_USER=gorm - MSSQL_PASSWORD=LoremIpsum86 tidb: image: 'pingcap/tidb:v6.5.0' ports: - "9940:4000"
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Mon Mar 18 08:28:46 UTC 2024 - 862 bytes - Viewed (0) -
pkg/controller/controller_utils.go
// ControllerExpectationsInterface. uidStore cache.Store } // GetUIDs is a convenience method to avoid exposing the set of expected uids. // The returned set is not thread safe, all modifications must be made holding // the uidStoreLock. func (u *UIDTrackingControllerExpectations) GetUIDs(controllerKey string) sets.String { if uid, exists, err := u.uidStore.GetByKey(controllerKey); err == nil && exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
test/abi/bad_select_crash.go
if FailCount != 0 { fmt.Fprintf(os.Stderr, "FAILURES: %d\n", FailCount) os.Exit(2) } } var ParamFailCount int var ReturnFailCount int var FailCount int var Mode string type UtilsType int //go:noinline func NoteFailure(cm int, pidx int, fidx int, pkg string, pref string, parmNo int, isret bool, _ uint64) { if isret { if ParamFailCount != 0 { return } ReturnFailCount++ } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 16 13:38:02 UTC 2021 - 5.7K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
fakeClock := testingclock.NewFakeClock(fakeTime) ttlPolicy := &cache.TTLPolicy{TTL: ttl, Clock: fakeClock} ttlStore := cache.NewFakeExpirationStore( ExpKeyFunc, nil, ttlPolicy, fakeClock) return &ControllerExpectations{ttlStore}, fakeClock } func newReplicationController(replicas int) *v1.ReplicationController { rc := &v1.ReplicationController{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0)