- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewGRPCService (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
func TestKMSPluginLateStart(t *testing.T) { t.Parallel() callTimeout := 3 * time.Second s := newEndpoint() ctx := testContext(t) service, err := NewGRPCService(ctx, s.endpoint, testProviderName, callTimeout) if err != nil { t.Fatalf("failed to create envelope service, error: %v", err) } defer destroyService(service) time.Sleep(callTimeout / 2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
ctx := testContext(t) s, err := NewGRPCService(ctx, endpoint.endpoint, 1*time.Second) if err != nil { t.Fatal(err) } defer destroyService(s) // Encrypt _, err = s.Encrypt(data) if err == nil || err.Error() != wantErr.Error() { t.Errorf("got err: %ver, want: %ver", err, wantErr) } destroyService(s) s, err = NewGRPCService(ctx, endpoint.endpoint, 1*time.Second) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
return result, nil } var ( // The factory to create kms service. This is to make writing test easier. envelopeServiceFactory = envelope.NewGRPCService // The factory to create kmsv2 service. Exported for integration tests. EnvelopeKMSv2ServiceFactory = envelopekmsv2.NewGRPCService ) type kmsState struct { v1Used, v2Used bool kmsTimeoutSum time.Duration } // accumulate computes the KMS state by:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0)