- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewPrefixTransformer (0.25 sec)
-
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) -
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) -
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)