- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for TransformFromStorage (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/identity/identity.go
// that the data is not encrypted data during TransformFromStorage type identityTransformer struct{} // NewEncryptCheckTransformer returns an identityTransformer which returns an error // on attempts to read encrypted data func NewEncryptCheckTransformer() value.Transformer { return transformer } // TransformFromStorage returns the input bytes if the data is not encrypted
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 13 14:52:29 UTC 2022 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/secretbox/secretbox_test.go
} from, stale, err := p.TransformFromStorage(ctx, out, dataCtx) if err != nil { t.Fatal(err) } if stale || !bytes.Equal([]byte("firstvalue"), from) { t.Fatalf("unexpected data: %t %q", stale, from) } // verify changing the context does not fails storage // Secretbox is not currently an authenticating store _, _, err = p.TransformFromStorage(ctx, out, value.DefaultContext([]byte("incorrect_context")))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 17 16:31:31 UTC 2022 - 6.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/transformer.go
AuthenticatedData() []byte } type Read interface { // TransformFromStorage may transform the provided data from its underlying storage representation or return an error. // Stale is true if the object on disk is stale and a write to etcd should be issued, even if the contents of the object // have not changed. TransformFromStorage(ctx context.Context, data []byte, dataCtx Context) (out []byte, stale bool, err error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 22:44:02 UTC 2023 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/aes_test.go
t.Fatalf("unexpected prefix: %q", out) } from, stale, err := p.TransformFromStorage(ctx, out, dataCtx) if err != nil { t.Fatal(err) } if stale || !bytes.Equal([]byte("firstvalue"), from) { t.Fatalf("unexpected data: %t %q", stale, from) } // verify changing the context fails storage _, _, err = p.TransformFromStorage(ctx, out, value.DefaultContext("incorrect_context")) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 23.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/envelope_test.go
if err != nil { t.Fatalf("envelopeTransformer: error while transforming data to storage: %s", err) } untransformedData, _, err := envelopeTransformer.TransformFromStorage(ctx, transformedData, dataCtx) if err != nil { t.Fatalf("could not decrypt Envelope transformer's encrypted data even once: %v", err) } if !bytes.Equal(untransformedData, originalText) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 14:23:50 UTC 2023 - 10.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/aes_extended_nonce.go
info []byte } func (t *transformerWithInfo) TransformFromStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, bool, error) { if !bytes.HasPrefix(data, t.info) { return nil, false, errors.New("the stored data is missing the required info prefix") } return t.transformer.TransformFromStorage(ctx, data[len(t.info):], dataCtx) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 6.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go
nextObject func(uint32) (string, *example.Pod) } func (rt *reproducingTransformer) TransformFromStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, bool, error) { if err := rt.createObject(ctx); err != nil { return nil, false, err } return rt.wrapped.TransformFromStorage(ctx, data, dataCtx) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 07:26:55 UTC 2024 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/envelope_test.go
if err != nil { t.Fatalf("envelopeTransformer: error while transforming data to storage: %s", err) } if _, _, err := transformer.TransformFromStorage(ctx, transformedData1, dataCtx); err != nil { t.Fatal(err) } if _, _, err := transformer.TransformFromStorage(ctx, transformedData2, dataCtx); err != nil { t.Fatal(err) } } func TestGenerateCacheKey(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 25 16:50:20 UTC 2023 - 47.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/envelope.go
baseTransformerFunc: baseTransformerFunc, cacheEnabled: cacheSize > 0, cacheSize: cacheSize, } } // TransformFromStorage decrypts data encrypted by this transformer using envelope encryption. func (t *envelopeTransformer) TransformFromStorage(ctx context.Context, data []byte, dataCtx value.Context) ([]byte, bool, error) { metrics.RecordArrival(metrics.FromStorageLabel, time.Now())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 14:23:50 UTC 2023 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/transformer_test.go
) type testTransformer struct { from, to []byte err error stale bool receivedFrom, receivedTo []byte } func (t *testTransformer) TransformFromStorage(ctx context.Context, data []byte, dataCtx Context) (out []byte, stale bool, err error) { t.receivedFrom = data return t.from, t.stale, t.err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 22:44:02 UTC 2023 - 12.8K bytes - Viewed (0)