in pkg/plugin/server.go [64:88]
func (s *KeyManagementServiceServer) Encrypt(ctx context.Context, request *kmsv1.EncryptRequest) (*kmsv1.EncryptResponse, error) {
start := time.Now()
var err error
defer func() {
errors := ""
status := metrics.SuccessStatusTypeValue
if err != nil {
status = metrics.ErrorStatusTypeValue
errors = err.Error()
}
s.reporter.ReportRequest(ctx, metrics.EncryptOperationTypeValue, status, time.Since(start).Seconds(), errors)
}()
mlog.Info("encrypt request started")
encryptResponse, err := s.kvClient.Encrypt(ctx, request.Plain, s.encryptionAlgorithm)
if err != nil {
mlog.Error("failed to encrypt", err)
return &kmsv1.EncryptResponse{}, err
}
mlog.Info("encrypt request complete")
return &kmsv1.EncryptResponse{
Cipher: encryptResponse.Ciphertext,
}, nil
}