// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc v4.25.3 // source: proto/mira_ida_access_service.proto package pb 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" context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 // MiraIdaAccessClient is the client API for MiraIdaAccess service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type MiraIdaAccessClient 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) // ///////////////////////// // /////chain-service/////// // //////////////////////// // retrieve platform info 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) // ///////////////////////// // /////registration-service/////// // //////////////////////// // 1. 获取包含隐私信息的数据源连接信息接口 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) // ///////////////////////// // //////key-service//////// // //////////////////////// // 生成密钥 CreateKey(ctx context.Context, in *keypb.KeyCreateRequest, opts ...grpc.CallOption) (*keypb.KeyCreateResponse, error) // 加密 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) } type miraIdaAccessClient struct { cc grpc.ClientConnInterface } func NewMiraIdaAccessClient(cc grpc.ClientConnInterface) MiraIdaAccessClient { return &miraIdaAccessClient{cc} } func (c *miraIdaAccessClient) CreateJob(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CreateJob", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CreateJobApprove(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CreateJobApprove", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetJobList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetJobList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetJob(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetJob", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetJobApproveList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetJobApproveList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetJobApprove(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetJobApprove", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetJobStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetJobStatus", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CreateJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CreateJobInstance", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetJobInstanceStatusReady(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetJobInstanceStatusReady", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetTaskPartyInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetTaskPartyInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetTaskStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetTaskStatus", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) UpdateJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/UpdateJobInstance", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetJobInstanceInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetJobInstanceInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetJobInstanceDetail(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetJobInstanceDetail", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CancelJobInstance(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CancelJobInstance", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) UpdateServiceStatus(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/UpdateServiceStatus", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetTaskOutput(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetTaskOutput", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) UpdateJobInstanceFailedReason(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/UpdateJobInstanceFailedReason", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetComputingResourceAll(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetComputingResourceAll", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CreateComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CreateComputingResource", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetComputingResourceByPartyId(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetComputingResourceByPartyId", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetComputingResource", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) RepublishComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/RepublishComputingResource", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) DeleteComputingResource(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/DeleteComputingResource", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CreateComputingModel(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CreateComputingModel", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetComputingModelList(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetComputingModelList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetComputingModel(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetComputingModel", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) QueryServiceDetails(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/QueryServiceDetails", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) QueryTaskDetails(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/QueryTaskDetails", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetResultServerAddr(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetResultServerAddr", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetResultServerAddr(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetResultServerAddr", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) UpdateJobTriggerEnable(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/UpdateJobTriggerEnable", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) SetTaskFailed(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/SetTaskFailed", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) UpdateTaskInfo(ctx context.Context, in *ContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/UpdateTaskInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CallContract(ctx context.Context, in *CallContractRequest, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CallContract", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetDataFromKey(ctx context.Context, in *GetDataFromKeyReq, opts ...grpc.CallOption) (*ContractResponse, error) { out := new(ContractResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetDataFromKey", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPlatformInfo(ctx context.Context, in *chainpb.GetPlatformInfoRequest, opts ...grpc.CallOption) (*chainpb.PlatformDataResponse, error) { out := new(chainpb.PlatformDataResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPlatformInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) ListChainInfo(ctx context.Context, in *chainpb.ListChainInfoRequest, opts ...grpc.CallOption) (*chainpb.ListChainInfoResponse, error) { out := new(chainpb.ListChainInfoResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/ListChainInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPrivateDBConnInfo(ctx context.Context, in *registrationpb.GetPrivateDBConnInfoReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateDBConnInfoResp, error) { out := new(registrationpb.GetPrivateDBConnInfoResp) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPrivateDBConnInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPrivateAssetList(ctx context.Context, in *registrationpb.GetPrivateAssetListReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetListResp, error) { out := new(registrationpb.GetPrivateAssetListResp) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPrivateAssetList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPrivateAssetInfo(ctx context.Context, in *registrationpb.GetPrivateAssetInfoReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetInfoResp, error) { out := new(registrationpb.GetPrivateAssetInfoResp) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPrivateAssetInfo", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPrivateAssetInfoByEnName(ctx context.Context, in *registrationpb.GetPrivateAssetInfoByEnNameReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateAssetInfoByEnNameResp, error) { out := new(registrationpb.GetPrivateAssetInfoByEnNameResp) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPrivateAssetInfoByEnName", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPrivateEnterpriseAsset(ctx context.Context, in *registrationpb.GetPrivateEnterpriseAssetReq, opts ...grpc.CallOption) (*registrationpb.GetPrivateEnterpriseAssetResp, error) { out := new(registrationpb.GetPrivateEnterpriseAssetResp) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPrivateEnterpriseAsset", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetPrivatePlatformPK(ctx context.Context, in *registrationpb.GetPrivatePlatformPKReq, opts ...grpc.CallOption) (*registrationpb.GetPrivatePlatformPKResp, error) { out := new(registrationpb.GetPrivatePlatformPKResp) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetPrivatePlatformPK", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) CreateKey(ctx context.Context, in *keypb.KeyCreateRequest, opts ...grpc.CallOption) (*keypb.KeyCreateResponse, error) { out := new(keypb.KeyCreateResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/CreateKey", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) Encrypt(ctx context.Context, in *keypb.KeyEncryptRequest, opts ...grpc.CallOption) (*keypb.KeyEncryptResponse, error) { out := new(keypb.KeyEncryptResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/Encrypt", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) EncryptWithPkList(ctx context.Context, in *keypb.KeyEncryptWithPkListRequest, opts ...grpc.CallOption) (*keypb.KeyEncryptWithPkListResponse, error) { out := new(keypb.KeyEncryptWithPkListResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/EncryptWithPkList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) Decrypt(ctx context.Context, in *keypb.KeyDecryptRequest, opts ...grpc.CallOption) (*keypb.KeyDecryptResponse, error) { out := new(keypb.KeyDecryptResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/Decrypt", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) EncWithDeK(ctx context.Context, in *keypb.DataEnvelopeEncryptRequest, opts ...grpc.CallOption) (*keypb.DataEnvelopeEncryptResponse, error) { out := new(keypb.DataEnvelopeEncryptResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/EncWithDeK", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) DecByKeK(ctx context.Context, in *keypb.DataEnvelopeDecryptRequest, opts ...grpc.CallOption) (*keypb.KeyDecryptResponse, error) { out := new(keypb.KeyDecryptResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/DecByKeK", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) EncWithDeKWithPkList(ctx context.Context, in *keypb.DataEnvelopeEncryptWithPkListRequest, opts ...grpc.CallOption) (*keypb.DataEnvelopeEncryptWithPkListResponse, error) { out := new(keypb.DataEnvelopeEncryptWithPkListResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/EncWithDeKWithPkList", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetSkFromPk(ctx context.Context, in *keypb.GetSkRequest, opts ...grpc.CallOption) (*keypb.GetSkResponse, error) { out := new(keypb.GetSkResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetSkFromPk", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *miraIdaAccessClient) GetSkFromKeyId(ctx context.Context, in *keypb.GetSkFromKeyIdRequest, opts ...grpc.CallOption) (*keypb.GetSkResponse, error) { out := new(keypb.GetSkResponse) err := c.cc.Invoke(ctx, "/proto.MiraIdaAccess/GetSkFromKeyId", in, out, opts...) if err != nil { return nil, err } return out, nil } // MiraIdaAccessServer is the server API for MiraIdaAccess service. // All implementations must embed UnimplementedMiraIdaAccessServer // for forward compatibility type MiraIdaAccessServer interface { // 创建job CreateJob(context.Context, *ContractRequest) (*ContractResponse, error) // 创建job审批 CreateJobApprove(context.Context, *ContractRequest) (*ContractResponse, error) // 获取job列表 GetJobList(context.Context, *ContractRequest) (*ContractResponse, error) // 获取job GetJob(context.Context, *ContractRequest) (*ContractResponse, error) // 获取job审批列表 GetJobApproveList(context.Context, *ContractRequest) (*ContractResponse, error) // 获取审批详情 GetJobApprove(context.Context, *ContractRequest) (*ContractResponse, error) // 获取job状态 SetJobStatus(context.Context, *ContractRequest) (*ContractResponse, error) // 创建job实例 CreateJobInstance(context.Context, *ContractRequest) (*ContractResponse, error) // 设置job实例状态为ready SetJobInstanceStatusReady(context.Context, *ContractRequest) (*ContractResponse, error) // 设置task参与方的信息 SetTaskPartyInfo(context.Context, *ContractRequest) (*ContractResponse, error) // 设置task状态 SetTaskStatus(context.Context, *ContractRequest) (*ContractResponse, error) // 更新job实例 UpdateJobInstance(context.Context, *ContractRequest) (*ContractResponse, error) // 获取job实例信息 GetJobInstanceInfo(context.Context, *ContractRequest) (*ContractResponse, error) // 获取job实例详情 GetJobInstanceDetail(context.Context, *ContractRequest) (*ContractResponse, error) // 取消job实例 CancelJobInstance(context.Context, *ContractRequest) (*ContractResponse, error) // 更新service状态 UpdateServiceStatus(context.Context, *ContractRequest) (*ContractResponse, error) // 设置task输出 SetTaskOutput(context.Context, *ContractRequest) (*ContractResponse, error) // 更新job实例失败原因 UpdateJobInstanceFailedReason(context.Context, *ContractRequest) (*ContractResponse, error) // 获取计算资源列表 GetComputingResourceAll(context.Context, *ContractRequest) (*ContractResponse, error) // 创建计算资源 CreateComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) // 根据partyId获取计算资源 GetComputingResourceByPartyId(context.Context, *ContractRequest) (*ContractResponse, error) // 获取计算资源 GetComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) // 重新发布计算资源 RepublishComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) // 删除计算资源 DeleteComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) // 创建计算模型 CreateComputingModel(context.Context, *ContractRequest) (*ContractResponse, error) // 获取计算模型列表 GetComputingModelList(context.Context, *ContractRequest) (*ContractResponse, error) // 获取计算模型 GetComputingModel(context.Context, *ContractRequest) (*ContractResponse, error) // 获取服务详情 QueryServiceDetails(context.Context, *ContractRequest) (*ContractResponse, error) // 获取task详情 QueryTaskDetails(context.Context, *ContractRequest) (*ContractResponse, error) // 设置执行结果的服务地址 SetResultServerAddr(context.Context, *ContractRequest) (*ContractResponse, error) // 获取执行结果的服务地址 GetResultServerAddr(context.Context, *ContractRequest) (*ContractResponse, error) // 更新job实例触发器状态 UpdateJobTriggerEnable(context.Context, *ContractRequest) (*ContractResponse, error) // 设置任务失败 SetTaskFailed(context.Context, *ContractRequest) (*ContractResponse, error) // 更新任务信息 UpdateTaskInfo(context.Context, *ContractRequest) (*ContractResponse, error) CallContract(context.Context, *CallContractRequest) (*ContractResponse, error) // 根据key查找数据 GetDataFromKey(context.Context, *GetDataFromKeyReq) (*ContractResponse, error) // ///////////////////////// // /////chain-service/////// // //////////////////////// // retrieve platform info GetPlatformInfo(context.Context, *chainpb.GetPlatformInfoRequest) (*chainpb.PlatformDataResponse, error) ListChainInfo(context.Context, *chainpb.ListChainInfoRequest) (*chainpb.ListChainInfoResponse, error) // ///////////////////////// // /////registration-service/////// // //////////////////////// // 1. 获取包含隐私信息的数据源连接信息接口 GetPrivateDBConnInfo(context.Context, *registrationpb.GetPrivateDBConnInfoReq) (*registrationpb.GetPrivateDBConnInfoResp, error) // 2. 获取链上资产列表 GetPrivateAssetList(context.Context, *registrationpb.GetPrivateAssetListReq) (*registrationpb.GetPrivateAssetListResp, error) // 3. 获取链上资产详情 GetPrivateAssetInfo(context.Context, *registrationpb.GetPrivateAssetInfoReq) (*registrationpb.GetPrivateAssetInfoResp, error) // 4. 通过资产英文名称获取资产详情 GetPrivateAssetInfoByEnName(context.Context, *registrationpb.GetPrivateAssetInfoByEnNameReq) (*registrationpb.GetPrivateAssetInfoByEnNameResp, error) // 5. 分组获取企业列表和资产对应关系 GetPrivateEnterpriseAsset(context.Context, *registrationpb.GetPrivateEnterpriseAssetReq) (*registrationpb.GetPrivateEnterpriseAssetResp, error) // 6. 根据平台id获取平台的公钥 GetPrivatePlatformPK(context.Context, *registrationpb.GetPrivatePlatformPKReq) (*registrationpb.GetPrivatePlatformPKResp, error) // ///////////////////////// // //////key-service//////// // //////////////////////// // 生成密钥 CreateKey(context.Context, *keypb.KeyCreateRequest) (*keypb.KeyCreateResponse, error) // 加密 Encrypt(context.Context, *keypb.KeyEncryptRequest) (*keypb.KeyEncryptResponse, error) // 传入多个公钥,对同一个明文加密 EncryptWithPkList(context.Context, *keypb.KeyEncryptWithPkListRequest) (*keypb.KeyEncryptWithPkListResponse, error) // 解密 Decrypt(context.Context, *keypb.KeyDecryptRequest) (*keypb.KeyDecryptResponse, error) // 数字信封加密 EncWithDeK(context.Context, *keypb.DataEnvelopeEncryptRequest) (*keypb.DataEnvelopeEncryptResponse, error) // 数字信封解密 DecByKeK(context.Context, *keypb.DataEnvelopeDecryptRequest) (*keypb.KeyDecryptResponse, error) // 数字信封传入多个公钥,对同一个明文加密 EncWithDeKWithPkList(context.Context, *keypb.DataEnvelopeEncryptWithPkListRequest) (*keypb.DataEnvelopeEncryptWithPkListResponse, error) // 根据公钥获取私钥 GetSkFromPk(context.Context, *keypb.GetSkRequest) (*keypb.GetSkResponse, error) // 根据 keyId 获取私钥 GetSkFromKeyId(context.Context, *keypb.GetSkFromKeyIdRequest) (*keypb.GetSkResponse, error) mustEmbedUnimplementedMiraIdaAccessServer() } // UnimplementedMiraIdaAccessServer must be embedded to have forward compatible implementations. type UnimplementedMiraIdaAccessServer struct { } func (UnimplementedMiraIdaAccessServer) CreateJob(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateJob not implemented") } func (UnimplementedMiraIdaAccessServer) CreateJobApprove(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateJobApprove not implemented") } func (UnimplementedMiraIdaAccessServer) GetJobList(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetJobList not implemented") } func (UnimplementedMiraIdaAccessServer) GetJob(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetJob not implemented") } func (UnimplementedMiraIdaAccessServer) GetJobApproveList(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetJobApproveList not implemented") } func (UnimplementedMiraIdaAccessServer) GetJobApprove(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetJobApprove not implemented") } func (UnimplementedMiraIdaAccessServer) SetJobStatus(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetJobStatus not implemented") } func (UnimplementedMiraIdaAccessServer) CreateJobInstance(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateJobInstance not implemented") } func (UnimplementedMiraIdaAccessServer) SetJobInstanceStatusReady(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetJobInstanceStatusReady not implemented") } func (UnimplementedMiraIdaAccessServer) SetTaskPartyInfo(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetTaskPartyInfo not implemented") } func (UnimplementedMiraIdaAccessServer) SetTaskStatus(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetTaskStatus not implemented") } func (UnimplementedMiraIdaAccessServer) UpdateJobInstance(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateJobInstance not implemented") } func (UnimplementedMiraIdaAccessServer) GetJobInstanceInfo(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetJobInstanceInfo not implemented") } func (UnimplementedMiraIdaAccessServer) GetJobInstanceDetail(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetJobInstanceDetail not implemented") } func (UnimplementedMiraIdaAccessServer) CancelJobInstance(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CancelJobInstance not implemented") } func (UnimplementedMiraIdaAccessServer) UpdateServiceStatus(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateServiceStatus not implemented") } func (UnimplementedMiraIdaAccessServer) SetTaskOutput(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetTaskOutput not implemented") } func (UnimplementedMiraIdaAccessServer) UpdateJobInstanceFailedReason(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateJobInstanceFailedReason not implemented") } func (UnimplementedMiraIdaAccessServer) GetComputingResourceAll(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetComputingResourceAll not implemented") } func (UnimplementedMiraIdaAccessServer) CreateComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateComputingResource not implemented") } func (UnimplementedMiraIdaAccessServer) GetComputingResourceByPartyId(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetComputingResourceByPartyId not implemented") } func (UnimplementedMiraIdaAccessServer) GetComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetComputingResource not implemented") } func (UnimplementedMiraIdaAccessServer) RepublishComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method RepublishComputingResource not implemented") } func (UnimplementedMiraIdaAccessServer) DeleteComputingResource(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteComputingResource not implemented") } func (UnimplementedMiraIdaAccessServer) CreateComputingModel(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateComputingModel not implemented") } func (UnimplementedMiraIdaAccessServer) GetComputingModelList(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetComputingModelList not implemented") } func (UnimplementedMiraIdaAccessServer) GetComputingModel(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetComputingModel not implemented") } func (UnimplementedMiraIdaAccessServer) QueryServiceDetails(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method QueryServiceDetails not implemented") } func (UnimplementedMiraIdaAccessServer) QueryTaskDetails(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method QueryTaskDetails not implemented") } func (UnimplementedMiraIdaAccessServer) SetResultServerAddr(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetResultServerAddr not implemented") } func (UnimplementedMiraIdaAccessServer) GetResultServerAddr(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetResultServerAddr not implemented") } func (UnimplementedMiraIdaAccessServer) UpdateJobTriggerEnable(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateJobTriggerEnable not implemented") } func (UnimplementedMiraIdaAccessServer) SetTaskFailed(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method SetTaskFailed not implemented") } func (UnimplementedMiraIdaAccessServer) UpdateTaskInfo(context.Context, *ContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateTaskInfo not implemented") } func (UnimplementedMiraIdaAccessServer) CallContract(context.Context, *CallContractRequest) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CallContract not implemented") } func (UnimplementedMiraIdaAccessServer) GetDataFromKey(context.Context, *GetDataFromKeyReq) (*ContractResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetDataFromKey not implemented") } func (UnimplementedMiraIdaAccessServer) GetPlatformInfo(context.Context, *chainpb.GetPlatformInfoRequest) (*chainpb.PlatformDataResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPlatformInfo not implemented") } func (UnimplementedMiraIdaAccessServer) ListChainInfo(context.Context, *chainpb.ListChainInfoRequest) (*chainpb.ListChainInfoResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method ListChainInfo not implemented") } func (UnimplementedMiraIdaAccessServer) GetPrivateDBConnInfo(context.Context, *registrationpb.GetPrivateDBConnInfoReq) (*registrationpb.GetPrivateDBConnInfoResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPrivateDBConnInfo not implemented") } func (UnimplementedMiraIdaAccessServer) GetPrivateAssetList(context.Context, *registrationpb.GetPrivateAssetListReq) (*registrationpb.GetPrivateAssetListResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPrivateAssetList not implemented") } func (UnimplementedMiraIdaAccessServer) GetPrivateAssetInfo(context.Context, *registrationpb.GetPrivateAssetInfoReq) (*registrationpb.GetPrivateAssetInfoResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPrivateAssetInfo not implemented") } func (UnimplementedMiraIdaAccessServer) GetPrivateAssetInfoByEnName(context.Context, *registrationpb.GetPrivateAssetInfoByEnNameReq) (*registrationpb.GetPrivateAssetInfoByEnNameResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPrivateAssetInfoByEnName not implemented") } func (UnimplementedMiraIdaAccessServer) GetPrivateEnterpriseAsset(context.Context, *registrationpb.GetPrivateEnterpriseAssetReq) (*registrationpb.GetPrivateEnterpriseAssetResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPrivateEnterpriseAsset not implemented") } func (UnimplementedMiraIdaAccessServer) GetPrivatePlatformPK(context.Context, *registrationpb.GetPrivatePlatformPKReq) (*registrationpb.GetPrivatePlatformPKResp, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPrivatePlatformPK not implemented") } func (UnimplementedMiraIdaAccessServer) CreateKey(context.Context, *keypb.KeyCreateRequest) (*keypb.KeyCreateResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateKey not implemented") } func (UnimplementedMiraIdaAccessServer) Encrypt(context.Context, *keypb.KeyEncryptRequest) (*keypb.KeyEncryptResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Encrypt not implemented") } func (UnimplementedMiraIdaAccessServer) EncryptWithPkList(context.Context, *keypb.KeyEncryptWithPkListRequest) (*keypb.KeyEncryptWithPkListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EncryptWithPkList not implemented") } func (UnimplementedMiraIdaAccessServer) Decrypt(context.Context, *keypb.KeyDecryptRequest) (*keypb.KeyDecryptResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Decrypt not implemented") } func (UnimplementedMiraIdaAccessServer) EncWithDeK(context.Context, *keypb.DataEnvelopeEncryptRequest) (*keypb.DataEnvelopeEncryptResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EncWithDeK not implemented") } func (UnimplementedMiraIdaAccessServer) DecByKeK(context.Context, *keypb.DataEnvelopeDecryptRequest) (*keypb.KeyDecryptResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method DecByKeK not implemented") } func (UnimplementedMiraIdaAccessServer) EncWithDeKWithPkList(context.Context, *keypb.DataEnvelopeEncryptWithPkListRequest) (*keypb.DataEnvelopeEncryptWithPkListResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method EncWithDeKWithPkList not implemented") } func (UnimplementedMiraIdaAccessServer) GetSkFromPk(context.Context, *keypb.GetSkRequest) (*keypb.GetSkResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSkFromPk not implemented") } func (UnimplementedMiraIdaAccessServer) GetSkFromKeyId(context.Context, *keypb.GetSkFromKeyIdRequest) (*keypb.GetSkResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetSkFromKeyId not implemented") } func (UnimplementedMiraIdaAccessServer) mustEmbedUnimplementedMiraIdaAccessServer() {} // UnsafeMiraIdaAccessServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to MiraIdaAccessServer will // result in compilation errors. type UnsafeMiraIdaAccessServer interface { mustEmbedUnimplementedMiraIdaAccessServer() } func RegisterMiraIdaAccessServer(s grpc.ServiceRegistrar, srv MiraIdaAccessServer) { s.RegisterService(&MiraIdaAccess_ServiceDesc, srv) } func _MiraIdaAccess_CreateJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CreateJob(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CreateJob", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CreateJob(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CreateJobApprove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CreateJobApprove(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CreateJobApprove", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CreateJobApprove(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetJobList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetJobList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetJobList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetJobList(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetJob(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetJob", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetJob(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetJobApproveList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetJobApproveList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetJobApproveList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetJobApproveList(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetJobApprove_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetJobApprove(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetJobApprove", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetJobApprove(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetJobStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetJobStatus(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetJobStatus", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetJobStatus(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CreateJobInstance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CreateJobInstance(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CreateJobInstance", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CreateJobInstance(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetJobInstanceStatusReady_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetJobInstanceStatusReady(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetJobInstanceStatusReady", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetJobInstanceStatusReady(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetTaskPartyInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetTaskPartyInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetTaskPartyInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetTaskPartyInfo(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetTaskStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetTaskStatus(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetTaskStatus", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetTaskStatus(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_UpdateJobInstance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).UpdateJobInstance(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/UpdateJobInstance", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).UpdateJobInstance(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetJobInstanceInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetJobInstanceInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetJobInstanceInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetJobInstanceInfo(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetJobInstanceDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetJobInstanceDetail(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetJobInstanceDetail", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetJobInstanceDetail(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CancelJobInstance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CancelJobInstance(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CancelJobInstance", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CancelJobInstance(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_UpdateServiceStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).UpdateServiceStatus(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/UpdateServiceStatus", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).UpdateServiceStatus(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetTaskOutput_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetTaskOutput(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetTaskOutput", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetTaskOutput(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_UpdateJobInstanceFailedReason_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).UpdateJobInstanceFailedReason(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/UpdateJobInstanceFailedReason", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).UpdateJobInstanceFailedReason(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetComputingResourceAll_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetComputingResourceAll(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetComputingResourceAll", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetComputingResourceAll(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CreateComputingResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CreateComputingResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CreateComputingResource", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CreateComputingResource(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetComputingResourceByPartyId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetComputingResourceByPartyId(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetComputingResourceByPartyId", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetComputingResourceByPartyId(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetComputingResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetComputingResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetComputingResource", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetComputingResource(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_RepublishComputingResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).RepublishComputingResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/RepublishComputingResource", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).RepublishComputingResource(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_DeleteComputingResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).DeleteComputingResource(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/DeleteComputingResource", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).DeleteComputingResource(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CreateComputingModel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CreateComputingModel(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CreateComputingModel", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CreateComputingModel(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetComputingModelList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetComputingModelList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetComputingModelList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetComputingModelList(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetComputingModel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetComputingModel(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetComputingModel", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetComputingModel(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_QueryServiceDetails_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).QueryServiceDetails(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/QueryServiceDetails", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).QueryServiceDetails(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_QueryTaskDetails_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).QueryTaskDetails(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/QueryTaskDetails", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).QueryTaskDetails(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetResultServerAddr_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetResultServerAddr(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetResultServerAddr", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetResultServerAddr(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetResultServerAddr_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetResultServerAddr(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetResultServerAddr", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetResultServerAddr(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_UpdateJobTriggerEnable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).UpdateJobTriggerEnable(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/UpdateJobTriggerEnable", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).UpdateJobTriggerEnable(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_SetTaskFailed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).SetTaskFailed(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/SetTaskFailed", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).SetTaskFailed(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_UpdateTaskInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).UpdateTaskInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/UpdateTaskInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).UpdateTaskInfo(ctx, req.(*ContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CallContract_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CallContractRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CallContract(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CallContract", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CallContract(ctx, req.(*CallContractRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetDataFromKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetDataFromKeyReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetDataFromKey(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetDataFromKey", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetDataFromKey(ctx, req.(*GetDataFromKeyReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPlatformInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(chainpb.GetPlatformInfoRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPlatformInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPlatformInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPlatformInfo(ctx, req.(*chainpb.GetPlatformInfoRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_ListChainInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(chainpb.ListChainInfoRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).ListChainInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/ListChainInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).ListChainInfo(ctx, req.(*chainpb.ListChainInfoRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPrivateDBConnInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(registrationpb.GetPrivateDBConnInfoReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPrivateDBConnInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPrivateDBConnInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPrivateDBConnInfo(ctx, req.(*registrationpb.GetPrivateDBConnInfoReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPrivateAssetList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(registrationpb.GetPrivateAssetListReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPrivateAssetList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPrivateAssetList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPrivateAssetList(ctx, req.(*registrationpb.GetPrivateAssetListReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPrivateAssetInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(registrationpb.GetPrivateAssetInfoReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPrivateAssetInfo(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPrivateAssetInfo", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPrivateAssetInfo(ctx, req.(*registrationpb.GetPrivateAssetInfoReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPrivateAssetInfoByEnName_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(registrationpb.GetPrivateAssetInfoByEnNameReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPrivateAssetInfoByEnName(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPrivateAssetInfoByEnName", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPrivateAssetInfoByEnName(ctx, req.(*registrationpb.GetPrivateAssetInfoByEnNameReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPrivateEnterpriseAsset_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(registrationpb.GetPrivateEnterpriseAssetReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPrivateEnterpriseAsset(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPrivateEnterpriseAsset", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPrivateEnterpriseAsset(ctx, req.(*registrationpb.GetPrivateEnterpriseAssetReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetPrivatePlatformPK_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(registrationpb.GetPrivatePlatformPKReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetPrivatePlatformPK(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetPrivatePlatformPK", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetPrivatePlatformPK(ctx, req.(*registrationpb.GetPrivatePlatformPKReq)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_CreateKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.KeyCreateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).CreateKey(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/CreateKey", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).CreateKey(ctx, req.(*keypb.KeyCreateRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_Encrypt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.KeyEncryptRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).Encrypt(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/Encrypt", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).Encrypt(ctx, req.(*keypb.KeyEncryptRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_EncryptWithPkList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.KeyEncryptWithPkListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).EncryptWithPkList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/EncryptWithPkList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).EncryptWithPkList(ctx, req.(*keypb.KeyEncryptWithPkListRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_Decrypt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.KeyDecryptRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).Decrypt(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/Decrypt", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).Decrypt(ctx, req.(*keypb.KeyDecryptRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_EncWithDeK_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.DataEnvelopeEncryptRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).EncWithDeK(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/EncWithDeK", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).EncWithDeK(ctx, req.(*keypb.DataEnvelopeEncryptRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_DecByKeK_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.DataEnvelopeDecryptRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).DecByKeK(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/DecByKeK", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).DecByKeK(ctx, req.(*keypb.DataEnvelopeDecryptRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_EncWithDeKWithPkList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.DataEnvelopeEncryptWithPkListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).EncWithDeKWithPkList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/EncWithDeKWithPkList", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).EncWithDeKWithPkList(ctx, req.(*keypb.DataEnvelopeEncryptWithPkListRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetSkFromPk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.GetSkRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetSkFromPk(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetSkFromPk", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetSkFromPk(ctx, req.(*keypb.GetSkRequest)) } return interceptor(ctx, in, info, handler) } func _MiraIdaAccess_GetSkFromKeyId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(keypb.GetSkFromKeyIdRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MiraIdaAccessServer).GetSkFromKeyId(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/proto.MiraIdaAccess/GetSkFromKeyId", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MiraIdaAccessServer).GetSkFromKeyId(ctx, req.(*keypb.GetSkFromKeyIdRequest)) } return interceptor(ctx, in, info, handler) } // MiraIdaAccess_ServiceDesc is the grpc.ServiceDesc for MiraIdaAccess service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var MiraIdaAccess_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.MiraIdaAccess", HandlerType: (*MiraIdaAccessServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateJob", Handler: _MiraIdaAccess_CreateJob_Handler, }, { MethodName: "CreateJobApprove", Handler: _MiraIdaAccess_CreateJobApprove_Handler, }, { MethodName: "GetJobList", Handler: _MiraIdaAccess_GetJobList_Handler, }, { MethodName: "GetJob", Handler: _MiraIdaAccess_GetJob_Handler, }, { MethodName: "GetJobApproveList", Handler: _MiraIdaAccess_GetJobApproveList_Handler, }, { MethodName: "GetJobApprove", Handler: _MiraIdaAccess_GetJobApprove_Handler, }, { MethodName: "SetJobStatus", Handler: _MiraIdaAccess_SetJobStatus_Handler, }, { MethodName: "CreateJobInstance", Handler: _MiraIdaAccess_CreateJobInstance_Handler, }, { MethodName: "SetJobInstanceStatusReady", Handler: _MiraIdaAccess_SetJobInstanceStatusReady_Handler, }, { MethodName: "SetTaskPartyInfo", Handler: _MiraIdaAccess_SetTaskPartyInfo_Handler, }, { MethodName: "SetTaskStatus", Handler: _MiraIdaAccess_SetTaskStatus_Handler, }, { MethodName: "UpdateJobInstance", Handler: _MiraIdaAccess_UpdateJobInstance_Handler, }, { MethodName: "GetJobInstanceInfo", Handler: _MiraIdaAccess_GetJobInstanceInfo_Handler, }, { MethodName: "GetJobInstanceDetail", Handler: _MiraIdaAccess_GetJobInstanceDetail_Handler, }, { MethodName: "CancelJobInstance", Handler: _MiraIdaAccess_CancelJobInstance_Handler, }, { MethodName: "UpdateServiceStatus", Handler: _MiraIdaAccess_UpdateServiceStatus_Handler, }, { MethodName: "SetTaskOutput", Handler: _MiraIdaAccess_SetTaskOutput_Handler, }, { MethodName: "UpdateJobInstanceFailedReason", Handler: _MiraIdaAccess_UpdateJobInstanceFailedReason_Handler, }, { MethodName: "GetComputingResourceAll", Handler: _MiraIdaAccess_GetComputingResourceAll_Handler, }, { MethodName: "CreateComputingResource", Handler: _MiraIdaAccess_CreateComputingResource_Handler, }, { MethodName: "GetComputingResourceByPartyId", Handler: _MiraIdaAccess_GetComputingResourceByPartyId_Handler, }, { MethodName: "GetComputingResource", Handler: _MiraIdaAccess_GetComputingResource_Handler, }, { MethodName: "RepublishComputingResource", Handler: _MiraIdaAccess_RepublishComputingResource_Handler, }, { MethodName: "DeleteComputingResource", Handler: _MiraIdaAccess_DeleteComputingResource_Handler, }, { MethodName: "CreateComputingModel", Handler: _MiraIdaAccess_CreateComputingModel_Handler, }, { MethodName: "GetComputingModelList", Handler: _MiraIdaAccess_GetComputingModelList_Handler, }, { MethodName: "GetComputingModel", Handler: _MiraIdaAccess_GetComputingModel_Handler, }, { MethodName: "QueryServiceDetails", Handler: _MiraIdaAccess_QueryServiceDetails_Handler, }, { MethodName: "QueryTaskDetails", Handler: _MiraIdaAccess_QueryTaskDetails_Handler, }, { MethodName: "SetResultServerAddr", Handler: _MiraIdaAccess_SetResultServerAddr_Handler, }, { MethodName: "GetResultServerAddr", Handler: _MiraIdaAccess_GetResultServerAddr_Handler, }, { MethodName: "UpdateJobTriggerEnable", Handler: _MiraIdaAccess_UpdateJobTriggerEnable_Handler, }, { MethodName: "SetTaskFailed", Handler: _MiraIdaAccess_SetTaskFailed_Handler, }, { MethodName: "UpdateTaskInfo", Handler: _MiraIdaAccess_UpdateTaskInfo_Handler, }, { MethodName: "CallContract", Handler: _MiraIdaAccess_CallContract_Handler, }, { MethodName: "GetDataFromKey", Handler: _MiraIdaAccess_GetDataFromKey_Handler, }, { MethodName: "GetPlatformInfo", Handler: _MiraIdaAccess_GetPlatformInfo_Handler, }, { MethodName: "ListChainInfo", Handler: _MiraIdaAccess_ListChainInfo_Handler, }, { MethodName: "GetPrivateDBConnInfo", Handler: _MiraIdaAccess_GetPrivateDBConnInfo_Handler, }, { MethodName: "GetPrivateAssetList", Handler: _MiraIdaAccess_GetPrivateAssetList_Handler, }, { MethodName: "GetPrivateAssetInfo", Handler: _MiraIdaAccess_GetPrivateAssetInfo_Handler, }, { MethodName: "GetPrivateAssetInfoByEnName", Handler: _MiraIdaAccess_GetPrivateAssetInfoByEnName_Handler, }, { MethodName: "GetPrivateEnterpriseAsset", Handler: _MiraIdaAccess_GetPrivateEnterpriseAsset_Handler, }, { MethodName: "GetPrivatePlatformPK", Handler: _MiraIdaAccess_GetPrivatePlatformPK_Handler, }, { MethodName: "CreateKey", Handler: _MiraIdaAccess_CreateKey_Handler, }, { MethodName: "Encrypt", Handler: _MiraIdaAccess_Encrypt_Handler, }, { MethodName: "EncryptWithPkList", Handler: _MiraIdaAccess_EncryptWithPkList_Handler, }, { MethodName: "Decrypt", Handler: _MiraIdaAccess_Decrypt_Handler, }, { MethodName: "EncWithDeK", Handler: _MiraIdaAccess_EncWithDeK_Handler, }, { MethodName: "DecByKeK", Handler: _MiraIdaAccess_DecByKeK_Handler, }, { MethodName: "EncWithDeKWithPkList", Handler: _MiraIdaAccess_EncWithDeKWithPkList_Handler, }, { MethodName: "GetSkFromPk", Handler: _MiraIdaAccess_GetSkFromPk_Handler, }, { MethodName: "GetSkFromKeyId", Handler: _MiraIdaAccess_GetSkFromKeyId_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/mira_ida_access_service.proto", }