// Code generated by goctl. DO NOT EDIT. // Source: mira_ida_access_service.proto package miraidaaccess import ( "chainweaver.org.cn/chainweaver/ida/chain-service/v2/pb/chainpb" "chainweaver.org.cn/chainweaver/ida/key-service/v2/pb/keypb" "chainweaver.org.cn/chainweaver/ida/registration-service/v2/pb/registrationpb" "chainweaver.org.cn/chainweaver/mira/mira-ida-access-service/pb" "github.com/zeromicro/go-zero/zrpc" "google.golang.org/grpc" "context" ) type ( CallContractRequest = pb.CallContractRequest ChainDataInfo = pb.ChainDataInfo ContractRequest = pb.ContractRequest ContractResponse = pb.ContractResponse GetDataFromKeyReq = pb.GetDataFromKeyReq MiraIdaAccess interface { // 创建job CreateJob(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 创建job审批 CreateJobApprove(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取job列表 GetJobList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取job GetJob(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取job审批列表 GetJobApproveList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取审批详情 GetJobApprove(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取job状态 SetJobStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 创建job实例 CreateJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 设置job实例状态为ready SetJobInstanceStatusReady(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 设置task参与方的信息 SetTaskPartyInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 设置task状态 SetTaskStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 更新job实例 UpdateJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取job实例信息 GetJobInstanceInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取job实例详情 GetJobInstanceDetail(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 取消job实例 CancelJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 更新service状态 UpdateServiceStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 设置task输出 SetTaskOutput(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 更新job实例失败原因 UpdateJobInstanceFailedReason(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取计算资源列表 GetComputingResourceAll(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 创建计算资源 CreateComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 根据partyId获取计算资源 GetComputingResourceByPartyId(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取计算资源 GetComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 重新发布计算资源 RepublishComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 删除计算资源 DeleteComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 创建计算模型 CreateComputingModel(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取计算模型列表 GetComputingModelList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取计算模型 GetComputingModel(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取服务详情 QueryServiceDetails(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取task详情 QueryTaskDetails(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 设置执行结果的服务地址 SetResultServerAddr(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 获取执行结果的服务地址 GetResultServerAddr(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 更新job实例触发器状态 UpdateJobTriggerEnable(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 设置任务失败 SetTaskFailed(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 更新任务信息 UpdateTaskInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) CallContract(ctx context.Context, in *CallContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) // 根据key查找数据 GetDataFromKey(ctx context.Context, in *GetDataFromKeyReq, opts ...grpc.CallOption) (*ContractResponse, error) GetPlatformInfo(ctx context.Context, in *chainpb.GetPlatformInfoRequest, opts ...grpc.CallOption) (*chainpb.PlatformDataResponse, error) ListChainInfo(ctx context.Context, in *chainpb.ListChainInfoRequest, opts ...grpc.CallOption) (*chainpb.ListChainInfoResponse, error) GetPrivateDBConnInfo(ctx context.Context, in *registrationpb.GetPrivateDBConnInfoReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateDBConnInfoResp, error) // 2. 获取链上资产列表 GetPrivateAssetList(ctx context.Context, in *registrationpb.GetPrivateAssetListReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetListResp, error) // 3. 获取链上资产详情 GetPrivateAssetInfo(ctx context.Context, in *registrationpb.GetPrivateAssetInfoReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetInfoResp, error) // 4. 通过资产英文名称获取资产详情 GetPrivateAssetInfoByEnName(ctx context.Context, in *registrationpb.GetPrivateAssetInfoByEnNameReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetInfoByEnNameResp, error) // 5. 分组获取企业列表和资产对应关系 GetPrivateEnterpriseAsset(ctx context.Context, in *registrationpb.GetPrivateEnterpriseAssetReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateEnterpriseAssetResp, error) // 6. 根据平台id获取平台的公钥 GetPrivatePlatformPK(ctx context.Context, in *registrationpb.GetPrivatePlatformPKReq, opts ...grpc.CallOption) (*registrationpb.GetPrivatePlatformPKResp, error) CreateKey(ctx context.Context, in *keypb.KeyCreateRequest, opts ...grpc.CallOption) (*keypb.KeyCreateResponse, error) // keypb Encrypt(ctx context.Context, in *keypb.KeyEncryptRequest, opts ...grpc.CallOption) (*keypb.KeyEncryptResponse, error) // 传入多个公钥,对同一个明文加密 EncryptWithPkList(ctx context.Context, in *keypb.KeyEncryptWithPkListRequest, opts ...grpc.CallOption) (*keypb.KeyEncryptWithPkListResponse, error) // 解密 Decrypt(ctx context.Context, in *keypb.KeyDecryptRequest, opts ...grpc.CallOption) (*keypb.KeyDecryptResponse, error) // 数字信封加密 EncWithDeK(ctx context.Context, in *keypb.DataEnvelopeEncryptRequest, opts ...grpc.CallOption) (*keypb.DataEnvelopeEncryptResponse, error) // 数字信封解密 DecByKeK(ctx context.Context, in *keypb.DataEnvelopeDecryptRequest, opts ...grpc.CallOption) (*keypb.KeyDecryptResponse, error) // 数字信封传入多个公钥,对同一个明文加密 EncWithDeKWithPkList(ctx context.Context, in *keypb.DataEnvelopeEncryptWithPkListRequest, opts ...grpc.CallOption) (*keypb.DataEnvelopeEncryptWithPkListResponse, error) // 根据公钥获取私钥 GetSkFromPk(ctx context.Context, in *keypb.GetSkRequest, opts ...grpc.CallOption) (*keypb.GetSkResponse, error) // 根据 keyId 获取私钥 GetSkFromKeyId(ctx context.Context, in *keypb.GetSkFromKeyIdRequest, opts ...grpc.CallOption) (*keypb.GetSkResponse, error) } defaultMiraIdaAccess struct { cli zrpc.Client } ) func NewMiraIdaAccess(cli zrpc.Client) MiraIdaAccess { return &defaultMiraIdaAccess{ cli: cli, } } // 创建job func (m *defaultMiraIdaAccess) CreateJob(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CreateJob(ctx, in, opts...) } // 创建job审批 func (m *defaultMiraIdaAccess) CreateJobApprove(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CreateJobApprove(ctx, in, opts...) } // 获取job列表 func (m *defaultMiraIdaAccess) GetJobList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetJobList(ctx, in, opts...) } // 获取job func (m *defaultMiraIdaAccess) GetJob(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetJob(ctx, in, opts...) } // 获取job审批列表 func (m *defaultMiraIdaAccess) GetJobApproveList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetJobApproveList(ctx, in, opts...) } // 获取审批详情 func (m *defaultMiraIdaAccess) GetJobApprove(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetJobApprove(ctx, in, opts...) } // 获取job状态 func (m *defaultMiraIdaAccess) SetJobStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetJobStatus(ctx, in, opts...) } // 创建job实例 func (m *defaultMiraIdaAccess) CreateJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CreateJobInstance(ctx, in, opts...) } // 设置job实例状态为ready func (m *defaultMiraIdaAccess) SetJobInstanceStatusReady(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetJobInstanceStatusReady(ctx, in, opts...) } // 设置task参与方的信息 func (m *defaultMiraIdaAccess) SetTaskPartyInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetTaskPartyInfo(ctx, in, opts...) } // 设置task状态 func (m *defaultMiraIdaAccess) SetTaskStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetTaskStatus(ctx, in, opts...) } // 更新job实例 func (m *defaultMiraIdaAccess) UpdateJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.UpdateJobInstance(ctx, in, opts...) } // 获取job实例信息 func (m *defaultMiraIdaAccess) GetJobInstanceInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetJobInstanceInfo(ctx, in, opts...) } // 获取job实例详情 func (m *defaultMiraIdaAccess) GetJobInstanceDetail(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetJobInstanceDetail(ctx, in, opts...) } // 取消job实例 func (m *defaultMiraIdaAccess) CancelJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CancelJobInstance(ctx, in, opts...) } // 更新service状态 func (m *defaultMiraIdaAccess) UpdateServiceStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.UpdateServiceStatus(ctx, in, opts...) } // 设置task输出 func (m *defaultMiraIdaAccess) SetTaskOutput(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetTaskOutput(ctx, in, opts...) } // 更新job实例失败原因 func (m *defaultMiraIdaAccess) UpdateJobInstanceFailedReason(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.UpdateJobInstanceFailedReason(ctx, in, opts...) } // 获取计算资源列表 func (m *defaultMiraIdaAccess) GetComputingResourceAll(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetComputingResourceAll(ctx, in, opts...) } // 创建计算资源 func (m *defaultMiraIdaAccess) CreateComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CreateComputingResource(ctx, in, opts...) } // 根据partyId获取计算资源 func (m *defaultMiraIdaAccess) GetComputingResourceByPartyId(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetComputingResourceByPartyId(ctx, in, opts...) } // 获取计算资源 func (m *defaultMiraIdaAccess) GetComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetComputingResource(ctx, in, opts...) } // 重新发布计算资源 func (m *defaultMiraIdaAccess) RepublishComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.RepublishComputingResource(ctx, in, opts...) } // 删除计算资源 func (m *defaultMiraIdaAccess) DeleteComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.DeleteComputingResource(ctx, in, opts...) } // 创建计算模型 func (m *defaultMiraIdaAccess) CreateComputingModel(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CreateComputingModel(ctx, in, opts...) } // 获取计算模型列表 func (m *defaultMiraIdaAccess) GetComputingModelList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetComputingModelList(ctx, in, opts...) } // 获取计算模型 func (m *defaultMiraIdaAccess) GetComputingModel(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetComputingModel(ctx, in, opts...) } // 获取服务详情 func (m *defaultMiraIdaAccess) QueryServiceDetails(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.QueryServiceDetails(ctx, in, opts...) } // 获取task详情 func (m *defaultMiraIdaAccess) QueryTaskDetails(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.QueryTaskDetails(ctx, in, opts...) } // 设置执行结果的服务地址 func (m *defaultMiraIdaAccess) SetResultServerAddr(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetResultServerAddr(ctx, in, opts...) } // 获取执行结果的服务地址 func (m *defaultMiraIdaAccess) GetResultServerAddr(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetResultServerAddr(ctx, in, opts...) } // 更新job实例触发器状态 func (m *defaultMiraIdaAccess) UpdateJobTriggerEnable(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.UpdateJobTriggerEnable(ctx, in, opts...) } // 设置任务失败 func (m *defaultMiraIdaAccess) SetTaskFailed(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.SetTaskFailed(ctx, in, opts...) } // 更新任务信息 func (m *defaultMiraIdaAccess) UpdateTaskInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.UpdateTaskInfo(ctx, in, opts...) } func (m *defaultMiraIdaAccess) CallContract(ctx context.Context, in *CallContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CallContract(ctx, in, opts...) } // 根据key查找数据 func (m *defaultMiraIdaAccess) GetDataFromKey(ctx context.Context, in *GetDataFromKeyReq, opts ...grpc.CallOption) (*ContractResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetDataFromKey(ctx, in, opts...) } func (m *defaultMiraIdaAccess) GetPlatformInfo(ctx context.Context, in *chainpb.GetPlatformInfoRequest, opts ...grpc.CallOption) (*chainpb.PlatformDataResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPlatformInfo(ctx, in, opts...) } func (m *defaultMiraIdaAccess) ListChainInfo(ctx context.Context, in *chainpb.ListChainInfoRequest, opts ...grpc.CallOption) (*chainpb.ListChainInfoResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.ListChainInfo(ctx, in, opts...) } func (m *defaultMiraIdaAccess) GetPrivateDBConnInfo(ctx context.Context, in *registrationpb.GetPrivateDBConnInfoReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateDBConnInfoResp, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPrivateDBConnInfo(ctx, in, opts...) } // 2. 获取链上资产列表 func (m *defaultMiraIdaAccess) GetPrivateAssetList(ctx context.Context, in *registrationpb.GetPrivateAssetListReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetListResp, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPrivateAssetList(ctx, in, opts...) } // 3. 获取链上资产详情 func (m *defaultMiraIdaAccess) GetPrivateAssetInfo(ctx context.Context, in *registrationpb.GetPrivateAssetInfoReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetInfoResp, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPrivateAssetInfo(ctx, in, opts...) } // 4. 通过资产英文名称获取资产详情 func (m *defaultMiraIdaAccess) GetPrivateAssetInfoByEnName(ctx context.Context, in *registrationpb.GetPrivateAssetInfoByEnNameReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetInfoByEnNameResp, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPrivateAssetInfoByEnName(ctx, in, opts...) } // 5. 分组获取企业列表和资产对应关系 func (m *defaultMiraIdaAccess) GetPrivateEnterpriseAsset(ctx context.Context, in *registrationpb.GetPrivateEnterpriseAssetReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateEnterpriseAssetResp, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPrivateEnterpriseAsset(ctx, in, opts...) } // 6. 根据平台id获取平台的公钥 func (m *defaultMiraIdaAccess) GetPrivatePlatformPK(ctx context.Context, in *registrationpb.GetPrivatePlatformPKReq, opts ...grpc.CallOption) (*registrationpb.GetPrivatePlatformPKResp, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetPrivatePlatformPK(ctx, in, opts...) } func (m *defaultMiraIdaAccess) CreateKey(ctx context.Context, in *keypb.KeyCreateRequest, opts ...grpc.CallOption) (*keypb.KeyCreateResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.CreateKey(ctx, in, opts...) } // 加密 func (m *defaultMiraIdaAccess) Encrypt(ctx context.Context, in *keypb.KeyEncryptRequest, opts ...grpc.CallOption) (*keypb.KeyEncryptResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.Encrypt(ctx, in, opts...) } // 传入多个公钥,对同一个明文加密 func (m *defaultMiraIdaAccess) EncryptWithPkList(ctx context.Context, in *keypb.KeyEncryptWithPkListRequest, opts ...grpc.CallOption) (*keypb.KeyEncryptWithPkListResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.EncryptWithPkList(ctx, in, opts...) } // 解密 func (m *defaultMiraIdaAccess) Decrypt(ctx context.Context, in *keypb.KeyDecryptRequest, opts ...grpc.CallOption) (*keypb.KeyDecryptResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.Decrypt(ctx, in, opts...) } // 数字信封加密 func (m *defaultMiraIdaAccess) EncWithDeK(ctx context.Context, in *keypb.DataEnvelopeEncryptRequest, opts ...grpc.CallOption) (*keypb.DataEnvelopeEncryptResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.EncWithDeK(ctx, in, opts...) } // 数字信封解密 func (m *defaultMiraIdaAccess) DecByKeK(ctx context.Context, in *keypb.DataEnvelopeDecryptRequest, opts ...grpc.CallOption) (*keypb.KeyDecryptResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.DecByKeK(ctx, in, opts...) } // 数字信封传入多个公钥,对同一个明文加密 func (m *defaultMiraIdaAccess) EncWithDeKWithPkList(ctx context.Context, in *keypb.DataEnvelopeEncryptWithPkListRequest, opts ...grpc.CallOption) (*keypb.DataEnvelopeEncryptWithPkListResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.EncWithDeKWithPkList(ctx, in, opts...) } // 根据公钥获取私钥 func (m *defaultMiraIdaAccess) GetSkFromPk(ctx context.Context, in *keypb.GetSkRequest, opts ...grpc.CallOption) (*keypb.GetSkResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetSkFromPk(ctx, in, opts...) } // 根据 keyId 获取私钥 func (m *defaultMiraIdaAccess) GetSkFromKeyId(ctx context.Context, in *keypb.GetSkFromKeyIdRequest, opts ...grpc.CallOption) (*keypb.GetSkResponse, error) { client := pb.NewMiraIdaAccessClient(m.cli.Conn()) return client.GetSkFromKeyId(ctx, in, opts...) }