Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for NewPrefixTransformer (0.25 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go

    // PrefixTransformer adds and verifies that all data has the correct prefix on its way in and out.
    type PrefixTransformer struct {
    	prefix []byte
    	stale  bool
    	err    error
    	reads  uint64
    }
    
    func NewPrefixTransformer(prefix []byte, stale bool) *PrefixTransformer {
    	return &PrefixTransformer{
    		prefix: prefix,
    		stale:  stale,
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 22 07:26:55 UTC 2024
    - 10.3K bytes
    - Viewed (1)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	// for testing purposes. See wait.ForeverTestTimeout
    	cfg.ReuseDurationSeconds = 1
    	return cfg
    }
    
    func newTestTransformer() value.Transformer {
    	return storagetesting.NewPrefixTransformer([]byte(defaultTestPrefix), false)
    }
    
    type clientRecorder struct {
    	reads uint64
    	clientv3.KV
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    		}
    	}
    
    	// create a second resource with an invalid prefix
    	revertTransformer := store.UpdatePrefixTransformer(
    		func(transformer *PrefixTransformer) value.Transformer {
    			return NewPrefixTransformer([]byte("otherprefix!"), false)
    		})
    	for i, ps := range preset[1:] {
    		preset[1:][i].storedObj = &example.Pod{}
    		err := store.Create(ctx, ps.key, ps.obj, preset[1:][i].storedObj, 0)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
Back to top