Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for TransformFromStorage (0.29 sec)

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