Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for utilstore (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top