- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for kmsservice (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
result, err := service.Decrypt(ctx, uid, &kmsservice.DecryptRequest{Ciphertext: resp.Ciphertext, KeyID: keyID}) if err != nil { t.Errorf("failed when execute decrypt, error: %v", err) } if !reflect.DeepEqual(data, result) { t.Errorf("expect: %v, but: %v", data, result) } }() } wg.Wait() } func destroyService(service kmsservice.Service) { if service != nil {
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/kmsv2/envelope_test.go
} return &kmsservice.EncryptResponse{Ciphertext: ciphertext, KeyID: t.keyVersion, Annotations: annotations}, nil } func (t *testEnvelopeService) Status(ctx context.Context) (*kmsservice.StatusResponse, error) { if t.disabled { return nil, fmt.Errorf("Envelope service was disabled") } return &kmsservice.StatusResponse{KeyID: t.keyVersion}, nil }
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/kmsv2/envelope.go
// the data items they encrypt. func NewEnvelopeTransformer(envelopeService kmsservice.Service, providerName string, stateFunc StateFunc, apiServerID string) value.Transformer { return newEnvelopeTransformerWithClock(envelopeService, providerName, stateFunc, apiServerID, cacheTTL, clock.RealClock{}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 00:23:50 UTC 2023 - 18.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
"k8s.io/apiserver/pkg/storage/value/encrypt/identity" "k8s.io/apiserver/pkg/storage/value/encrypt/secretbox" utilfeature "k8s.io/apiserver/pkg/util/feature" "k8s.io/klog/v2" kmsservice "k8s.io/kms/pkg/service" ) const ( aesCBCTransformerPrefixV1 = "k8s:enc:aescbc:v1:" aesGCMTransformerPrefixV1 = "k8s:enc:aesgcm:v1:" secretboxTransformerPrefixV1 = "k8s:enc:secretbox:v1:"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
) var sdsServiceLog = log.RegisterScope("sds", "SDS service debugging") type sdsservice struct { st security.SecretManager stop chan struct{} rootCaPath string pkpConf *mesh.PrivateKeyProvider sync.Mutex clients map[string]*Context } type Context struct { BaseConnection xds.Connection s *sdsservice w *Watch } type Watch struct { sync.Mutex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
for _, se := range c.exports.ExportedServices() { mcsService := outMap[se.namespacedName] mcsService.Cluster = c.Cluster() mcsService.Name = se.namespacedName.Name mcsService.Namespace = se.namespacedName.Namespace mcsService.Exported = true mcsService.Discoverability = se.discoverability outMap[se.namespacedName] = mcsService } // Add the ServiceImport info.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
mcsService = ic.genMCSService(realService, mcsHost, ips) } else { if event == model.EventDelete || len(ips) == 0 { ic.deleteService(mcsService) return nil } // The service already existed. Treat it as an update. event = model.EventUpdate mcsService = mcsService.DeepCopy() if ic.updateIPs(mcsService, ips) { needsFullPush = true } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/dns/dns_test.go
DNSIP: "10.233.0.3", }) type args struct { dnsService *v1.Service serviceBytes []byte } tests := []struct { name string args args wantErr bool }{ { name: "dnsService and serviceBytes are nil", args: args{ dnsService: nil, serviceBytes: nil, }, wantErr: true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 41.7K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/dns/dns.go
} coreDNSService := &v1.Service{} return createDNSService(coreDNSService, serviceBytes, client) } func createDNSService(dnsService *v1.Service, serviceBytes []byte, client clientset.Interface) error { if err := kuberuntime.DecodeInto(clientsetscheme.Codecs.UniversalDecoder(), serviceBytes, dnsService); err != nil { return errors.Wrap(err, "unable to decode the DNS service") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 16.1K bytes - Viewed (0) -
pkg/istio-agent/agent.go
const ( DrainLifecycleEvent LifecycleEvent = "drain" ExitLifecycleEvent LifecycleEvent = "exit" ) type SDSService interface { OnSecretUpdate(resourceName string) Stop() } type SDSServiceFactory = func(_ *security.Options, _ security.SecretManager, _ *mesh.PrivateKeyProvider) SDSService // Shared properties with Pilot Proxy struct. type Proxy struct { ID string IPAddresses []string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 26.7K bytes - Viewed (0)