Documentation ¶
Overview ¶
Package chainmaker_sdk_go define chainmaker sdk go
Index ¶
- Constants
- Variables
- func GetCMAddressFromCertPEM(certPEM string) (string, error)
- func GetCMAddressFromCertPath(certPath string) (string, error)
- func GetCMAddressFromPKHex(pkHex string, hashType crypto.HashType) (string, error)
- func GetCMAddressFromPKPEM(pkPEM string, hashType crypto.HashType) (string, error)
- func GetEVMAddressFromCertBytes(certBytes []byte) (string, error)
- func GetEVMAddressFromCertPath(certFilePath string) (string, error)
- func GetEVMAddressFromPKHex(pkHex string, hashType crypto.HashType) (string, error)
- func GetEVMAddressFromPKPEM(pkPEM string, hashType crypto.HashType) (string, error)
- func GetEVMAddressFromPrivateKeyBytes(privateKeyBytes []byte, hashType crypto.HashType) (string, error)
- func GetEVMAddressFromPrivateKeyPath(privateKeyFilePath string, hashType crypto.HashType) (string, error)
- func GetP11Handle() interface{}
- func GetZXAddressFromCertPEM(certPEM string) (string, error)
- func GetZXAddressFromCertPath(certPath string) (string, error)
- func GetZXAddressFromPKHex(pkHex string, hashType crypto.HashType) (string, error)
- func GetZXAddressFromPKPEM(pkPEM string, hashType crypto.HashType) (string, error)
- func NewCanonicalTxFetcherPools(config *ChainClientConfig) (map[string]ConnectionPool, error)
- func SM3(data []byte) (string, error)
- func SignPayload(keyPem, certPem []byte, payload *common.Payload) (*common.EndorsementEntry, error)
- func SignPayloadWithPath(keyFilePath, crtFilePath string, payload *common.Payload) (*common.EndorsementEntry, error)
- type ArchiveCenterConfig
- type ArchiveCenterGrpcClient
- func (a *ArchiveCenterGrpcClient) ArchiveBlock(block *common.BlockInfo) error
- func (a *ArchiveCenterGrpcClient) ArchiveBlocks(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) error
- func (a *ArchiveCenterGrpcClient) ArchiveCenterConfig() *ArchiveCenterConfig
- func (client *ArchiveCenterGrpcClient) Close() error
- func (a *ArchiveCenterGrpcClient) GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error)
- func (a *ArchiveCenterGrpcClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveCenterGrpcClient) GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveCenterGrpcClient) GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveCenterGrpcClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
- func (a *ArchiveCenterGrpcClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
- func (a *ArchiveCenterGrpcClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
- func (client *ArchiveCenterGrpcClient) GrpcCallOption() []grpc.CallOption
- func (a *ArchiveCenterGrpcClient) Register(genesisBlock *common.BlockInfo) error
- type ArchiveCenterHttpClient
- func (a *ArchiveCenterHttpClient) ArchiveBlock(block *common.BlockInfo) error
- func (a *ArchiveCenterHttpClient) ArchiveBlocks(bi BlockIterator, _ func(ProcessMessage) error) error
- func (a *ArchiveCenterHttpClient) ArchiveCenterConfig() *ArchiveCenterConfig
- func (_ *ArchiveCenterHttpClient) Close() error
- func (a *ArchiveCenterHttpClient) GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error)
- func (a *ArchiveCenterHttpClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveCenterHttpClient) GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveCenterHttpClient) GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveCenterHttpClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
- func (a *ArchiveCenterHttpClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
- func (a *ArchiveCenterHttpClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
- func (a *ArchiveCenterHttpClient) Register(genesis *common.BlockInfo) error
- type ArchiveCenterQueryParam
- type ArchiveCenterResponse
- type ArchiveCenterResponseBlockHeader
- type ArchiveCenterResponseBlockInfo
- type ArchiveCenterResponseBlockWithRwSet
- type ArchiveCenterResponseChainConfig
- type ArchiveCenterResponseHeight
- type ArchiveCenterResponseMerklePath
- type ArchiveCenterResponseTransaction
- type ArchiveCenterResponseTransactionWithRwSet
- type ArchiveConfig
- type ArchiveMySqlClient
- func (a *ArchiveMySqlClient) ArchiveBlock(block *common.BlockInfo) error
- func (a *ArchiveMySqlClient) ArchiveBlocks(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) error
- func (a *ArchiveMySqlClient) Close() error
- func (a *ArchiveMySqlClient) GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error)
- func (a *ArchiveMySqlClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveMySqlClient) GetBlockByHeight(height uint64, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveMySqlClient) GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
- func (a *ArchiveMySqlClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
- func (a *ArchiveMySqlClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
- func (a *ArchiveMySqlClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
- func (a *ArchiveMySqlClient) Register(genesis *common.BlockInfo) error
- type ArchiveOption
- type ArchiveService
- type AuthType
- type BlockIterator
- type CertAliasSigner
- type CertHashSigner
- type CertModeSigner
- type ChainClient
- func (cc *ChainClient) AddAlias() (*common.TxResponse, error)
- func (cc *ChainClient) AddCert() (*common.TxResponse, error)
- func (cc *ChainClient) ArchiveBlocks(archiveHeight uint64, mode string, heightNotice func(ProcessMessage) error) error
- func (cc *ChainClient) ArchiveCenterConfig() *ArchiveCenterConfig
- func (cc *ChainClient) AttachGasLimit(payload *common.Payload, limit *common.Limit) *common.Payload
- func (cc *ChainClient) ChangeSigner(signerPrivKey crypto.PrivateKey, signerCrt *bcx509.Certificate, ...) error
- func (cc *ChainClient) CheckCallerCertAuth(payload string, orgIds []string, signPairs []*syscontract.SignInfo) (*common.TxResponse, error)
- func (cc *ChainClient) CheckNewBlockChainConfig() error
- func (cc *ChainClient) CreateArchiveBlockPayload(targetBlockHeight uint64) (*common.Payload, error)
- func (cc *ChainClient) CreateCertManageFrozenPayload(certs []string) *common.Payload
- func (cc *ChainClient) CreateCertManagePayload(method string, kvs []*common.KeyValuePair) *common.Payload
- func (cc *ChainClient) CreateCertManageRevocationPayload(certCrl string) *common.Payload
- func (cc *ChainClient) CreateCertManageUnfrozenPayload(certs []string) *common.Payload
- func (cc *ChainClient) CreateChainConfigAlterAddrTypePayload(addrType string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigBlockUpdatePayload(txTimestampVerify, blockTimestampVerify bool, ...) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusExtAddPayload(kvs []*common.KeyValuePair) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusExtDeletePayload(keys []string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusExtUpdatePayload(kvs []*common.KeyValuePair) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusNodeIdAddPayload(nodeOrgId string, nodeIds []string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusNodeIdDeletePayload(nodeOrgId, nodeId string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusNodeIdUpdatePayload(nodeOrgId, nodeOldIds, nodeNewIds string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusNodeOrgAddPayload(nodeOrgId string, nodeIds []string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusNodeOrgDeletePayload(nodeOrgId string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigConsensusNodeOrgUpdatePayload(nodeOrgId string, nodeIds []string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigCoreUpdatePayload(txSchedulerTimeout, txSchedulerValidateTimeout uint64) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigEnableMultiSignManualRunPayload(enable bool) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigEnableOrDisableGasPayload() (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigOptimizeChargeGasPayload(enable bool) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigPermissionAddPayload(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigPermissionDeletePayload(resourceName string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigPermissionUpdatePayload(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigTrustMemberAddPayload(trustMemberOrgId, trustMemberNodeId, trustMemberRole, trustMemberInfo string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigTrustMemberDeletePayload(trustMemberInfo string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigTrustRootAddPayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigTrustRootDeletePayload(orgIdOrPKPubkeyPEM string) (*common.Payload, error)
- func (cc *ChainClient) CreateChainConfigTrustRootUpdatePayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)
- func (cc *ChainClient) CreateContractCreatePayload(contractName, version, byteCodeStringOrFilePath string, ...) (*common.Payload, error)
- func (cc *ChainClient) CreateContractFreezePayload(contractName string) (*common.Payload, error)
- func (cc *ChainClient) CreateContractRevokePayload(contractName string) (*common.Payload, error)
- func (cc *ChainClient) CreateContractUnfreezePayload(contractName string) (*common.Payload, error)
- func (cc *ChainClient) CreateContractUpgradePayload(contractName, version, byteCodeStringOrFilePath string, ...) (*common.Payload, error)
- func (cc *ChainClient) CreateDeleteCertsAliasPayload(aliases []string) *common.Payload
- func (cc *ChainClient) CreateFrozenGasAccountPayload(address string) (*common.Payload, error)
- func (cc *ChainClient) CreateHibeInitParamsTxPayloadParams(orgId string, hibeParams []byte) ([]*common.KeyValuePair, error)
- func (cc *ChainClient) CreateHibeTxPayloadParamsWithHibeParams(plaintext []byte, receiverIds []string, paramsBytesList [][]byte, txId string, ...) ([]*common.KeyValuePair, error)
- func (cc *ChainClient) CreateHibeTxPayloadParamsWithoutHibeParams(contractName, queryParamsMethod string, plaintext []byte, receiverIds []string, ...) ([]*common.KeyValuePair, error)
- func (cc *ChainClient) CreateMultiSignReqPayload(pairs []*common.KeyValuePair) *common.Payload
- func (cc *ChainClient) CreateMultiSignReqPayloadWithGasLimit(pairs []*common.KeyValuePair, gasLimit uint64) *common.Payload
- func (cc *ChainClient) CreateNativeContractAccessGrantPayload(grantContractList []string) (*common.Payload, error)
- func (cc *ChainClient) CreateNativeContractAccessRevokePayload(revokeContractList []string) (*common.Payload, error)
- func (cc *ChainClient) CreatePayload(txId string, txType common.TxType, contractName, method string, ...) *common.Payload
- func (cc *ChainClient) CreatePubkeyAddPayload(pubkey string, orgId string, role string) (*common.Payload, error)
- func (cc *ChainClient) CreatePubkeyDelPayload(pubkey string, orgId string) (*common.Payload, error)
- func (cc *ChainClient) CreatePubkeyQueryPayload(pubkey string) (*common.Payload, error)
- func (cc *ChainClient) CreateRechargeGasPayload(rechargeGasList []*syscontract.RechargeGas) (*common.Payload, error)
- func (cc *ChainClient) CreateRefundGasPayload(address string, amount int64) (*common.Payload, error)
- func (cc *ChainClient) CreateRestoreBlockPayload(fullBlock []byte) (*common.Payload, error)
- func (cc *ChainClient) CreateRestoreBlocksPayload(fullBlocks [][]byte) (*common.Payload, error)
- func (cc *ChainClient) CreateSaveEnclaveCACertPayload(enclaveCACert string, txId string) (*common.Payload, error)
- func (cc *ChainClient) CreateSaveEnclaveReportPayload(enclaveId, report, txId string) (*common.Payload, error)
- func (cc *ChainClient) CreateSetGasAdminPayload(address string) (*common.Payload, error)
- func (cc *ChainClient) CreateSetInstallBaseGasPayload(amount int64) (*common.Payload, error)
- func (cc *ChainClient) CreateSetInstallGasPricePayload(gasPrice string) (*common.Payload, error)
- func (cc *ChainClient) CreateSetInvokeBaseGasPayload(amount int64) (*common.Payload, error)
- func (cc *ChainClient) CreateSetInvokeGasPricePayload(gasPrice string) (*common.Payload, error)
- func (cc *ChainClient) CreateSubscribeBlockPayload(startBlock, endBlock int64, withRWSet, onlyHeader bool) *common.Payload
- func (cc *ChainClient) CreateSubscribeContractEventPayload(startBlock, endBlock int64, contractName, topic string) *common.Payload
- func (cc *ChainClient) CreateSubscribeTxPayload(startBlock, endBlock int64, contractName string, txIds []string) *common.Payload
- func (cc *ChainClient) CreateUnfrozenGasAccountPayload(address string) (*common.Payload, error)
- func (cc *ChainClient) CreateUpdateCertByAliasPayload(alias, newCertPEM string) *common.Payload
- func (cc *ChainClient) DecryptHibeTxByTxId(localId string, hibeParams []byte, hibePrvKey []byte, txId string, ...) ([]byte, error)
- func (cc *ChainClient) DeleteCert(certHashes []string) (*common.TxResponse, error)
- func (cc *ChainClient) DeleteCertsAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) DisableCertHash() error
- func (cc *ChainClient) EasyCodecItemToParamsMap(items []*serialize.EasyCodecItem) map[string][]byte
- func (cc *ChainClient) EnableAlias() error
- func (cc *ChainClient) EnableCertHash() error
- func (cc *ChainClient) EstimateGas(payload *common.Payload) (uint64, error)
- func (cc *ChainClient) GenerateTxRequest(payload *common.Payload, endorsers []*common.EndorsementEntry) (*common.TxRequest, error)
- func (cc *ChainClient) GenerateTxRequestBySigner(payload *common.Payload, endorsers []*common.EndorsementEntry, signer Signer) (*common.TxRequest, error)
- func (cc *ChainClient) GenerateTxRequestWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxRequest, error)
- func (cc *ChainClient) GetArchiveService() ArchiveService
- func (cc *ChainClient) GetArchiveStatus() (*store.ArchiveStatus, error)
- func (cc *ChainClient) GetArchivedBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetArchivedBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetArchivedBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetArchivedBlockHeight() (uint64, error)
- func (cc *ChainClient) GetArchivedTxByTxId(txId string) (*common.TransactionInfo, error)
- func (cc *ChainClient) GetAuthType() AuthType
- func (cc *ChainClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetBlockByHeightTruncate(blockHeight uint64, withRWSet bool, truncateLength int, truncateModel string) (*common.BlockInfo, error)
- func (cc *ChainClient) GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetBlockHeaderByHeight(blockHeight uint64) (*common.BlockHeader, error)
- func (cc *ChainClient) GetBlockHeightByHash(blockHash string) (uint64, error)
- func (cc *ChainClient) GetBlockHeightByTxId(txId string) (uint64, error)
- func (cc *ChainClient) GetCertHash() ([]byte, error)
- func (cc *ChainClient) GetCertPEM() []byte
- func (cc *ChainClient) GetChainConfig() (*config.ChainConfig, error)
- func (cc *ChainClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
- func (cc *ChainClient) GetChainConfigPermissionList() ([]*config.ResourcePolicy, error)
- func (cc *ChainClient) GetChainConfigSequence() (uint64, error)
- func (cc *ChainClient) GetChainInfo() (*discovery.ChainInfo, error)
- func (cc *ChainClient) GetChainMakerServerVersion() (string, error)
- func (cc *ChainClient) GetChainMakerServerVersionCustom(ctx context.Context) (string, error)
- func (cc *ChainClient) GetConsensusHeight() (uint64, error)
- func (cc *ChainClient) GetConsensusStateJSON() ([]byte, error)
- func (cc *ChainClient) GetConsensusValidators() ([]string, error)
- func (cc *ChainClient) GetContract(contractName, codeHash string) (*common.PrivateGetContract, error)
- func (cc *ChainClient) GetContractInfo(contractName string) (*common.Contract, error)
- func (cc *ChainClient) GetContractList() ([]*common.Contract, error)
- func (cc *ChainClient) GetCurrentBlockHeight() (uint64, error)
- func (cc *ChainClient) GetData(contractName, key string) ([]byte, error)
- func (cc *ChainClient) GetDir(orderId string) ([]byte, error)
- func (cc *ChainClient) GetDisabledNativeContractList() ([]string, error)
- func (cc *ChainClient) GetEnabledCrtHash() bool
- func (cc *ChainClient) GetEnclaveCACert() ([]byte, error)
- func (cc *ChainClient) GetEnclaveChallenge(enclaveId string) ([]byte, error)
- func (cc *ChainClient) GetEnclaveEncryptPubKey(enclaveId string) ([]byte, error)
- func (cc *ChainClient) GetEnclaveProof(enclaveId string) ([]byte, error)
- func (cc *ChainClient) GetEnclaveReport(enclaveId string) ([]byte, error)
- func (cc *ChainClient) GetEnclaveSignature(enclaveId string) ([]byte, error)
- func (cc *ChainClient) GetEnclaveVerificationPubKey(enclaveId string) ([]byte, error)
- func (cc *ChainClient) GetFullBlockByHeight(blockHeight uint64) (*store.BlockWithRWSet, error)
- func (cc *ChainClient) GetGasAccountStatus(address string) (bool, error)
- func (cc *ChainClient) GetGasAdmin() (string, error)
- func (cc *ChainClient) GetGasBalance(address string) (int64, error)
- func (cc *ChainClient) GetHashType() crypto.HashType
- func (cc *ChainClient) GetLastBlock(withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetLastConfigBlock(withRWSet bool) (*common.BlockInfo, error)
- func (cc *ChainClient) GetLocalCertAlias() string
- func (cc *ChainClient) GetMerklePathByTxId(txId string) ([]byte, error)
- func (cc *ChainClient) GetNodeChainList() (*discovery.ChainList, error)
- func (cc *ChainClient) GetPoolStatus() (*txpool.TxPoolStatus, error)
- func (cc *ChainClient) GetPrivateKey() crypto.PrivateKey
- func (cc *ChainClient) GetPublicKey() crypto.PublicKey
- func (cc *ChainClient) GetSyncResult(txId string, timeout int64) (*common.Result, error)
- func (cc *ChainClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
- func (cc *ChainClient) GetTxByTxIdTruncate(txId string, withRWSet bool, truncateLength int, truncateModel string) (*common.TransactionInfoWithRWSet, error)
- func (cc *ChainClient) GetTxIdsByTypeAndStage(txType txpool.TxType, txStage txpool.TxStage) ([]string, error)
- func (cc *ChainClient) GetTxRequest(contractName, method, txId string, kvs []*common.KeyValuePair) (*common.TxRequest, error)
- func (cc *ChainClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
- func (cc *ChainClient) GetTxsInPoolByTxIds(txIds []string) ([]*common.Transaction, []string, error)
- func (cc *ChainClient) GetUserCrtHash() []byte
- func (cc *ChainClient) InvokeContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) InvokeContractBySigner(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) InvokeContractWithLimit(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) InvokeSystemContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) IsArchiveCenterQueryFist() bool
- func (cc *ChainClient) IsEnableNormalKey() bool
- func (cc *ChainClient) MultiSignContractQuery(txId string) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractQueryWithParams(txId string, params []*common.KeyValuePair) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractReq(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractReqWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractTrig(multiSignReqPayload *common.Payload, timeout int64, limit *common.Limit, ...) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractTrigWithPayer(multiSignReqPayload *common.Payload, payer *common.EndorsementEntry, ...) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractVote(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry, ...) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractVoteWithGasLimit(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry, ...) (*common.TxResponse, error)
- func (cc *ChainClient) MultiSignContractVoteWithGasLimitAndPayer(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry, ...) (*common.TxResponse, error)
- func (cc *ChainClient) Pkcs11Config() *Pkcs11Config
- func (cc *ChainClient) QueryCert(certHashes []string) (*common.CertInfos, error)
- func (cc *ChainClient) QueryCertsAlias(aliases []string) (*common.AliasInfos, error)
- func (cc *ChainClient) QueryContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) QueryContractMethodPayer(contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)
- func (cc *ChainClient) QueryHibeParamsWithOrgId(contractName, method, orgId string, timeout int64) ([]byte, error)
- func (cc *ChainClient) QuerySystemContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) QueryTxPayer(txId string, gasLimit uint64) (*common.TxResponse, error)
- func (cc *ChainClient) RestoreBlocks(restoreHeight uint64, _ string, ...) error
- func (cc *ChainClient) SaveData(contractName string, contractVersion string, isDeployment bool, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SaveDir(orderId, txId string, privateDir *common.StrSlice, withSyncResult bool, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SaveEnclaveCACert(enclaveCACert, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) SaveEnclaveReport(enclaveId, report, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) SaveRemoteAttestationProof(proof, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) SendArchiveBlockRequest(payload *common.Payload, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) SendCertManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendChainConfigUpdateRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendContractManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendContractManageRequestWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendGasManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendMultiSigningRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendPubkeyManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SendRestoreBlockRequest(payload *common.Payload, timeout int64) (*common.TxResponse, error)
- func (cc *ChainClient) SendTxRequest(txRequest *common.TxRequest, timeout int64, withSyncResult bool) (*common.TxResponse, error)
- func (cc *ChainClient) SetContractMethodPayer(payerAddress string, contractName string, methodName string, requestId string, ...) (*common.TxResponse, error)
- func (cc *ChainClient) SignCertManagePayload(payload *common.Payload) (*common.EndorsementEntry, error)
- func (cc *ChainClient) SignChainConfigPayload(payload *common.Payload) (*common.EndorsementEntry, error)
- func (cc *ChainClient) SignContractManagePayload(payload *common.Payload) (*common.EndorsementEntry, error)
- func (cc *ChainClient) SignDeleteAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error)
- func (cc *ChainClient) SignPayload(payload *common.Payload) (*common.EndorsementEntry, error)
- func (cc *ChainClient) SignUpdateCertByAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error)
- func (cc *ChainClient) Stop() error
- func (cc *ChainClient) Subscribe(ctx context.Context, payload *common.Payload) (<-chan interface{}, error)
- func (cc *ChainClient) SubscribeBlock(ctx context.Context, startBlock, endBlock int64, withRWSet, onlyHeader bool) (<-chan interface{}, error)
- func (cc *ChainClient) SubscribeContractEvent(ctx context.Context, startBlock, endBlock int64, contractName, topic string) (<-chan interface{}, error)
- func (cc *ChainClient) SubscribeTx(ctx context.Context, startBlock, endBlock int64, contractName string, ...) (<-chan interface{}, error)
- func (cc *ChainClient) SubscribeTxByPreAlias(ctx context.Context, startBlock, endBlock int64, aliasPrefix string) (<-chan interface{}, error)
- func (cc *ChainClient) SubscribeTxByPreOrgId(ctx context.Context, startBlock, endBlock int64, orgIdPrefix string) (<-chan interface{}, error)
- func (cc *ChainClient) SubscribeTxByPreTxId(ctx context.Context, startBlock, endBlock int64, txIdPrefix string) (<-chan interface{}, error)
- func (cc *ChainClient) UnsetContractMethodPayer(contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)
- func (cc *ChainClient) UpdateCertByAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)
- type ChainClientConfig
- type ChainClientOption
- func AddChainClientNodeConfig(nodeConfig *NodeConfig) ChainClientOption
- func WithArchiveCenterHttpConfig(conf *ArchiveCenterConfig) ChainClientOption
- func WithArchiveCenterQueryFirst(first bool) ChainClientOption
- func WithArchiveConfig(conf *ArchiveConfig) ChainClientOption
- func WithAuthType(authType string) ChainClientOption
- func WithChainClientAlias(alias string) ChainClientOption
- func WithChainClientChainId(chainId string) ChainClientOption
- func WithChainClientLogger(logger utils.Logger) ChainClientOption
- func WithChainClientOrgId(orgId string) ChainClientOption
- func WithConfPath(confPath string) ChainClientOption
- func WithCryptoConfig(conf *CryptoConfig) ChainClientOption
- func WithEnableNormalKey(enableNormalKey bool) ChainClientOption
- func WithEnableSyncCanonicalTxResult(enable bool) ChainClientOption
- func WithEnableTxResultDispatcher(enable bool) ChainClientOption
- func WithPkcs11Config(conf *Pkcs11Config) ChainClientOption
- func WithRPCClientConfig(conf *RPCClientConfig) ChainClientOption
- func WithRetryInterval(interval int) ChainClientOption
- func WithRetryLimit(limit int) ChainClientOption
- func WithUserCrtBytes(userCrtBytes []byte) ChainClientOption
- func WithUserCrtFilePath(userCrtFilePath string) ChainClientOption
- func WithUserEncKeyPwd(pwd string) ChainClientOption
- func WithUserKeyBytes(userKeyBytes []byte) ChainClientOption
- func WithUserKeyFilePath(userKeyFilePath string) ChainClientOption
- func WithUserKeyPwd(pwd string) ChainClientOption
- func WithUserSignCrtBytes(userSignCrtBytes []byte) ChainClientOption
- func WithUserSignCrtFilePath(userSignCrtFilePath string) ChainClientOption
- func WithUserSignKeyBytes(userSignKeyBytes []byte) ChainClientOption
- func WithUserSignKeyFilePath(userSignKeyFilePath string) ChainClientOption
- func WithUserSignKeyPwd(pwd string) ChainClientOption
- type ClientConnectionPool
- type ConnectionPool
- type CryptoConfig
- type CryptoOption
- type NodeConfig
- type NodeOption
- type PermissionedWithKeyModeSigner
- type Pkcs11Config
- type ProcessMessage
- type PublicModeSigner
- type RPCClientConfig
- type RPCClientOption
- type SDKInterface
- type Signer
Constants ¶
const ( // KEY_ALIAS key of alias KEY_ALIAS = "alias" // KEY_ALIASES key of aliases KEY_ALIASES = "aliases" // KEY_CERT key of cert KEY_CERT = "cert" )
const ( // DefaultRetryLimit 默认轮训交易结果最大次数 DefaultRetryLimit = 10 // DefaultRetryInterval 默认每次轮训交易结果时的等待时间,单位ms DefaultRetryInterval = 500 )
const ( // MaxConnCnt 单ChainMaker节点最大连接数 MaxConnCnt = 1024 // DefaultGetTxTimeout 查询交易超时时间 DefaultGetTxTimeout = 10 // DefaultSendTxTimeout 发送交易超时时间 DefaultSendTxTimeout = 10 // DefaultRpcClientMaxReceiveMessageSize 默认grpc客户端接收message最大值 4M DefaultRpcClientMaxReceiveMessageSize = 4 // DefaultRpcClientMaxSendMessageSize 默认grpc客户端发送message最大值 4M DefaultRpcClientMaxSendMessageSize = 4 )
const ( // HibeMsgKey as a payload parameter HibeMsgKey = "hibe_msg" // HibeMsgIdKey Key as a hibeMsgMap parameter HibeMsgIdKey = "tx_id" // HibeMsgCipherTextKey Key as a hibeMsgMap parameter // The value of the key (CT) is the hibe_msg's message (ciphertext) HibeMsgCipherTextKey = "CT" // HibeParamsKey The value of the key (org_id) is the unique identifier of a HIBE params HibeParamsKey = "org_id" // HibeParamsValueKey The value of the key (params) is the Hibe's params HibeParamsValueKey = "params" )
hibe msg's Keys
const ContractResultCode_OK uint32 = 0 //todo pb create const
ContractResultCode_OK ContractResultCode_OK
const (
// DefaultAuthType is default cert auth type
DefaultAuthType = ""
)
const (
// ZXLAddressPrefix define zhixinlian address prefix
ZXLAddressPrefix = "ZX"
)
Variables ¶
var AuthTypeToStringMap = map[AuthType]string{ PermissionedWithCert: "permissionedwithcert", PermissionedWithKey: "permissionedwithkey", Public: "public", }
AuthTypeToStringMap define auth type to string map
var StringToAuthTypeMap = map[string]AuthType{ "permissionedwithcert": PermissionedWithCert, "permissionedwithkey": PermissionedWithKey, "public": Public, }
StringToAuthTypeMap define string to auth type map
Functions ¶
func GetCMAddressFromCertPEM ¶ added in v2.3.0
GetCMAddressFromCertPEM get chainmaker address from cert pem
func GetCMAddressFromCertPath ¶ added in v2.3.0
GetCMAddressFromCertPath get chainmaker address from cert file path
func GetCMAddressFromPKHex ¶ added in v2.3.0
GetCMAddressFromPKHex get chainmaker address from public key hex
func GetCMAddressFromPKPEM ¶ added in v2.3.0
GetCMAddressFromPKPEM get chainmaker address from public key pem
func GetEVMAddressFromCertBytes ¶
GetEVMAddressFromCertBytes get evm address from cert bytes
func GetEVMAddressFromCertPath ¶
GetEVMAddressFromCertPath get evm address from cert file path
func GetEVMAddressFromPKHex ¶ added in v2.3.0
GetEVMAddressFromPKHex get evm address from public key hex
func GetEVMAddressFromPKPEM ¶ added in v2.3.0
GetEVMAddressFromPKPEM get evm address from public key pem
func GetEVMAddressFromPrivateKeyBytes ¶ added in v2.1.0
func GetEVMAddressFromPrivateKeyBytes(privateKeyBytes []byte, hashType crypto.HashType) (string, error)
GetEVMAddressFromPrivateKeyBytes get evm address from private key bytes
func GetEVMAddressFromPrivateKeyPath ¶ added in v2.1.0
func GetEVMAddressFromPrivateKeyPath(privateKeyFilePath string, hashType crypto.HashType) (string, error)
GetEVMAddressFromPrivateKeyPath get evm address from private key file path
func GetP11Handle ¶ added in v2.1.0
func GetP11Handle() interface{}
GetP11Handle get global thread-safe pkcs11 handler
func GetZXAddressFromCertPEM ¶ added in v2.2.0
GetZXAddressFromCertPEM get zhixinlian address from cert pem
func GetZXAddressFromCertPath ¶ added in v2.2.0
GetZXAddressFromCertPath get zhixinlian address from cert file path
func GetZXAddressFromPKHex ¶ added in v2.2.0
GetZXAddressFromPKHex get zhixinlian address from public key hex
func GetZXAddressFromPKPEM ¶ added in v2.2.0
GetZXAddressFromPKPEM get zhixinlian address from public key pem
func NewCanonicalTxFetcherPools ¶ added in v2.3.0
func NewCanonicalTxFetcherPools(config *ChainClientConfig) (map[string]ConnectionPool, error)
NewCanonicalTxFetcherPools 创建连接池
func SM3 ¶ added in v2.3.3
SM3 sum of data in SM3, returns sum hex
func SignPayload ¶
SignPayload sign payload Deprecated: use ./utils.MakeEndorserWithPem
Types ¶
type ArchiveCenterConfig ¶ added in v2.3.3
type ArchiveCenterConfig struct { ChainGenesisHash string // ArchiveCenterHttpUrl string ReqeustSecondLimit int // http请求的超时间隔,默认5秒 RpcAddress string TlsEnable bool Tls utils.TlsConfig MaxSendMsgSize int MaxRecvMsgSize int }
ArchiveCenterConfig 定义归档中心配置
func NewArchiveCenterConfig ¶ added in v2.3.3
func NewArchiveCenterConfig(httpUrl, rpcUrl, chainGenesisHash string, requestSecondLimit, maxRpcSend, maxRpcRecv int, tlsEnable bool, tlsCfg utils.TlsConfig) *ArchiveCenterConfig
NewArchiveCenterConfig 根据传入参数创建新的归档中心对象 @param httpUrl @param chainGenesisHash @param requestSecondLimit @return *ArchiveCenterHttpConfig
type ArchiveCenterGrpcClient ¶ added in v2.3.3
type ArchiveCenterGrpcClient struct {
// contains filtered or unexported fields
}
ArchiveCenterGrpcClient 归档服务的归档中心GRPC客户端实现
func NewArchiveCenterGrpcClient ¶ added in v2.3.3
func NewArchiveCenterGrpcClient(config *ArchiveCenterConfig, log utils.Logger) *ArchiveCenterGrpcClient
NewArchiveCenterGrpcClient 构造ArchiveCenterGrpcClient @param config @param log @return *ArchiveCenterGrpcClient
func (*ArchiveCenterGrpcClient) ArchiveBlock ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) ArchiveBlock(block *common.BlockInfo) error
ArchiveBlock 向归档中心提交一个归档区块 @param block @return error
func (*ArchiveCenterGrpcClient) ArchiveBlocks ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) ArchiveBlocks(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) error
ArchiveBlocks 向归档中心Stream提交要归档的区块 @param bi @return error
func (*ArchiveCenterGrpcClient) ArchiveCenterConfig ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) ArchiveCenterConfig() *ArchiveCenterConfig
ArchiveCenterConfig 获得配置参数 @return *ArchiveCenterConfig
func (*ArchiveCenterGrpcClient) Close ¶ added in v2.3.3
func (client *ArchiveCenterGrpcClient) Close() error
Close 关闭连接 @return error
func (*ArchiveCenterGrpcClient) GetArchivedStatus ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error)
GetArchivedStatus 获得归档中心的归档状态 @return archivedHeight @return inArchive @return code @return err
func (*ArchiveCenterGrpcClient) GetBlockByHash ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHash 根据Hash获得区块 @param blockHash @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveCenterGrpcClient) GetBlockByHeight ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHeight 根据高度获得区块 @param blockHeight @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveCenterGrpcClient) GetBlockByTxId ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
GetBlockByTxId 根据TxId获得所在区块 @param txId @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveCenterGrpcClient) GetChainConfigByBlockHeight ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
GetChainConfigByBlockHeight 获得链配置 @param blockHeight @return *config.ChainConfig @return error
func (*ArchiveCenterGrpcClient) GetTxByTxId ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
GetTxByTxId 根据TxId获得交易 @param txId @return *common.TransactionInfo @return error
func (*ArchiveCenterGrpcClient) GetTxWithRWSetByTxId ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
GetTxWithRWSetByTxId 根据TxId获得交易和读写集 @param txId @return *common.TransactionInfoWithRWSet @return error
func (*ArchiveCenterGrpcClient) GrpcCallOption ¶ added in v2.3.3
func (client *ArchiveCenterGrpcClient) GrpcCallOption() []grpc.CallOption
GrpcCallOption Grpc选项 @return []grpc.CallOption
func (*ArchiveCenterGrpcClient) Register ¶ added in v2.3.3
func (a *ArchiveCenterGrpcClient) Register(genesisBlock *common.BlockInfo) error
Register 将创世区块注册到归档中心 @param genesisBlock @return error
type ArchiveCenterHttpClient ¶ added in v2.3.3
type ArchiveCenterHttpClient struct {
// contains filtered or unexported fields
}
ArchiveCenterHttpClient 归档服务的归档中心HTTP客户端实现,只读
func NewArchiveCenterHttpClient ¶ added in v2.3.3
func NewArchiveCenterHttpClient(config *ArchiveCenterConfig, log utils.Logger) *ArchiveCenterHttpClient
NewArchiveCenterHttpClient ArchiveCenterHttpClient构造函数 @param config @param log @return *ArchiveCenterHttpClient
func (*ArchiveCenterHttpClient) ArchiveBlock ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) ArchiveBlock(block *common.BlockInfo) error
ArchiveBlock 只读查询,不支持归档区块 @param block @return error
func (*ArchiveCenterHttpClient) ArchiveBlocks ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) ArchiveBlocks(bi BlockIterator, _ func(ProcessMessage) error) error
ArchiveBlocks 只读查询,不支持归档区块 @param bi @return error
func (*ArchiveCenterHttpClient) ArchiveCenterConfig ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) ArchiveCenterConfig() *ArchiveCenterConfig
ArchiveCenterConfig 获得归档中心配置 @return *ArchiveCenterConfig
func (*ArchiveCenterHttpClient) Close ¶ added in v2.3.3
func (_ *ArchiveCenterHttpClient) Close() error
Close 关闭 @return error
func (*ArchiveCenterHttpClient) GetArchivedStatus ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error)
GetArchivedStatus 获得归档中心状态 @return archivedHeight @return inArchive @return code @return err
func (*ArchiveCenterHttpClient) GetBlockByHash ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHash 根据Hash获得区块 @param blockHash @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveCenterHttpClient) GetBlockByHeight ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHeight 根据高度获得区块 @param blockHeight @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveCenterHttpClient) GetBlockByTxId ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
GetBlockByTxId 根据TxId获得区块 @param txId @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveCenterHttpClient) GetChainConfigByBlockHeight ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
GetChainConfigByBlockHeight 根据高度获得链配置 @param blockHeight @return *config.ChainConfig @return error
func (*ArchiveCenterHttpClient) GetTxByTxId ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
GetTxByTxId 根据TxId获得交易 @param txId @return *common.TransactionInfo @return error
func (*ArchiveCenterHttpClient) GetTxWithRWSetByTxId ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
GetTxWithRWSetByTxId 根据TxId获得交易和读写集 @param txId @return *common.TransactionInfoWithRWSet @return error
func (*ArchiveCenterHttpClient) Register ¶ added in v2.3.3
func (a *ArchiveCenterHttpClient) Register(genesis *common.BlockInfo) error
Register 只读查询,不支持注册 @param genesis @return error
type ArchiveCenterQueryParam ¶ added in v2.3.3
type ArchiveCenterQueryParam struct { ChainGenesisHash string `json:"chain_genesis_hash,omitempty"` Start uint64 `json:"start,omitempty"` End uint64 `json:"end,omitempty"` BlockHash string `json:"block_hash,omitempty"` Height uint64 `json:"height,omitempty"` TxId string `json:"tx_id,omitempty"` WithRwSet bool `json:"with_rwset,omitempty"` TruncateLength int `json:"truncate_length,omitempty"` TruncateModel string `json:"truncate_model,omitempty"` }
ArchiveCenterQueryParam 定义归档中心通用请求头
type ArchiveCenterResponse ¶ added in v2.3.3
type ArchiveCenterResponse struct { Code int `json:"code"` // 错误码,0代表成功.其余代表失败 ErrorMsg string `json:"errorMsg"` }
ArchiveCenterResponse 定义了归档中心通用返回头信息
type ArchiveCenterResponseBlockHeader ¶ added in v2.3.3
type ArchiveCenterResponseBlockHeader struct { ArchiveCenterResponse Data *common.BlockHeader `json:"data"` }
ArchiveCenterResponseBlockHeader 定义区块头返回结构
type ArchiveCenterResponseBlockInfo ¶ added in v2.3.3
type ArchiveCenterResponseBlockInfo struct { ArchiveCenterResponse Data *common.BlockInfo `json:"data"` }
ArchiveCenterResponseBlockInfo 定义区块返回结构
type ArchiveCenterResponseBlockWithRwSet ¶ added in v2.3.3
type ArchiveCenterResponseBlockWithRwSet struct { ArchiveCenterResponse Data *common.BlockInfo `json:"data"` }
ArchiveCenterResponseBlockWithRwSet 定义带读写集区块
type ArchiveCenterResponseChainConfig ¶ added in v2.3.3
type ArchiveCenterResponseChainConfig struct { ArchiveCenterResponse Data *config.ChainConfig `json:"data"` }
ArchiveCenterResponseChainConfig 定义链配置返回结构
type ArchiveCenterResponseHeight ¶ added in v2.3.3
type ArchiveCenterResponseHeight struct { ArchiveCenterResponse Data *uint64 `json:"data"` }
ArchiveCenterResponseHeight 定义块高返回结构
type ArchiveCenterResponseMerklePath ¶ added in v2.3.3
type ArchiveCenterResponseMerklePath struct { ArchiveCenterResponse Data []byte `json:"data"` }
ArchiveCenterResponseMerklePath 定义merkle path 返回结构
type ArchiveCenterResponseTransaction ¶ added in v2.3.3
type ArchiveCenterResponseTransaction struct { ArchiveCenterResponse Data *common.TransactionInfo `json:"data"` }
ArchiveCenterResponseTransaction 定义交易返回结构
type ArchiveCenterResponseTransactionWithRwSet ¶ added in v2.3.3
type ArchiveCenterResponseTransactionWithRwSet struct { ArchiveCenterResponse Data *common.TransactionInfoWithRWSet `json:"data"` }
ArchiveCenterResponseTransactionWithRwSet 定义读写集交易
type ArchiveConfig ¶
type ArchiveConfig struct { Dest string // contains filtered or unexported fields }
ArchiveConfig Archive配置
func NewArchiveConfig ¶
func NewArchiveConfig(opts ...ArchiveOption) *ArchiveConfig
NewArchiveConfig new archive config
type ArchiveMySqlClient ¶ added in v2.3.3
type ArchiveMySqlClient struct {
// contains filtered or unexported fields
}
ArchiveMySqlClient 归档服务的MySQL客户端实现
func NewArchiveMySqlClient ¶ added in v2.3.3
func NewArchiveMySqlClient(chainId string, config *ArchiveConfig, cc SDKInterface, log utils.Logger) *ArchiveMySqlClient
NewArchiveMySqlClient creates a new ArchiveMySqlClient @param chainId @param config @param cc @param log @return *ArchiveMySqlClient
func NewArchiveMySqlClient2 ¶ added in v2.3.3
func NewArchiveMySqlClient2(chainId, dbDest string, secretKey string, cc SDKInterface, log utils.Logger) *ArchiveMySqlClient
NewArchiveMySqlClient2 creates a new ArchiveMySqlClient @param chainId @param dbDest @param secretKey @param cc @param log @return *ArchiveMySqlClient
func (*ArchiveMySqlClient) ArchiveBlock ¶ added in v2.3.3
func (a *ArchiveMySqlClient) ArchiveBlock(block *common.BlockInfo) error
ArchiveBlock 归档一个区块 @param block @return error
func (*ArchiveMySqlClient) ArchiveBlocks ¶ added in v2.3.3
func (a *ArchiveMySqlClient) ArchiveBlocks(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) error
ArchiveBlocks 归档多个区块 @param bi @param heightNoticeCallback @return error
func (*ArchiveMySqlClient) Close ¶ added in v2.3.4
func (a *ArchiveMySqlClient) Close() error
Close 关闭与归档数据源的链接 @return err
func (*ArchiveMySqlClient) GetArchivedStatus ¶ added in v2.3.3
func (a *ArchiveMySqlClient) GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error)
GetArchivedStatus get archived status @return archivedHeight @return inArchive @return code @return err
func (*ArchiveMySqlClient) GetBlockByHash ¶ added in v2.3.3
func (a *ArchiveMySqlClient) GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHash get block by hash @param blockHash @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveMySqlClient) GetBlockByHeight ¶ added in v2.3.3
func (a *ArchiveMySqlClient) GetBlockByHeight(height uint64, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHeight get block by height @param height @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveMySqlClient) GetBlockByTxId ¶ added in v2.3.3
GetBlockByTxId get block by txId @param txId @param withRWSet @return *common.BlockInfo @return error
func (*ArchiveMySqlClient) GetChainConfigByBlockHeight ¶ added in v2.3.3
func (a *ArchiveMySqlClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
GetChainConfigByBlockHeight get chain config by block height @param blockHeight @return *config.ChainConfig @return error
func (*ArchiveMySqlClient) GetTxByTxId ¶ added in v2.3.3
func (a *ArchiveMySqlClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
GetTxByTxId get transaction by txId @param txId @return *common.TransactionInfo @return error
func (*ArchiveMySqlClient) GetTxWithRWSetByTxId ¶ added in v2.3.3
func (a *ArchiveMySqlClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
GetTxWithRWSetByTxId get transaction with rwset by txId @param txId @return *common.TransactionInfoWithRWSet @return error
func (*ArchiveMySqlClient) Register ¶ added in v2.3.3
func (a *ArchiveMySqlClient) Register(genesis *common.BlockInfo) error
Register register archive client @param genesis @return error
type ArchiveOption ¶
type ArchiveOption func(config *ArchiveConfig)
ArchiveOption define archive option func
func WithDest ¶ added in v2.3.3
func WithDest(dest string) ArchiveOption
WithDest 设置Archive的目标路径 @param dest @return ArchiveOption
func WithSecretKey ¶
func WithSecretKey(key string) ArchiveOption
WithSecretKey 设置Archive的secret key
func WithType ¶ added in v2.3.3
func WithType(archiveType string) ArchiveOption
WithType 设置Archive的类型 @param archiveType @return ArchiveOption
type ArchiveService ¶ added in v2.3.3
type ArchiveService interface { // ## 2 系统合约接口 // ### 2.1 根据交易Id查询交易 // **参数说明** // - txId: 交易ID // “`go GetTxByTxId(txId string) (*common.TransactionInfo, error) // ### 2.2 根据交易Id查询包含rwset的交易 // **参数说明** // - txId: 交易ID // “`go GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error) // ### 2.3 根据区块高度查询区块 // **参数说明** // - blockHeight: 指定区块高度,若为-1,将返回最新区块 // - withRWSet: 是否返回读写集 // “`go GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error) // ### 2.5 根据区块哈希查询区块 // **参数说明** // - blockHash: 指定区块Hash // - withRWSet: 是否返回读写集 // “`go GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error) // ### 2.6 根据交易Id查询区块 // **参数说明** // - txId: 交易ID // - withRWSet: 是否返回读写集 // “`go GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error) // GetChainConfigByBlockHeight 获取指定高度的区块的配置 // @param blockHeight // @return *config.ChainConfig // @return error GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error) // Register 注册一个新的链到归档中心 // @param genesis 新链的创世区块 // @return error Register(genesis *common.BlockInfo) error // ArchiveBlock 归档一个区块 // @param block // @return error ArchiveBlock(block *common.BlockInfo) error // ArchiveBlocks 传入一个区块查询的迭代器,按顺序将区块归档 // @param bi 区块迭代器 // @return error ArchiveBlocks(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) error // GetArchivedStatus 获得归档的状态 // @return archivedHeight // @return inArchive // @return code // @return err GetArchivedStatus() (archivedHeight uint64, inArchive bool, code uint32, err error) // Close 关闭与归档数据源的链接 // @return err Close() error }
ArchiveService 归档服务
type BlockIterator ¶ added in v2.3.3
type BlockIterator interface { // Next 是否有下一个值 // @return bool Next() bool // Value 取值 // @return *common.BlockInfo // @return error Value() (*common.BlockInfo, error) // Release 释放资源 Release() // Total 总数 // @return uint64 Total() uint64 // Current 当前索引 // @return uint64 Current() uint64 }
BlockIterator 区块查询迭代器
type CertAliasSigner ¶ added in v2.3.0
type CertAliasSigner struct { PrivateKey crypto.PrivateKey Cert *bcx509.Certificate OrgId string CertAlias string }
CertAliasSigner define a cert alias signer in PermissionedWithCert mode
func (*CertAliasSigner) NewMember ¶ added in v2.3.0
func (signer *CertAliasSigner) NewMember() (*accesscontrol.Member, error)
NewMember new *accesscontrol.Member
type CertHashSigner ¶ added in v2.3.0
type CertHashSigner struct { PrivateKey crypto.PrivateKey Cert *bcx509.Certificate OrgId string CertHash []byte }
CertHashSigner define a cert hash signer in PermissionedWithCert mode
func (*CertHashSigner) NewMember ¶ added in v2.3.0
func (signer *CertHashSigner) NewMember() (*accesscontrol.Member, error)
NewMember new *accesscontrol.Member
type CertModeSigner ¶ added in v2.3.0
type CertModeSigner struct { PrivateKey crypto.PrivateKey Cert *bcx509.Certificate OrgId string }
CertModeSigner define a classic cert signer in PermissionedWithCert mode
func (*CertModeSigner) NewMember ¶ added in v2.3.0
func (signer *CertModeSigner) NewMember() (*accesscontrol.Member, error)
NewMember new *accesscontrol.Member
type ChainClient ¶
type ChainClient struct { ConfigModel *utils.ChainClientConfigModel // contains filtered or unexported fields }
ChainClient define chainmaker chain client to interact with node
func CreateChainClient ¶
func CreateChainClient(pool ConnectionPool, userCrtBytes, privKey, userCrtHash []byte, orgId, chainId string, enabledCrtHash int) (*ChainClient, error)
CreateChainClient create chain client and init chain client, returns *ChainClient
func NewChainClient ¶
func NewChainClient(opts ...ChainClientOption) (*ChainClient, error)
NewChainClient new chain client
func (*ChainClient) AddAlias ¶ added in v2.2.0
func (cc *ChainClient) AddAlias() (*common.TxResponse, error)
AddAlias add cert alias to block chain network
func (*ChainClient) AddCert ¶
func (cc *ChainClient) AddCert() (*common.TxResponse, error)
AddCert add ChainClient myself cert hash to chain
func (*ChainClient) ArchiveBlocks ¶ added in v2.3.3
func (cc *ChainClient) ArchiveBlocks(archiveHeight uint64, mode string, heightNotice func(ProcessMessage) error) error
ArchiveBlocks 归档指定区块高度范围的区块 @param beginHeight @param endHeight @param mode @param heightNotice @return error
func (*ChainClient) ArchiveCenterConfig ¶ added in v2.3.3
func (cc *ChainClient) ArchiveCenterConfig() *ArchiveCenterConfig
ArchiveCenterConfig 获取归档中心的配置信息
func (*ChainClient) AttachGasLimit ¶ added in v2.2.0
AttachGasLimit attach gas limit for payload
func (*ChainClient) ChangeSigner ¶ added in v2.2.0
func (cc *ChainClient) ChangeSigner(signerPrivKey crypto.PrivateKey, signerCrt *bcx509.Certificate, publicModeHashType crypto.HashType) error
ChangeSigner change ChainClient siger. signerCrt passes nil in Public or PermissionedWithKey mode publicModeHashType must be set in Public mode else set to zero value.
func (*ChainClient) CheckCallerCertAuth ¶
func (cc *ChainClient) CheckCallerCertAuth(payload string, orgIds []string, signPairs []*syscontract.SignInfo) ( *common.TxResponse, error)
CheckCallerCertAuth CheckCallerCertAuth
func (*ChainClient) CheckNewBlockChainConfig ¶
func (cc *ChainClient) CheckNewBlockChainConfig() error
CheckNewBlockChainConfig check chain configuration and load new chain dynamically
func (*ChainClient) CreateArchiveBlockPayload ¶
func (cc *ChainClient) CreateArchiveBlockPayload(targetBlockHeight uint64) (*common.Payload, error)
CreateArchiveBlockPayload create `archive block` payload
func (*ChainClient) CreateCertManageFrozenPayload ¶
func (cc *ChainClient) CreateCertManageFrozenPayload(certs []string) *common.Payload
CreateCertManageFrozenPayload create `cert manage frozen` payload
func (*ChainClient) CreateCertManagePayload ¶
func (cc *ChainClient) CreateCertManagePayload(method string, kvs []*common.KeyValuePair) *common.Payload
CreateCertManagePayload create `cert manage` payload
func (*ChainClient) CreateCertManageRevocationPayload ¶
func (cc *ChainClient) CreateCertManageRevocationPayload(certCrl string) *common.Payload
CreateCertManageRevocationPayload create `cert manage revocation` payload
func (*ChainClient) CreateCertManageUnfrozenPayload ¶
func (cc *ChainClient) CreateCertManageUnfrozenPayload(certs []string) *common.Payload
CreateCertManageUnfrozenPayload create `cert manage unfrozen` payload
func (*ChainClient) CreateChainConfigAlterAddrTypePayload ¶ added in v2.2.0
func (cc *ChainClient) CreateChainConfigAlterAddrTypePayload(addrType string) (*common.Payload, error)
CreateChainConfigAlterAddrTypePayload create chain config alter address type payload
func (*ChainClient) CreateChainConfigBlockUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigBlockUpdatePayload(txTimestampVerify, blockTimestampVerify bool, txTimeout, blockTimeout, blockTxCapacity, blockSize, blockInterval, txParamterSize uint32) (*common.Payload, error)
CreateChainConfigBlockUpdatePayload create chain config block update payload
func (*ChainClient) CreateChainConfigConsensusExtAddPayload ¶
func (cc *ChainClient) CreateChainConfigConsensusExtAddPayload(kvs []*common.KeyValuePair) (*common.Payload, error)
CreateChainConfigConsensusExtAddPayload create chain config consensus ext add payload
func (*ChainClient) CreateChainConfigConsensusExtDeletePayload ¶
func (cc *ChainClient) CreateChainConfigConsensusExtDeletePayload(keys []string) (*common.Payload, error)
CreateChainConfigConsensusExtDeletePayload create chain config consensus ext delete payload
func (*ChainClient) CreateChainConfigConsensusExtUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigConsensusExtUpdatePayload(kvs []*common.KeyValuePair) (*common.Payload, error)
CreateChainConfigConsensusExtUpdatePayload create chain config consensus ext update payload
func (*ChainClient) CreateChainConfigConsensusNodeIdAddPayload ¶
func (cc *ChainClient) CreateChainConfigConsensusNodeIdAddPayload(nodeOrgId string, nodeIds []string) (*common.Payload, error)
CreateChainConfigConsensusNodeIdAddPayload create chain config consensus node id add payload
func (*ChainClient) CreateChainConfigConsensusNodeIdDeletePayload ¶
func (cc *ChainClient) CreateChainConfigConsensusNodeIdDeletePayload(nodeOrgId, nodeId string) (*common.Payload, error)
CreateChainConfigConsensusNodeIdDeletePayload create chain config consensus node id delete payload
func (*ChainClient) CreateChainConfigConsensusNodeIdUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigConsensusNodeIdUpdatePayload(nodeOrgId, nodeOldIds, nodeNewIds string) (*common.Payload, error)
CreateChainConfigConsensusNodeIdUpdatePayload create chain config consensus node id update payload
func (*ChainClient) CreateChainConfigConsensusNodeOrgAddPayload ¶
func (cc *ChainClient) CreateChainConfigConsensusNodeOrgAddPayload(nodeOrgId string, nodeIds []string) (*common.Payload, error)
CreateChainConfigConsensusNodeOrgAddPayload create chain config consensus node org add payload
func (*ChainClient) CreateChainConfigConsensusNodeOrgDeletePayload ¶
func (cc *ChainClient) CreateChainConfigConsensusNodeOrgDeletePayload(nodeOrgId string) (*common.Payload, error)
CreateChainConfigConsensusNodeOrgDeletePayload create chain config consensus node org delete payload
func (*ChainClient) CreateChainConfigConsensusNodeOrgUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigConsensusNodeOrgUpdatePayload(nodeOrgId string, nodeIds []string) (*common.Payload, error)
CreateChainConfigConsensusNodeOrgUpdatePayload create chain config consensus node org update payload
func (*ChainClient) CreateChainConfigCoreUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigCoreUpdatePayload(txSchedulerTimeout, txSchedulerValidateTimeout uint64) (*common.Payload, error)
CreateChainConfigCoreUpdatePayload create chain config core update payload
func (*ChainClient) CreateChainConfigEnableMultiSignManualRunPayload ¶ added in v2.3.2
func (cc *ChainClient) CreateChainConfigEnableMultiSignManualRunPayload(enable bool) (*common.Payload, error)
CreateChainConfigEnableMultiSignManualRunPayload create chain config for multi-sign to `enable_manual_run` flag payload
func (*ChainClient) CreateChainConfigEnableOrDisableGasPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateChainConfigEnableOrDisableGasPayload() (*common.Payload, error)
CreateChainConfigEnableOrDisableGasPayload create chain config enable or disable gas payload
func (*ChainClient) CreateChainConfigOptimizeChargeGasPayload ¶ added in v2.3.0
func (cc *ChainClient) CreateChainConfigOptimizeChargeGasPayload(enable bool) (*common.Payload, error)
CreateChainConfigOptimizeChargeGasPayload create chain config optimize charge gas payload
func (*ChainClient) CreateChainConfigPermissionAddPayload ¶
func (cc *ChainClient) CreateChainConfigPermissionAddPayload(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error)
CreateChainConfigPermissionAddPayload create chain config permission add payload
func (*ChainClient) CreateChainConfigPermissionDeletePayload ¶
func (cc *ChainClient) CreateChainConfigPermissionDeletePayload(resourceName string) (*common.Payload, error)
CreateChainConfigPermissionDeletePayload create chain config permission delete payload
func (*ChainClient) CreateChainConfigPermissionUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigPermissionUpdatePayload(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error)
CreateChainConfigPermissionUpdatePayload create chain config permission update payload
func (*ChainClient) CreateChainConfigTrustMemberAddPayload ¶
func (cc *ChainClient) CreateChainConfigTrustMemberAddPayload(trustMemberOrgId, trustMemberNodeId, trustMemberRole, trustMemberInfo string) (*common.Payload, error)
CreateChainConfigTrustMemberAddPayload create chain config trust member add payload
func (*ChainClient) CreateChainConfigTrustMemberDeletePayload ¶
func (cc *ChainClient) CreateChainConfigTrustMemberDeletePayload(trustMemberInfo string) (*common.Payload, error)
CreateChainConfigTrustMemberDeletePayload create chain config trust member delete payload
func (*ChainClient) CreateChainConfigTrustRootAddPayload ¶
func (cc *ChainClient) CreateChainConfigTrustRootAddPayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)
CreateChainConfigTrustRootAddPayload create chain config trust root add payload
func (*ChainClient) CreateChainConfigTrustRootDeletePayload ¶
func (cc *ChainClient) CreateChainConfigTrustRootDeletePayload(orgIdOrPKPubkeyPEM string) (*common.Payload, error)
CreateChainConfigTrustRootDeletePayload create chain config trust root delete payload
func (*ChainClient) CreateChainConfigTrustRootUpdatePayload ¶
func (cc *ChainClient) CreateChainConfigTrustRootUpdatePayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)
CreateChainConfigTrustRootUpdatePayload create chain config trust root update payload
func (*ChainClient) CreateContractCreatePayload ¶
func (cc *ChainClient) CreateContractCreatePayload(contractName, version, byteCodeStringOrFilePath string, runtime common.RuntimeType, kvs []*common.KeyValuePair) (*common.Payload, error)
CreateContractCreatePayload create user contract creation payload
func (*ChainClient) CreateContractFreezePayload ¶
func (cc *ChainClient) CreateContractFreezePayload(contractName string) (*common.Payload, error)
CreateContractFreezePayload create user contract freeze payload
func (*ChainClient) CreateContractRevokePayload ¶
func (cc *ChainClient) CreateContractRevokePayload(contractName string) (*common.Payload, error)
CreateContractRevokePayload create user contract revoke payload
func (*ChainClient) CreateContractUnfreezePayload ¶
func (cc *ChainClient) CreateContractUnfreezePayload(contractName string) (*common.Payload, error)
CreateContractUnfreezePayload create user contract unfreeze payload
func (*ChainClient) CreateContractUpgradePayload ¶
func (cc *ChainClient) CreateContractUpgradePayload(contractName, version, byteCodeStringOrFilePath string, runtime common.RuntimeType, kvs []*common.KeyValuePair) (*common.Payload, error)
CreateContractUpgradePayload create user contract upgrade payload
func (*ChainClient) CreateDeleteCertsAliasPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateDeleteCertsAliasPayload(aliases []string) *common.Payload
CreateDeleteCertsAliasPayload create `delete certs alias` payload
func (*ChainClient) CreateFrozenGasAccountPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateFrozenGasAccountPayload(address string) (*common.Payload, error)
CreateFrozenGasAccountPayload create frozen gas account payload
func (*ChainClient) CreateHibeInitParamsTxPayloadParams ¶
func (cc *ChainClient) CreateHibeInitParamsTxPayloadParams(orgId string, hibeParams []byte) ([]*common.KeyValuePair, error)
CreateHibeInitParamsTxPayloadParams CreateHibeInitParamsTxPayloadParams
func (*ChainClient) CreateHibeTxPayloadParamsWithHibeParams ¶
func (cc *ChainClient) CreateHibeTxPayloadParamsWithHibeParams(plaintext []byte, receiverIds []string, paramsBytesList [][]byte, txId string, keyType crypto.KeyType) ([]*common.KeyValuePair, error)
CreateHibeTxPayloadParamsWithHibeParams CreateHibeTxPayloadParamsWithHibeParams
func (*ChainClient) CreateHibeTxPayloadParamsWithoutHibeParams ¶
func (cc *ChainClient) CreateHibeTxPayloadParamsWithoutHibeParams(contractName, queryParamsMethod string, plaintext []byte, receiverIds []string, receiverOrgIds []string, txId string, keyType crypto.KeyType, timeout int64) ([]*common.KeyValuePair, error)
CreateHibeTxPayloadParamsWithoutHibeParams CreateHibeTxPayloadParamsWithoutHibeParams
func (*ChainClient) CreateMultiSignReqPayload ¶ added in v2.1.0
func (cc *ChainClient) CreateMultiSignReqPayload( pairs []*common.KeyValuePair) *common.Payload
CreateMultiSignReqPayload create multi sign req payload
func (*ChainClient) CreateMultiSignReqPayloadWithGasLimit ¶ added in v2.3.3
func (cc *ChainClient) CreateMultiSignReqPayloadWithGasLimit( pairs []*common.KeyValuePair, gasLimit uint64) *common.Payload
CreateMultiSignReqPayloadWithGasLimit create multi sign req payload
func (*ChainClient) CreateNativeContractAccessGrantPayload ¶ added in v2.1.0
func (cc *ChainClient) CreateNativeContractAccessGrantPayload(grantContractList []string) (*common.Payload, error)
CreateNativeContractAccessGrantPayload create `native contract access grant` payload for grant access to a native contract
func (*ChainClient) CreateNativeContractAccessRevokePayload ¶ added in v2.1.0
func (cc *ChainClient) CreateNativeContractAccessRevokePayload(revokeContractList []string) (*common.Payload, error)
CreateNativeContractAccessRevokePayload create `native contract access revoke` payload for revoke access to a native contract
func (*ChainClient) CreatePayload ¶ added in v2.2.0
func (cc *ChainClient) CreatePayload(txId string, txType common.TxType, contractName, method string, kvs []*common.KeyValuePair, seq uint64, limit *common.Limit) *common.Payload
CreatePayload create unsigned payload
func (*ChainClient) CreatePubkeyAddPayload ¶ added in v2.1.0
func (cc *ChainClient) CreatePubkeyAddPayload(pubkey string, orgId string, role string) (*common.Payload, error)
CreatePubkeyAddPayload create pubkey add payload
func (*ChainClient) CreatePubkeyDelPayload ¶ added in v2.1.0
CreatePubkeyDelPayload create pubkey delete payload
func (*ChainClient) CreatePubkeyQueryPayload ¶ added in v2.1.0
func (cc *ChainClient) CreatePubkeyQueryPayload(pubkey string) (*common.Payload, error)
CreatePubkeyQueryPayload create pubkey query payload
func (*ChainClient) CreateRechargeGasPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateRechargeGasPayload(rechargeGasList []*syscontract.RechargeGas) (*common.Payload, error)
CreateRechargeGasPayload create recharge gas payload
func (*ChainClient) CreateRefundGasPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateRefundGasPayload(address string, amount int64) (*common.Payload, error)
CreateRefundGasPayload create refund gas payload
func (*ChainClient) CreateRestoreBlockPayload ¶
func (cc *ChainClient) CreateRestoreBlockPayload(fullBlock []byte) (*common.Payload, error)
CreateRestoreBlockPayload create `restore block` payload
func (*ChainClient) CreateRestoreBlocksPayload ¶ added in v2.3.3
func (cc *ChainClient) CreateRestoreBlocksPayload(fullBlocks [][]byte) (*common.Payload, error)
CreateRestoreBlocksPayload create `restore blocks` payload
func (*ChainClient) CreateSaveEnclaveCACertPayload ¶
func (cc *ChainClient) CreateSaveEnclaveCACertPayload(enclaveCACert string, txId string) (*common.Payload, error)
CreateSaveEnclaveCACertPayload CreateSaveEnclaveCACertPayload
func (*ChainClient) CreateSaveEnclaveReportPayload ¶
func (cc *ChainClient) CreateSaveEnclaveReportPayload(enclaveId, report, txId string) (*common.Payload, error)
CreateSaveEnclaveReportPayload CreateSaveEnclaveReportPayload
func (*ChainClient) CreateSetGasAdminPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateSetGasAdminPayload(address string) (*common.Payload, error)
CreateSetGasAdminPayload create set gas admin payload
func (*ChainClient) CreateSetInstallBaseGasPayload ¶ added in v2.3.3
func (cc *ChainClient) CreateSetInstallBaseGasPayload(amount int64) (*common.Payload, error)
CreateSetInstallBaseGasPayload create set_install_base_gas payload
func (*ChainClient) CreateSetInstallGasPricePayload ¶ added in v2.3.3
func (cc *ChainClient) CreateSetInstallGasPricePayload(gasPrice string) (*common.Payload, error)
CreateSetInstallGasPricePayload create set_install_gas_price payload
func (*ChainClient) CreateSetInvokeBaseGasPayload ¶ added in v2.3.0
func (cc *ChainClient) CreateSetInvokeBaseGasPayload(amount int64) (*common.Payload, error)
CreateSetInvokeBaseGasPayload create set invoke base gas payload
func (*ChainClient) CreateSetInvokeGasPricePayload ¶ added in v2.3.3
func (cc *ChainClient) CreateSetInvokeGasPricePayload(gasPrice string) (*common.Payload, error)
CreateSetInvokeGasPricePayload create set invoke gas price payload
func (*ChainClient) CreateSubscribeBlockPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateSubscribeBlockPayload(startBlock, endBlock int64, withRWSet, onlyHeader bool) *common.Payload
CreateSubscribeBlockPayload create subscribe block payload
func (*ChainClient) CreateSubscribeContractEventPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateSubscribeContractEventPayload(startBlock, endBlock int64, contractName, topic string) *common.Payload
CreateSubscribeContractEventPayload create subscribe contract event payload
func (*ChainClient) CreateSubscribeTxPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateSubscribeTxPayload(startBlock, endBlock int64, contractName string, txIds []string) *common.Payload
CreateSubscribeTxPayload create subscribe tx payload
func (*ChainClient) CreateUnfrozenGasAccountPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateUnfrozenGasAccountPayload(address string) (*common.Payload, error)
CreateUnfrozenGasAccountPayload create unfrozen gas account payload
func (*ChainClient) CreateUpdateCertByAliasPayload ¶ added in v2.2.0
func (cc *ChainClient) CreateUpdateCertByAliasPayload(alias, newCertPEM string) *common.Payload
CreateUpdateCertByAliasPayload create `update cert by alias` payload
func (*ChainClient) DecryptHibeTxByTxId ¶
func (cc *ChainClient) DecryptHibeTxByTxId(localId string, hibeParams []byte, hibePrvKey []byte, txId string, keyType crypto.KeyType) ([]byte, error)
DecryptHibeTxByTxId DecryptHibeTxByTxId
func (*ChainClient) DeleteCert ¶
func (cc *ChainClient) DeleteCert(certHashes []string) (*common.TxResponse, error)
DeleteCert delete myself cert hash on chain
func (*ChainClient) DeleteCertsAlias ¶ added in v2.2.0
func (cc *ChainClient) DeleteCertsAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
DeleteCertsAlias delete certs alias on chain
func (*ChainClient) DisableCertHash ¶
func (cc *ChainClient) DisableCertHash() error
DisableCertHash disable cert hash logic
func (*ChainClient) EasyCodecItemToParamsMap ¶
func (cc *ChainClient) EasyCodecItemToParamsMap(items []*serialize.EasyCodecItem) map[string][]byte
EasyCodecItemToParamsMap easy codec items to params map
func (*ChainClient) EnableAlias ¶ added in v2.2.0
func (cc *ChainClient) EnableAlias() error
EnableAlias enable cert alias logic
func (*ChainClient) EnableCertHash ¶
func (cc *ChainClient) EnableCertHash() error
EnableCertHash Cert Hash logic
func (*ChainClient) EstimateGas ¶ added in v2.3.0
func (cc *ChainClient) EstimateGas(payload *common.Payload) (uint64, error)
EstimateGas estimate gas used of payload
func (*ChainClient) GenerateTxRequest ¶ added in v2.2.0
func (cc *ChainClient) GenerateTxRequest(payload *common.Payload, endorsers []*common.EndorsementEntry) (*common.TxRequest, error)
GenerateTxRequest sign payload and generate *common.TxRequest
func (*ChainClient) GenerateTxRequestBySigner ¶ added in v2.3.0
func (cc *ChainClient) GenerateTxRequestBySigner(payload *common.Payload, endorsers []*common.EndorsementEntry, signer Signer) (*common.TxRequest, error)
GenerateTxRequestBySigner sign payload and generate *common.TxRequest use signer to sign payload if it is not nil. use cc.privateKey to sign payload if signer is nil.
func (*ChainClient) GenerateTxRequestWithPayer ¶ added in v2.3.3
func (cc *ChainClient) GenerateTxRequestWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, payer *common.EndorsementEntry) (*common.TxRequest, error)
GenerateTxRequestWithPayer sign payload and generate *common.TxRequest with payer
func (*ChainClient) GetArchiveService ¶ added in v2.3.3
func (cc *ChainClient) GetArchiveService() ArchiveService
GetArchiveService 获取归档中心服务 lazy load @return ArchiveService
func (*ChainClient) GetArchiveStatus ¶ added in v2.3.3
func (cc *ChainClient) GetArchiveStatus() (*store.ArchiveStatus, error)
GetArchiveStatus get peer archive status
func (*ChainClient) GetArchivedBlockByHash ¶
func (cc *ChainClient) GetArchivedBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error)
GetArchivedBlockByHash get archived block by block hash, returns *common.BlockInfo
func (*ChainClient) GetArchivedBlockByHeight ¶
func (cc *ChainClient) GetArchivedBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
GetArchivedBlockByHeight get archived block by block height, returns *common.BlockInfo
func (*ChainClient) GetArchivedBlockByTxId ¶
func (cc *ChainClient) GetArchivedBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error)
GetArchivedBlockByTxId get archived block by tx id, returns *common.BlockInfo
func (*ChainClient) GetArchivedBlockHeight ¶
func (cc *ChainClient) GetArchivedBlockHeight() (uint64, error)
GetArchivedBlockHeight get archived block height
func (*ChainClient) GetArchivedTxByTxId ¶
func (cc *ChainClient) GetArchivedTxByTxId(txId string) (*common.TransactionInfo, error)
GetArchivedTxByTxId get archived tx by tx id, returns *common.TransactionInfo
func (*ChainClient) GetAuthType ¶ added in v2.1.0
func (cc *ChainClient) GetAuthType() AuthType
GetAuthType get auth type of cc
func (*ChainClient) GetBlockByHash ¶
GetBlockByHash get block by block hash, returns *common.BlockInfo
func (*ChainClient) GetBlockByHeight ¶
func (cc *ChainClient) GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)
GetBlockByHeight get block by block height, returns *common.BlockInfo
func (*ChainClient) GetBlockByHeightTruncate ¶ added in v2.3.0
func (cc *ChainClient) GetBlockByHeightTruncate(blockHeight uint64, withRWSet bool, truncateLength int, truncateModel string) (*common.BlockInfo, error)
GetBlockByHeightTruncate 根据区块高度获得区块,应对超大block,可设置返回block的截断规则。 @param blockHeight @param withRWSet @param truncateLength 截断的长度设置,如果此参数为>0,超过此长度的剩余数据将被丢弃。如果<=0则不截断 @param truncateModel 截断的模式设置:hash,truncate,empty @return *common.BlockInfo @return error
func (*ChainClient) GetBlockByTxId ¶
GetBlockByTxId get block by tx id, returns *common.BlockInfo
func (*ChainClient) GetBlockHeaderByHeight ¶
func (cc *ChainClient) GetBlockHeaderByHeight(blockHeight uint64) (*common.BlockHeader, error)
GetBlockHeaderByHeight get block header by block height
func (*ChainClient) GetBlockHeightByHash ¶
func (cc *ChainClient) GetBlockHeightByHash(blockHash string) (uint64, error)
GetBlockHeightByHash get block height by block hash
func (*ChainClient) GetBlockHeightByTxId ¶
func (cc *ChainClient) GetBlockHeightByTxId(txId string) (uint64, error)
GetBlockHeightByTxId get block height by tx id
func (*ChainClient) GetCertHash ¶
func (cc *ChainClient) GetCertHash() ([]byte, error)
GetCertHash get cert hash on chain
func (*ChainClient) GetCertPEM ¶ added in v2.2.0
func (cc *ChainClient) GetCertPEM() []byte
GetCertPEM get cert pem of cc
func (*ChainClient) GetChainConfig ¶
func (cc *ChainClient) GetChainConfig() (*config.ChainConfig, error)
GetChainConfig get chain config
func (*ChainClient) GetChainConfigByBlockHeight ¶
func (cc *ChainClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)
GetChainConfigByBlockHeight get chain config by block height
func (*ChainClient) GetChainConfigPermissionList ¶ added in v2.3.0
func (cc *ChainClient) GetChainConfigPermissionList() ([]*config.ResourcePolicy, error)
GetChainConfigPermissionList get chain config
func (*ChainClient) GetChainConfigSequence ¶
func (cc *ChainClient) GetChainConfigSequence() (uint64, error)
GetChainConfigSequence get chain config sequence
func (*ChainClient) GetChainInfo ¶
func (cc *ChainClient) GetChainInfo() (*discovery.ChainInfo, error)
GetChainInfo get chain info
func (*ChainClient) GetChainMakerServerVersion ¶
func (cc *ChainClient) GetChainMakerServerVersion() (string, error)
GetChainMakerServerVersion get chainmaker version
func (*ChainClient) GetChainMakerServerVersionCustom ¶ added in v2.3.3
func (cc *ChainClient) GetChainMakerServerVersionCustom(ctx context.Context) (string, error)
GetChainMakerServerVersionCustom get chainmaker version
func (*ChainClient) GetConsensusHeight ¶ added in v2.3.5
func (cc *ChainClient) GetConsensusHeight() (uint64, error)
GetConsensusHeight returns the current block height of consensus
func (*ChainClient) GetConsensusStateJSON ¶ added in v2.3.5
func (cc *ChainClient) GetConsensusStateJSON() ([]byte, error)
GetConsensusStateJSON returns state json of consensus
func (*ChainClient) GetConsensusValidators ¶ added in v2.3.5
func (cc *ChainClient) GetConsensusValidators() ([]string, error)
GetConsensusValidators returns consensus validators
func (*ChainClient) GetContract ¶
func (cc *ChainClient) GetContract(contractName, codeHash string) (*common.PrivateGetContract, error)
GetContract GetContract
func (*ChainClient) GetContractInfo ¶ added in v2.1.0
func (cc *ChainClient) GetContractInfo(contractName string) (*common.Contract, error)
GetContractInfo get contract info by contract name, returns *common.Contract
func (*ChainClient) GetContractList ¶ added in v2.1.0
func (cc *ChainClient) GetContractList() ([]*common.Contract, error)
GetContractList get all contracts from block chain, include user contract and system contract
func (*ChainClient) GetCurrentBlockHeight ¶
func (cc *ChainClient) GetCurrentBlockHeight() (uint64, error)
GetCurrentBlockHeight get current block height
func (*ChainClient) GetData ¶
func (cc *ChainClient) GetData(contractName, key string) ([]byte, error)
GetData GetData
func (*ChainClient) GetDir ¶
func (cc *ChainClient) GetDir(orderId string) ([]byte, error)
GetDir GetDir
func (*ChainClient) GetDisabledNativeContractList ¶ added in v2.1.0
func (cc *ChainClient) GetDisabledNativeContractList() ([]string, error)
GetDisabledNativeContractList get all disabled native contracts, returns contracts name list
func (*ChainClient) GetEnabledCrtHash ¶
func (cc *ChainClient) GetEnabledCrtHash() bool
GetEnabledCrtHash check whether the cert hash logic is enabled
func (*ChainClient) GetEnclaveCACert ¶
func (cc *ChainClient) GetEnclaveCACert() ([]byte, error)
GetEnclaveCACert GetEnclaveCACert
func (*ChainClient) GetEnclaveChallenge ¶
func (cc *ChainClient) GetEnclaveChallenge(enclaveId string) ([]byte, error)
GetEnclaveChallenge GetEnclaveChallenge
func (*ChainClient) GetEnclaveEncryptPubKey ¶
func (cc *ChainClient) GetEnclaveEncryptPubKey(enclaveId string) ([]byte, error)
GetEnclaveEncryptPubKey GetEnclaveEncryptPubKey
func (*ChainClient) GetEnclaveProof ¶
func (cc *ChainClient) GetEnclaveProof(enclaveId string) ([]byte, error)
GetEnclaveProof GetEnclaveProof
func (*ChainClient) GetEnclaveReport ¶
func (cc *ChainClient) GetEnclaveReport(enclaveId string) ([]byte, error)
GetEnclaveReport GetEnclaveReport
func (*ChainClient) GetEnclaveSignature ¶
func (cc *ChainClient) GetEnclaveSignature(enclaveId string) ([]byte, error)
GetEnclaveSignature GetEnclaveSignature
func (*ChainClient) GetEnclaveVerificationPubKey ¶
func (cc *ChainClient) GetEnclaveVerificationPubKey(enclaveId string) ([]byte, error)
GetEnclaveVerificationPubKey GetEnclaveVerificationPubKey
func (*ChainClient) GetFullBlockByHeight ¶
func (cc *ChainClient) GetFullBlockByHeight(blockHeight uint64) (*store.BlockWithRWSet, error)
GetFullBlockByHeight Deprecated, get full block by block height, returns *store.BlockWithRWSet
func (*ChainClient) GetGasAccountStatus ¶ added in v2.2.0
func (cc *ChainClient) GetGasAccountStatus(address string) (bool, error)
GetGasAccountStatus get gas account status
func (*ChainClient) GetGasAdmin ¶ added in v2.2.0
func (cc *ChainClient) GetGasAdmin() (string, error)
GetGasAdmin get gas admin on chain, returns gas admin address
func (*ChainClient) GetGasBalance ¶ added in v2.2.0
func (cc *ChainClient) GetGasBalance(address string) (int64, error)
GetGasBalance returns gas balance of address
func (*ChainClient) GetHashType ¶ added in v2.1.0
func (cc *ChainClient) GetHashType() crypto.HashType
GetHashType get hash type of cc
func (*ChainClient) GetLastBlock ¶
func (cc *ChainClient) GetLastBlock(withRWSet bool) (*common.BlockInfo, error)
GetLastBlock get last block
func (*ChainClient) GetLastConfigBlock ¶
func (cc *ChainClient) GetLastConfigBlock(withRWSet bool) (*common.BlockInfo, error)
GetLastConfigBlock get last config block
func (*ChainClient) GetLocalCertAlias ¶ added in v2.2.0
func (cc *ChainClient) GetLocalCertAlias() string
GetLocalCertAlias get local cert alias of cc
func (*ChainClient) GetMerklePathByTxId ¶ added in v2.1.0
func (cc *ChainClient) GetMerklePathByTxId(txId string) ([]byte, error)
GetMerklePathByTxId get merkle path by tx id
func (*ChainClient) GetNodeChainList ¶
func (cc *ChainClient) GetNodeChainList() (*discovery.ChainList, error)
GetNodeChainList get node chain list
func (*ChainClient) GetPoolStatus ¶ added in v2.3.0
func (cc *ChainClient) GetPoolStatus() (*txpool.TxPoolStatus, error)
GetPoolStatus Returns the max size of config transaction pool and common transaction pool, the num of config transaction in queue and pendingCache, and the the num of common transaction in queue and pendingCache.
func (*ChainClient) GetPrivateKey ¶ added in v2.2.0
func (cc *ChainClient) GetPrivateKey() crypto.PrivateKey
GetPrivateKey get private key of cc
func (*ChainClient) GetPublicKey ¶ added in v2.2.0
func (cc *ChainClient) GetPublicKey() crypto.PublicKey
GetPublicKey get public key of cc
func (*ChainClient) GetSyncResult ¶ added in v2.2.0
GetSyncResult get sync result of tx
func (*ChainClient) GetTxByTxId ¶
func (cc *ChainClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)
GetTxByTxId get tx by tx id, returns *common.TransactionInfo
func (*ChainClient) GetTxByTxIdTruncate ¶ added in v2.3.0
func (cc *ChainClient) GetTxByTxIdTruncate(txId string, withRWSet bool, truncateLength int, truncateModel string) (*common.TransactionInfoWithRWSet, error)
GetTxByTxIdTruncate 根据TxId获得Transaction对象,并根据参数进行截断 @param txId @param withRWSet @param truncateLength @param truncateModel @return *common.TransactionInfoWithRWSet @return error
func (*ChainClient) GetTxIdsByTypeAndStage ¶ added in v2.3.0
func (cc *ChainClient) GetTxIdsByTypeAndStage(txType txpool.TxType, txStage txpool.TxStage) ([]string, error)
GetTxIdsByTypeAndStage Returns config or common txIds in different stage. txType may be TxType_CONFIG_TX, TxType_COMMON_TX, (TxType_CONFIG_TX|TxType_COMMON_TX) txStage may be TxStage_IN_QUEUE, TxStage_IN_PENDING, (TxStage_IN_QUEUE|TxStage_IN_PENDING)
func (*ChainClient) GetTxRequest ¶
func (cc *ChainClient) GetTxRequest(contractName, method, txId string, kvs []*common.KeyValuePair) ( *common.TxRequest, error)
GetTxRequest build tx request, returns *common.TxRequest
func (*ChainClient) GetTxWithRWSetByTxId ¶ added in v2.2.0
func (cc *ChainClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)
GetTxWithRWSetByTxId get tx with rwset by tx id
func (*ChainClient) GetTxsInPoolByTxIds ¶ added in v2.3.0
func (cc *ChainClient) GetTxsInPoolByTxIds(txIds []string) ([]*common.Transaction, []string, error)
GetTxsInPoolByTxIds Retrieve the transactions by the txIds from the txPool, return transactions in the txPool and txIds not in txPool. default query upper limit is 1w transaction, and error is returned if the limit is exceeded.
func (*ChainClient) GetUserCrtHash ¶
func (cc *ChainClient) GetUserCrtHash() []byte
GetUserCrtHash get user cert hash of cc
func (*ChainClient) InvokeContract ¶
func (cc *ChainClient) InvokeContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool) (*common.TxResponse, error)
InvokeContract invoke contract
func (*ChainClient) InvokeContractBySigner ¶ added in v2.3.0
func (cc *ChainClient) InvokeContractBySigner(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool, limit *common.Limit, signer Signer) (*common.TxResponse, error)
InvokeContractBySigner invoke contract with specified signer. use signer to sign payload if it is not nil. use cc.privateKey to sign payload if signer is nil.
func (*ChainClient) InvokeContractWithLimit ¶ added in v2.2.0
func (cc *ChainClient) InvokeContractWithLimit(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool, limit *common.Limit) (*common.TxResponse, error)
InvokeContractWithLimit invoke contract with specified gas limit
func (*ChainClient) InvokeSystemContract ¶
func (cc *ChainClient) InvokeSystemContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool) (*common.TxResponse, error)
InvokeSystemContract invoke system contract
func (*ChainClient) IsArchiveCenterQueryFist ¶ added in v2.3.3
func (cc *ChainClient) IsArchiveCenterQueryFist() bool
IsArchiveCenterQueryFist check whether to query archive data from archivecenter first
func (*ChainClient) IsEnableNormalKey ¶ added in v2.2.1
func (cc *ChainClient) IsEnableNormalKey() bool
IsEnableNormalKey whether to use normal key
func (*ChainClient) MultiSignContractQuery ¶ added in v2.1.0
func (cc *ChainClient) MultiSignContractQuery(txId string) (*common.TxResponse, error)
MultiSignContractQuery query online multi sign
func (*ChainClient) MultiSignContractQueryWithParams ¶ added in v2.3.3
func (cc *ChainClient) MultiSignContractQueryWithParams( txId string, params []*common.KeyValuePair) (*common.TxResponse, error)
MultiSignContractQueryWithParams query online multi sign
func (*ChainClient) MultiSignContractReq ¶ added in v2.1.0
func (cc *ChainClient) MultiSignContractReq(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractReq send online multi sign contract request to node
func (*ChainClient) MultiSignContractReqWithPayer ¶ added in v2.3.3
func (cc *ChainClient) MultiSignContractReqWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, payer *common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractReqWithPayer send online multi sign contract request to node
func (*ChainClient) MultiSignContractTrig ¶ added in v2.3.2
func (cc *ChainClient) MultiSignContractTrig(multiSignReqPayload *common.Payload, timeout int64, limit *common.Limit, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractTrig send online multi sign trig request to node this function is plugin after v2.3.1
func (*ChainClient) MultiSignContractTrigWithPayer ¶ added in v2.3.3
func (cc *ChainClient) MultiSignContractTrigWithPayer(multiSignReqPayload *common.Payload, payer *common.EndorsementEntry, timeout int64, limit *common.Limit, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractTrigWithPayer send online multi sign trig request to node this function is plugin after v2.3.1
func (*ChainClient) MultiSignContractVote ¶ added in v2.1.0
func (cc *ChainClient) MultiSignContractVote(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry, isAgree bool, timeout int64, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractVote send online multi sign vote request to node
func (*ChainClient) MultiSignContractVoteWithGasLimit ¶ added in v2.3.3
func (cc *ChainClient) MultiSignContractVoteWithGasLimit(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry, isAgree bool, timeout int64, gasLimit uint64, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractVoteWithGasLimit send online multi sign vote request to node
func (*ChainClient) MultiSignContractVoteWithGasLimitAndPayer ¶ added in v2.3.3
func (cc *ChainClient) MultiSignContractVoteWithGasLimitAndPayer(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry, payer *common.EndorsementEntry, isAgree bool, timeout int64, gasLimit uint64, withSyncResult bool) (*common.TxResponse, error)
MultiSignContractVoteWithGasLimitAndPayer send online multi sign vote request to node
func (*ChainClient) Pkcs11Config ¶ added in v2.1.0
func (cc *ChainClient) Pkcs11Config() *Pkcs11Config
Pkcs11Config get pkcs11 config of cc
func (*ChainClient) QueryCert ¶
func (cc *ChainClient) QueryCert(certHashes []string) (*common.CertInfos, error)
QueryCert query cert on chain, returns *common.CertInfos
func (*ChainClient) QueryCertsAlias ¶ added in v2.2.0
func (cc *ChainClient) QueryCertsAlias(aliases []string) (*common.AliasInfos, error)
QueryCertsAlias query cert alias on chain, returns *common.AliasInfos
func (*ChainClient) QueryContract ¶
func (cc *ChainClient) QueryContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error)
QueryContract query contract
func (*ChainClient) QueryContractMethodPayer ¶ added in v2.3.4
func (cc *ChainClient) QueryContractMethodPayer( contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)
QueryContractMethodPayer query contract-method payer
func (*ChainClient) QueryHibeParamsWithOrgId ¶
func (cc *ChainClient) QueryHibeParamsWithOrgId(contractName, method, orgId string, timeout int64) ([]byte, error)
QueryHibeParamsWithOrgId QueryHibeParamsWithOrgId
func (*ChainClient) QuerySystemContract ¶
func (cc *ChainClient) QuerySystemContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error)
QuerySystemContract query system contract
func (*ChainClient) QueryTxPayer ¶ added in v2.3.4
func (cc *ChainClient) QueryTxPayer(txId string, gasLimit uint64) (*common.TxResponse, error)
QueryTxPayer query tx payer
func (*ChainClient) RestoreBlocks ¶ added in v2.3.3
func (cc *ChainClient) RestoreBlocks(restoreHeight uint64, _ string, heightNotice func(message ProcessMessage) error) error
RestoreBlocks 从归档服务查询已归档区块恢复到节点账本中 @param endHeight @return error
func (*ChainClient) SaveData ¶
func (cc *ChainClient) SaveData(contractName string, contractVersion string, isDeployment bool, codeHash []byte, reportHash []byte, result *common.ContractResult, codeHeader []byte, txId string, rwSet *common.TxRWSet, sign []byte, events *common.StrSlice, privateReq []byte, withSyncResult bool, timeout int64) (*common.TxResponse, error)
SaveData SaveData
func (*ChainClient) SaveDir ¶
func (cc *ChainClient) SaveDir(orderId, txId string, privateDir *common.StrSlice, withSyncResult bool, timeout int64) (*common.TxResponse, error)
SaveDir SaveDir
func (*ChainClient) SaveEnclaveCACert ¶
func (cc *ChainClient) SaveEnclaveCACert( enclaveCACert, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)
SaveEnclaveCACert SaveEnclaveCACert
func (*ChainClient) SaveEnclaveReport ¶
func (cc *ChainClient) SaveEnclaveReport( enclaveId, report, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)
SaveEnclaveReport SaveEnclaveReport
func (*ChainClient) SaveRemoteAttestationProof ¶
func (cc *ChainClient) SaveRemoteAttestationProof(proof, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)
SaveRemoteAttestationProof SaveRemoteAttestationProof
func (*ChainClient) SendArchiveBlockRequest ¶
func (cc *ChainClient) SendArchiveBlockRequest(payload *common.Payload, timeout int64) (*common.TxResponse, error)
SendArchiveBlockRequest send `archive block` request to node grpc server
func (*ChainClient) SendCertManageRequest ¶
func (cc *ChainClient) SendCertManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendCertManageRequest send cert manage request to node
func (*ChainClient) SendChainConfigUpdateRequest ¶
func (cc *ChainClient) SendChainConfigUpdateRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendChainConfigUpdateRequest send chain config update request to node
func (*ChainClient) SendContractManageRequest ¶
func (cc *ChainClient) SendContractManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendContractManageRequest send user contract manage request to node
func (*ChainClient) SendContractManageRequestWithPayer ¶ added in v2.3.3
func (cc *ChainClient) SendContractManageRequestWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, payer *common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendContractManageRequestWithPayer send user contract manage request to node with payer
func (*ChainClient) SendGasManageRequest ¶ added in v2.2.0
func (cc *ChainClient) SendGasManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendGasManageRequest send gas manage request to node
func (*ChainClient) SendMultiSigningRequest ¶
func (cc *ChainClient) SendMultiSigningRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendMultiSigningRequest SendMultiSigningRequest
func (*ChainClient) SendPubkeyManageRequest ¶ added in v2.1.0
func (cc *ChainClient) SendPubkeyManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendPubkeyManageRequest send pubkey manage request to node
func (*ChainClient) SendRestoreBlockRequest ¶
func (cc *ChainClient) SendRestoreBlockRequest(payload *common.Payload, timeout int64) (*common.TxResponse, error)
SendRestoreBlockRequest send `restore block` request to node grpc server
func (*ChainClient) SendTxRequest ¶
func (cc *ChainClient) SendTxRequest(txRequest *common.TxRequest, timeout int64, withSyncResult bool) (*common.TxResponse, error)
SendTxRequest send tx request to node
func (*ChainClient) SetContractMethodPayer ¶ added in v2.3.4
func (cc *ChainClient) SetContractMethodPayer( payerAddress string, contractName string, methodName string, requestId string, payerOrgId string, payerKeyPem []byte, payerCertPem []byte, gasLimit uint64) ( *common.TxResponse, error)
SetContractMethodPayer set contract-method payer
func (*ChainClient) SignCertManagePayload ¶
func (cc *ChainClient) SignCertManagePayload(payload *common.Payload) (*common.EndorsementEntry, error)
SignCertManagePayload sign `cert manage` payload
func (*ChainClient) SignChainConfigPayload ¶
func (cc *ChainClient) SignChainConfigPayload(payload *common.Payload) (*common.EndorsementEntry, error)
SignChainConfigPayload sign chain config payload
func (*ChainClient) SignContractManagePayload ¶
func (cc *ChainClient) SignContractManagePayload(payload *common.Payload) (*common.EndorsementEntry, error)
SignContractManagePayload sign user contract manage payload
func (*ChainClient) SignDeleteAliasPayload ¶ added in v2.2.0
func (cc *ChainClient) SignDeleteAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error)
SignDeleteAliasPayload sign `delete alias` payload
func (*ChainClient) SignPayload ¶
func (cc *ChainClient) SignPayload(payload *common.Payload) (*common.EndorsementEntry, error)
SignPayload sign payload, returns *common.EndorsementEntry
func (*ChainClient) SignUpdateCertByAliasPayload ¶ added in v2.2.0
func (cc *ChainClient) SignUpdateCertByAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error)
SignUpdateCertByAliasPayload sign `update cert by alias` payload
func (*ChainClient) Subscribe ¶
func (cc *ChainClient) Subscribe(ctx context.Context, payload *common.Payload) (<-chan interface{}, error)
Subscribe returns channel of subscribed items
func (*ChainClient) SubscribeBlock ¶
func (cc *ChainClient) SubscribeBlock(ctx context.Context, startBlock, endBlock int64, withRWSet, onlyHeader bool) (<-chan interface{}, error)
SubscribeBlock block subscription, returns channel of subscribed blocks
func (*ChainClient) SubscribeContractEvent ¶
func (cc *ChainClient) SubscribeContractEvent(ctx context.Context, startBlock, endBlock int64, contractName, topic string) (<-chan interface{}, error)
SubscribeContractEvent contract event subscription, returns channel of subscribed contract events
func (*ChainClient) SubscribeTx ¶
func (cc *ChainClient) SubscribeTx(ctx context.Context, startBlock, endBlock int64, contractName string, txIds []string) (<-chan interface{}, error)
SubscribeTx tx subscription, returns channel of subscribed txs
func (*ChainClient) SubscribeTxByPreAlias ¶ added in v2.3.5
func (cc *ChainClient) SubscribeTxByPreAlias(ctx context.Context, startBlock, endBlock int64, aliasPrefix string) (<-chan interface{}, error)
SubscribeTxByPreAlias tx subscription by alias prefix, returns channel of subscribed txs
func (*ChainClient) SubscribeTxByPreOrgId ¶ added in v2.3.5
func (cc *ChainClient) SubscribeTxByPreOrgId(ctx context.Context, startBlock, endBlock int64, orgIdPrefix string) (<-chan interface{}, error)
SubscribeTxByPreOrgId tx subscription by org id prefix, returns channel of subscribed txs
func (*ChainClient) SubscribeTxByPreTxId ¶ added in v2.3.5
func (cc *ChainClient) SubscribeTxByPreTxId(ctx context.Context, startBlock, endBlock int64, txIdPrefix string) (<-chan interface{}, error)
SubscribeTxByPreTxId tx subscription by tx id prefix, returns channel of subscribed txs
func (*ChainClient) UnsetContractMethodPayer ¶ added in v2.3.4
func (cc *ChainClient) UnsetContractMethodPayer( contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)
UnsetContractMethodPayer unset contract-method payer
func (*ChainClient) UpdateCertByAlias ¶ added in v2.2.0
func (cc *ChainClient) UpdateCertByAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error)
UpdateCertByAlias update cert by alias on chain
type ChainClientConfig ¶
type ChainClientConfig struct { ConfigModel *utils.ChainClientConfigModel // contains filtered or unexported fields }
ChainClientConfig define chain client configuration
type ChainClientOption ¶
type ChainClientOption func(*ChainClientConfig)
ChainClientOption define chain client option func
func AddChainClientNodeConfig ¶
func AddChainClientNodeConfig(nodeConfig *NodeConfig) ChainClientOption
AddChainClientNodeConfig 添加ChainMaker节点地址及连接数配置
func WithArchiveCenterHttpConfig ¶ added in v2.3.3
func WithArchiveCenterHttpConfig(conf *ArchiveCenterConfig) ChainClientOption
WithArchiveCenterHttpConfig 设置归档中心http接口
func WithArchiveCenterQueryFirst ¶ added in v2.3.3
func WithArchiveCenterQueryFirst(first bool) ChainClientOption
WithArchiveCenterQueryFirst 设置优先从归档中心查询
func WithArchiveConfig ¶
func WithArchiveConfig(conf *ArchiveConfig) ChainClientOption
WithArchiveConfig 设置Archive配置
func WithAuthType ¶ added in v2.1.0
func WithAuthType(authType string) ChainClientOption
WithAuthType specified auth type
func WithChainClientAlias ¶ added in v2.2.0
func WithChainClientAlias(alias string) ChainClientOption
WithChainClientAlias specified cert alias
func WithChainClientChainId ¶
func WithChainClientChainId(chainId string) ChainClientOption
WithChainClientChainId 添加ChainId
func WithChainClientLogger ¶
func WithChainClientLogger(logger utils.Logger) ChainClientOption
WithChainClientLogger 设置Logger对象,便于日志打印
func WithChainClientOrgId ¶
func WithChainClientOrgId(orgId string) ChainClientOption
WithChainClientOrgId 添加OrgId
func WithCryptoConfig ¶ added in v2.3.0
func WithCryptoConfig(conf *CryptoConfig) ChainClientOption
WithCryptoConfig 设置crypto配置
func WithEnableNormalKey ¶ added in v2.2.1
func WithEnableNormalKey(enableNormalKey bool) ChainClientOption
WithEnableNormalKey specified use normal key or not
func WithEnableSyncCanonicalTxResult ¶ added in v2.3.0
func WithEnableSyncCanonicalTxResult(enable bool) ChainClientOption
WithEnableSyncCanonicalTxResult 设置是否启用 同步获取权威的公认的交易结果,即超过半数共识的交易。默认不启用。
func WithEnableTxResultDispatcher ¶ added in v2.3.0
func WithEnableTxResultDispatcher(enable bool) ChainClientOption
WithEnableTxResultDispatcher 设置是否启用 异步订阅机制获取交易结果。 默认不启用,如不启用将继续使用轮训机制获取交易结果。
func WithPkcs11Config ¶ added in v2.1.0
func WithPkcs11Config(conf *Pkcs11Config) ChainClientOption
WithPkcs11Config 设置pkcs11配置
func WithRPCClientConfig ¶
func WithRPCClientConfig(conf *RPCClientConfig) ChainClientOption
WithRPCClientConfig 设置grpc客户端配置
func WithRetryInterval ¶ added in v2.1.0
func WithRetryInterval(interval int) ChainClientOption
WithRetryInterval 设置 chain client 同步模式下,每次轮训交易结果时的等待时间,单位:ms
func WithRetryLimit ¶ added in v2.1.0
func WithRetryLimit(limit int) ChainClientOption
WithRetryLimit 设置 chain client 同步模式下,轮训获取交易结果时的最大轮训次数
func WithUserCrtBytes ¶
func WithUserCrtBytes(userCrtBytes []byte) ChainClientOption
WithUserCrtBytes 添加用户证书文件内容配置
func WithUserCrtFilePath ¶
func WithUserCrtFilePath(userCrtFilePath string) ChainClientOption
WithUserCrtFilePath 添加用户证书文件路径配置
func WithUserEncKeyPwd ¶ added in v2.3.0
func WithUserEncKeyPwd(pwd string) ChainClientOption
WithUserEncKeyPwd 配置国密双证书模式下用户私钥密码
func WithUserKeyBytes ¶
func WithUserKeyBytes(userKeyBytes []byte) ChainClientOption
WithUserKeyBytes 添加用户私钥文件内容配置
func WithUserKeyFilePath ¶
func WithUserKeyFilePath(userKeyFilePath string) ChainClientOption
WithUserKeyFilePath 添加用户私钥文件路径配置
func WithUserKeyPwd ¶ added in v2.3.0
func WithUserKeyPwd(pwd string) ChainClientOption
WithUserKeyPwd 配置用户私钥密码
func WithUserSignCrtBytes ¶
func WithUserSignCrtBytes(userSignCrtBytes []byte) ChainClientOption
WithUserSignCrtBytes 添加用户签名证书文件内容配置
func WithUserSignCrtFilePath ¶
func WithUserSignCrtFilePath(userSignCrtFilePath string) ChainClientOption
WithUserSignCrtFilePath 添加用户签名证书文件路径配置
func WithUserSignKeyBytes ¶
func WithUserSignKeyBytes(userSignKeyBytes []byte) ChainClientOption
WithUserSignKeyBytes 添加用户签名私钥文件内容配置
func WithUserSignKeyFilePath ¶
func WithUserSignKeyFilePath(userSignKeyFilePath string) ChainClientOption
WithUserSignKeyFilePath 添加用户签名私钥文件路径配置
func WithUserSignKeyPwd ¶ added in v2.3.0
func WithUserSignKeyPwd(pwd string) ChainClientOption
WithUserSignKeyPwd 配置用户签名私钥密码
type ClientConnectionPool ¶
type ClientConnectionPool struct {
// contains filtered or unexported fields
}
ClientConnectionPool 客户端连接池结构定义
func NewConnPool ¶
func NewConnPool(config *ChainClientConfig) (*ClientConnectionPool, error)
NewConnPool 创建连接池
func NewConnPoolWithOptions ¶
func NewConnPoolWithOptions(opts ...ChainClientOption) (*ClientConnectionPool, error)
NewConnPoolWithOptions new conn pool with optioins, returns *ClientConnectionPool
type ConnectionPool ¶
type ConnectionPool interface { Close() error // contains filtered or unexported methods }
ConnectionPool grpc connection pool interface
type CryptoConfig ¶ added in v2.1.0
type CryptoConfig struct {
// contains filtered or unexported fields
}
CryptoConfig define crypto config
func NewCryptoConfig ¶ added in v2.3.0
func NewCryptoConfig(opts ...CryptoOption) *CryptoConfig
NewCryptoConfig 根据传入参数创建新的CryptoConfig对象 @param opts @return *CryptoConfig
type CryptoOption ¶ added in v2.1.0
type CryptoOption func(config *CryptoConfig)
CryptoOption define crypto option func
func WithHashAlgo ¶ added in v2.1.0
func WithHashAlgo(hashType string) CryptoOption
WithHashAlgo 公钥模式下:添加用户哈希算法配置
type NodeConfig ¶
type NodeConfig struct {
// contains filtered or unexported fields
}
NodeConfig 节点配置
func NewNodeConfig ¶
func NewNodeConfig(opts ...NodeOption) *NodeConfig
NewNodeConfig new node config, returns *NodeConfig
type NodeOption ¶
type NodeOption func(config *NodeConfig)
NodeOption define node option func
func WithNodeTLSHostName ¶
func WithNodeTLSHostName(tlsHostName string) NodeOption
WithNodeTLSHostName use tls host name
type PermissionedWithKeyModeSigner ¶ added in v2.3.0
type PermissionedWithKeyModeSigner struct { PrivateKey crypto.PrivateKey HashType crypto.HashType OrgId string }
PermissionedWithKeyModeSigner define a signer in PermissionedWithKey mode
func (*PermissionedWithKeyModeSigner) NewMember ¶ added in v2.3.0
func (signer *PermissionedWithKeyModeSigner) NewMember() (*accesscontrol.Member, error)
NewMember new *accesscontrol.Member
type Pkcs11Config ¶ added in v2.1.0
type Pkcs11Config struct { // 是否开启pkcs11, 如果为 ture 则下面所有的字段都是必填 Enabled bool // interface type of lib, support pkcs11 and sdf Type string // path to the .so file of pkcs11 interface Library string // label for the slot to be used Label string // password to logon the HSM(Hardware security module) Password string // size of HSM session cache SessionCacheSize int // hash algorithm used to compute SKI, eg, SHA256 Hash string }
Pkcs11Config pkcs11配置
type ProcessMessage ¶ added in v2.3.3
ProcessMessage 处理过程通知消息
type PublicModeSigner ¶ added in v2.3.0
type PublicModeSigner struct { PrivateKey crypto.PrivateKey HashType crypto.HashType }
PublicModeSigner define a signer in Public mode
func (*PublicModeSigner) NewMember ¶ added in v2.3.0
func (signer *PublicModeSigner) NewMember() (*accesscontrol.Member, error)
NewMember new *accesscontrol.Member
type RPCClientConfig ¶
type RPCClientConfig struct {
// contains filtered or unexported fields
}
RPCClientConfig RPC Client 链接配置
func NewRPCClientConfig ¶
func NewRPCClientConfig(opts ...RPCClientOption) *RPCClientConfig
NewRPCClientConfig new rpc client config
type RPCClientOption ¶
type RPCClientOption func(config *RPCClientConfig)
RPCClientOption define rpc client option func
func WithRPCClientGetTxTimeout ¶ added in v2.3.0
func WithRPCClientGetTxTimeout(timeout int64) RPCClientOption
WithRPCClientGetTxTimeout 设置RPC Client的查询交易超时时间
func WithRPCClientMaxReceiveMessageSize ¶
func WithRPCClientMaxReceiveMessageSize(size int) RPCClientOption
WithRPCClientMaxReceiveMessageSize 设置RPC Client的Max Receive Message Size
func WithRPCClientMaxSendMessageSize ¶ added in v2.2.0
func WithRPCClientMaxSendMessageSize(size int) RPCClientOption
WithRPCClientMaxSendMessageSize 设置RPC Client的Max Send Message Size
func WithRPCClientSendTxTimeout ¶ added in v2.3.0
func WithRPCClientSendTxTimeout(timeout int64) RPCClientOption
WithRPCClientSendTxTimeout 设置RPC Client的发送交易超时时间
type SDKInterface ¶
type SDKInterface interface { // ## 1 用户合约接口 // ### 1.1 创建合约待签名payload生成 // **参数说明** // - contractName: 合约名 // - version: 版本号 // - byteCodeStringOrFilePath: 支持传入合约二进制文件路径或Hex或Base64编码的string // - runtime: 合约运行环境 // - kvs: 合约初始化参数 // “`go CreateContractCreatePayload(contractName, version, byteCodeStringOrFilePath string, runtime common.RuntimeType, kvs []*common.KeyValuePair) (*common.Payload, error) // ### 1.2 升级合约待签名payload生成 // **参数说明** // - contractName: 合约名 // - version: 版本号 // - byteCodeStringOrFilePath: 支持传入合约二进制文件路径或Hex或Base64编码的string // - runtime: 合约运行环境 // - kvs: 合约升级参数 // “`go CreateContractUpgradePayload(contractName, version, byteCodeStringOrFilePath string, runtime common.RuntimeType, kvs []*common.KeyValuePair) (*common.Payload, error) // ### 1.3 冻结合约payload生成 // **参数说明** // - contractName: 合约名 // “`go CreateContractFreezePayload(contractName string) (*common.Payload, error) // ### 1.4 解冻合约payload生成 // **参数说明** // - contractName: 合约名 // “`go CreateContractUnfreezePayload(contractName string) (*common.Payload, error) // ### 1.5 吊销合约payload生成 // **参数说明** // - contractName: 合约名 // “`go CreateContractRevokePayload(contractName string) (*common.Payload, error) // ### 1.6 合约管理获取Payload签名 // **参数说明** // - payload: 待签名payload // “`go SignContractManagePayload(payload *common.Payload) (*common.EndorsementEntry, error) // ### 1.7 发送合约管理请求(创建、更新、冻结、解冻、吊销) // **参数说明** // - payload: 交易payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go SendContractManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 1.7 发送合约管理请求(创建、更新、冻结、解冻、吊销) // **参数说明** // - payer: gas扣费代扣人 // - 其他同SendContractManageRequest SendContractManageRequestWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, payer *common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 1.8 合约调用 // **参数说明** // - contractName: 合约名称 // - method: 合约方法 // - txId: 交易ID // 格式要求:长度为64字节,字符在a-z0-9 // 可为空,若为空字符串,将自动生成txId // - kvs: 合约参数 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // - limit: transaction limitation,执行交易时的资源消耗上限,设为nil则不设置上限 // “`go InvokeContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool) (*common.TxResponse, error) InvokeContractWithLimit(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool, limit *common.Limit) (*common.TxResponse, error) // ### 1.9 合约查询接口调用 // **参数说明** // - contractName: 合约名称 // - method: 合约方法 // - kvs: 合约参数 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // “`go QueryContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error) // ### 1.10 构造待发送交易体 // **参数说明** // - contractName: 合约名称 // - method: 合约方法 // - txId: 交易ID // 格式要求:长度为64字节,字符在a-z0-9 // 可为空,若为空字符串,将自动生成txId // - kvs: 合约参数 // “`go GetTxRequest(contractName, method, txId string, kvs []*common.KeyValuePair) (*common.TxRequest, error) // ### 1.11 发送已构造好的交易体 // **参数说明** // - txRequest: 已构造好的交易体 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go SendTxRequest(txRequest *common.TxRequest, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ## 2 系统合约接口 // ### 2.1 根据交易Id查询交易 // **参数说明** // - txId: 交易ID // “`go GetTxByTxId(txId string) (*common.TransactionInfo, error) // ### 2.2 根据交易Id查询包含rwset的交易 // **参数说明** // - txId: 交易ID // “`go GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error) // ### 2.3 根据区块高度查询区块 // **参数说明** // - blockHeight: 指定区块高度,若为-1,将返回最新区块 // - withRWSet: 是否返回读写集 // “`go GetBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error) //Deprecated, 请使用GetBlockByHeight //### 2.4 根据区块高度查询完整区块 // **参数说明** // - blockHeight: 指定区块高度,若为-1,将返回最新区块 // “`go GetFullBlockByHeight(blockHeight uint64) (*store.BlockWithRWSet, error) // ### 2.5 根据区块哈希查询区块 // **参数说明** // - blockHash: 指定区块Hash // - withRWSet: 是否返回读写集 // “`go GetBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error) // ### 2.6 根据交易Id查询区块 // **参数说明** // - txId: 交易ID // - withRWSet: 是否返回读写集 // “`go GetBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error) // ### 2.7 查询最新的配置块 // **参数说明** // - withRWSet: 是否返回读写集 // “`go GetLastConfigBlock(withRWSet bool) (*common.BlockInfo, error) // ### 2.8 查询最新区块 // **参数说明** // - withRWSet: 是否返回读写集 // “`go GetLastBlock(withRWSet bool) (*common.BlockInfo, error) // ### 2.9 查询节点加入的链信息 // - 返回ChainId清单 // “`go GetNodeChainList() (*discovery.ChainList, error) // ### 2.10 查询链信息 // - 包括:当前链最新高度,链节点信息 // “`go GetChainInfo() (*discovery.ChainInfo, error) // ### 2.11 根据交易Id获取区块高度 // **参数说明** // - txId: 交易ID // “`go GetBlockHeightByTxId(txId string) (uint64, error) // ### 2.12 根据区块Hash获取区块高度 // **参数说明** // - blockHash: 指定区块Hash // “`go GetBlockHeightByHash(blockHash string) (uint64, error) // ### 2.13 查询当前最新区块高度 // “`go GetCurrentBlockHeight() (uint64, error) // ### 2.14 根据区块高度查询区块头 // **参数说明** // - blockHeight: 指定区块高度,若为-1,将返回最新区块头 // “`go GetBlockHeaderByHeight(blockHeight uint64) (*common.BlockHeader, error) // ### 2.15 系统合约调用 // **参数说明** // - contractName: 合约名称 // - method: 合约方法 // - txId: 交易ID // 格式要求:长度为64字节,字符在a-z0-9 // 可为空,若为空字符串,将自动生成txId // - kvs: 合约参数 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go InvokeSystemContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 2.16 系统合约查询接口调用 // **参数说明** // - contractName: 合约名称 // - method: 合约方法 // - kvs: 合约参数 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // “`go QuerySystemContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error) // ### 2.17 根据交易Id获取Merkle路径 // **参数说明** // - txId: 交易ID // “`go GetMerklePathByTxId(txId string) ([]byte, error) // ### 2.18 开放系统合约 // **参数说明** // - grantContractList: 需要开放的系统合约字符串数组 // “`go CreateNativeContractAccessGrantPayload(grantContractList []string) (*common.Payload, error) // ### 2.19 弃用系统合约 // **参数说明** // - revokeContractList: 需要弃用的系统合约字符串数组 // “`go CreateNativeContractAccessRevokePayload(revokeContractList []string) (*common.Payload, error) // ### 2.20 查询指定合约的信息,包括系统合约和用户合约 // **参数说明** // - contractName: 指定查询的合约名字,包括系统合约和用户合约 // “`go GetContractInfo(contractName string) (*common.Contract, error) // ### 2.21 查询所有的合约名单,包括系统合约和用户合约 // **返回值说明** // - []*common.Contract: 链上所有的合约列表,包括系统合约和用户合约 // “`go GetContractList() ([]*common.Contract, error) // ### 2.22 查询已禁用的系统合约名单 // **返回值说明** // - []string: 链上已禁用的系统合约名字列表 // “`go GetDisabledNativeContractList() ([]string, error) // ### 2.23 根据区块高度获得区块,应对超大block,可设置返回block的截断规则。 // **参数说明** // - blockHeight: 指定区块高度 // - withRWSet: 是否返回读写集 // - truncateLength 截断的长度设置,如果此参数为>0,超过此长度的剩余数据将被丢弃。如果<=0则不截断 // - truncateModel 截断的模式设置:hash,truncate,empty // “`go GetBlockByHeightTruncate(blockHeight uint64, withRWSet bool, truncateLength int, truncateModel string) (*common.BlockInfo, error) // ## 3 链配置接口 // ### 3.1 查询最新链配置 // “`go GetChainConfig() (*config.ChainConfig, error) // ### 3.2 根据指定区块高度查询最近链配置 // **参数说明** // - blockHeight: 指定区块高度 // 如果当前区块就是配置块,直接返回当前区块的链配置 // “`go GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error) // ### 3.3 查询最新链配置序号Sequence // - 用于链配置更新 // “`go GetChainConfigSequence() (uint64, error) // ### 3.4 链配置更新获取Payload签名 // **参数说明** // - payload: 待签名payload // “`go SignChainConfigPayload(payload *common.Payload) (*common.EndorsementEntry, error) // ### 3.5 发送链配置更新请求 // **参数说明** // - payload: 待签名payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go SendChainConfigUpdateRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 3.6 更新Core模块待签名payload生成 // **参数说明** // - txSchedulerTimeout: 交易调度器从交易池拿到交易后, 进行调度的时间,其值范围为(0, 60], 若设置为0,则抛出错误 // - txSchedulerValidateTimeout: 交易调度器从区块中拿到交易后, 进行验证的超时时间,其值范围为(0, 60], 若设置为0,则抛出错误 // “`go CreateChainConfigCoreUpdatePayload(txSchedulerTimeout, txSchedulerValidateTimeout uint64) (*common.Payload, error) // ### 3.7 更新链配置的区块相关参数待签名payload生成 // **参数说明** // - txTimestampVerify: 是否需要开启交易时间戳校验 // - blockTimestampVerify: 是否需要开启区块头时间戳校验 // - txTimeout: 交易时间戳的过期时间(秒),其值范围为[600, +∞) // - blockTimeout: 区块头时间戳的过期时间(秒),其值范围为[10, +∞) // - blockTxCapacity: 区块中最大交易数,其值范围为(0, +∞] // - blockSize: 区块最大限制,单位MB,其值范围为(0, +∞] // - blockInterval: 出块间隔,单位:ms,其值范围为[10, +∞] // - txParamterSize: 交易的参数的最大值限制,单位:MB,其值范围为[0,100] // “`go CreateChainConfigBlockUpdatePayload(txTimestampVerify, blockTimestampVerify bool, txTimeout, blockTimeout, blockTxCapacity, blockSize, blockInterval, txParamterSize uint32) (*common.Payload, error) // ### 3.8 添加信任组织根证书待签名payload生成 // **参数说明** // - trustRootOrgId: 组织Id // - trustRootCrt: 根证书 // “`go CreateChainConfigTrustRootAddPayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error) // ### 3.9 更新信任组织根证书待签名payload生成 // **参数说明** // - trustRootOrgId: 组织Id // - trustRootCrt: 根证书 // “`go CreateChainConfigTrustRootUpdatePayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error) // ### 3.10 删除信任组织根证书待签名payload生成 // **参数说明** // - orgIdOrPKPubkeyPEM: cert模式下传组织Id,public模式下传公钥PEM // “`go CreateChainConfigTrustRootDeletePayload(orgIdOrPKPubkeyPEM string) (*common.Payload, error) // ### 3.11 添加信任成员证书待签名payload生成 // **参数说明** // - trustMemberOrgId: 组织Id // - trustMemberNodeId: 节点Id // - trustMemberRole: 成员角色 // - trustMemberInfo: 成员信息内容 // “`go CreateChainConfigTrustMemberAddPayload(trustMemberOrgId, trustMemberNodeId, trustMemberRole, trustMemberInfo string) (*common.Payload, error) // ### 3.12 删除信任成员证书待签名payload生成 // **参数说明** // - trustMemberInfo: 成员信息内容 // “`go CreateChainConfigTrustMemberDeletePayload(trustMemberInfo string) (*common.Payload, error) // ### 3.13 添加权限配置待签名payload生成 // **参数说明** // - permissionResourceName: 权限名 // - policy: 权限规则 // “`go CreateChainConfigPermissionAddPayload(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error) // ### 3.14 更新权限配置待签名payload生成 // **参数说明** // - permissionResourceName: 权限名 // - policy: 权限规则 // “`go CreateChainConfigPermissionUpdatePayload(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error) // ### 3.15 删除权限配置待签名payload生成 // **参数说明** // - permissionResourceName: 权限名 // “`go CreateChainConfigPermissionDeletePayload(permissionResourceName string) (*common.Payload, error) // ### 3.16 添加共识节点地址待签名payload生成 // **参数说明** // - nodeOrgId: 节点组织Id // - nodeIds: 节点Id // “`go CreateChainConfigConsensusNodeIdAddPayload(nodeOrgId string, nodeIds []string) (*common.Payload, error) // ### 3.17 更新共识节点地址待签名payload生成 // **参数说明** // - nodeOrgId: 节点组织Id // - nodeOldNodeId: 节点原Id // - nodeNewNodeId: 节点新Id // “`go CreateChainConfigConsensusNodeIdUpdatePayload(nodeOrgId, nodeOldNodeId, nodeNewNodeId string) (*common.Payload, error) // ### 3.18 删除共识节点地址待签名payload生成 // **参数说明** // - nodeOrgId: 节点组织Id // - nodeId: 节点Id // “`go CreateChainConfigConsensusNodeIdDeletePayload(nodeOrgId, nodeId string) (*common.Payload, error) // ### 3.19 添加共识节点待签名payload生成 // **参数说明** // - nodeOrgId: 节点组织Id // - nodeIds: 节点Id // “`go CreateChainConfigConsensusNodeOrgAddPayload(nodeOrgId string, nodeIds []string) (*common.Payload, error) // ### 3.20 更新共识节点待签名payload生成 // **参数说明** // - nodeOrgId: 节点组织Id // - nodeIds: 节点Id // “`go CreateChainConfigConsensusNodeOrgUpdatePayload(nodeOrgId string, nodeIds []string) (*common.Payload, error) // ### 3.21 删除共识节点待签名payload生成 // **参数说明** // - nodeOrgId: 节点组织Id // “`go CreateChainConfigConsensusNodeOrgDeletePayload(nodeOrgId string) (*common.Payload, error) // ### 3.22 添加共识扩展字段待签名payload生成 // **参数说明** // - kvs: 字段key、value对 // “`go CreateChainConfigConsensusExtAddPayload(kvs []*common.KeyValuePair) (*common.Payload, error) // ### 3.23 更新共识扩展字段待签名payload生成 // **参数说明** // - kvs: 字段key、value对 // “`go CreateChainConfigConsensusExtUpdatePayload(kvs []*common.KeyValuePair) (*common.Payload, error) // ### 3.24 删除共识扩展字段待签名payload生成 // **参数说明** // - keys: 待删除字段 // “`go CreateChainConfigConsensusExtDeletePayload(keys []string) (*common.Payload, error) // ### 3.25 修改地址类型payload生成 // **参数说明** // - addrType: 地址类型,0-ChainMaker; 1-ZXL // “`go CreateChainConfigAlterAddrTypePayload(addrType string) (*common.Payload, error) // ### 3.26 启用或停用Gas计费开关payload生成 // “`go CreateChainConfigEnableOrDisableGasPayload() (*common.Payload, error) // ### 3.27 开启或关闭链配置的Gas优化payload生成 // “`go CreateChainConfigOptimizeChargeGasPayload(enable bool) (*common.Payload, error) // ### 3.28 查询最新权限配置列表 // “`go GetChainConfigPermissionList() ([]*config.ResourcePolicy, error) // ## 4 证书管理接口 // ### 4.1 用户证书添加 // **参数说明** // - 在common.TxResponse.ContractResult.Result字段中返回成功添加的certHash // “`go AddCert() (*common.TxResponse, error) // ### 4.2 用户证书删除 // **参数说明** // - certHashes: 证书Hash列表 // “`go DeleteCert(certHashes []string) (*common.TxResponse, error) // ### 4.3 用户证书查询 // **参数说明** // - certHashes: 证书Hash列表 // **返回值说明** // - *common.CertInfos: 包含证书Hash和证书内容的列表 // “`go QueryCert(certHashes []string) (*common.CertInfos, error) // ### 4.4 获取用户证书哈希 // “`go GetCertHash() ([]byte, error) // ### 4.5 生成证书管理操作Payload(三合一接口) // **参数说明** // - method: CERTS_FROZEN(证书冻结)/CERTS_UNFROZEN(证书解冻)/CERTS_REVOCATION(证书吊销) // - kvs: 证书管理操作参数 // “`go CreateCertManagePayload(method string, kvs []*common.KeyValuePair) *common.Payload // ### 4.6 生成证书冻结操作Payload // **参数说明** // - certs: X509证书列表 // “`go CreateCertManageFrozenPayload(certs []string) *common.Payload // ### 4.7 生成证书解冻操作Payload // **参数说明** // - certs: X509证书列表 // “`go CreateCertManageUnfrozenPayload(certs []string) *common.Payload // ### 4.8 生成证书吊销操作Payload // **参数说明** // - certs: X509证书列表 // “`go CreateCertManageRevocationPayload(certCrl string) *common.Payload // ### 4.9 待签payload签名 // *一般需要使用具有管理员权限账号进行签名* // **参数说明** // - payload: 待签名payload // “`go SignCertManagePayload(payload *common.Payload) (*common.EndorsementEntry, error) // ### 4.10 发送证书管理请求(证书冻结、解冻、吊销) // **参数说明** // - payload: 交易payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go SendCertManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ## 5 消息订阅接口 // ### 5.1 区块订阅 // **参数说明** // - startBlock: 订阅起始区块高度,包含起始区块。若为-1,表示订阅实时最新区块 // - endBlock: 订阅结束区块高度,包含结束区块。若为-1,表示订阅实时最新区块 // - withRwSet: 是否返回读写集 // - onlyHeader: 若设置为true,将忽略withRwSet选项,仅返回区块头(common.BlockHeader),若设置为false,将返回common.BlockInfo // “`go SubscribeBlock(ctx context.Context, startBlock, endBlock int64, withRWSet, onlyHeader bool) (<-chan interface{}, error) // ### 5.2 交易订阅 // **参数说明** // - startBlock: 订阅起始区块高度,包含起始区块。若为-1,表示订阅实时最新区块 // - endBlock: 订阅结束区块高度,包含结束区块。若为-1,表示订阅实时最新区块 // - contractName :指定订阅指定合约的交易,可以传用户合约名称或系统合约名称,若为空,表示订阅所有合约的交易 // - txIds: 订阅txId列表,若为空,表示订阅所有txId // “`go SubscribeTx(ctx context.Context, startBlock, endBlock int64, contractName string, txIds []string) (<-chan interface{}, error) // ### 5.3 合约事件订阅 // **参数说明** // - startBlock: 订阅起始区块高度,包含起始区块。若为-1,表示订阅实时最新区块 // - endBlock: 订阅结束区块高度,包含结束区块。若为-1,表示订阅实时最新区块 // - contractName :指定订阅的合约名称 // - topic :指定订阅主题 // “`go SubscribeContractEvent(ctx context.Context, startBlock, endBlock int64, contractName, topic string) (<-chan interface{}, error) // ### 5.4 多合一订阅 // **参数说明** // - txType: 订阅交易类型,目前已支持:区块消息订阅(common.TxType_SUBSCRIBE_BLOCK_INFO)、交易消息订阅(common.TxType_SUBSCRIBE_TX_INFO) // - payloadBytes: 消息订阅参数payload // “`go Subscribe(ctx context.Context, payloadBytes *common.Payload) (<-chan interface{}, error) //### 5.5 根据别名前缀订阅交易(仅支持证书模式链) //**参数说明** //- startBlock: 订阅起始区块高度,若为-1,表示订阅实时最新区块 //- endBlock: 订阅结束区块高度,若为-1,表示订阅实时最新区块 //- aliasPrefix: 证书别名前缀,不允许为空 // “`go SubscribeTxByPreAlias(ctx context.Context, startBlock, endBlock int64, aliasPrefix string) (<-chan interface{}, error) //### 5.6 根据交易id前缀订阅交易 //**参数说明** //- startBlock: 订阅起始区块高度,若为-1,表示订阅实时最新区块 //- endBlock: 订阅结束区块高度,若为-1,表示订阅实时最新区块 //- txIdPrefix: 交易id前缀,不允许为空 //“`go SubscribeTxByPreTxId(ctx context.Context, startBlock, endBlock int64, txIdPrefix string) (<-chan interface{}, error) //### 5.7 根据组织id前缀订阅交易 //**参数说明** //- startBlock: 订阅起始区块高度,若为-1,表示订阅实时最新区块 //- endBlock: 订阅结束区块高度,若为-1,表示订阅实时最新区块 //- orgIdPrefix: 组织id前缀,不允许为空 //“`go SubscribeTxByPreOrgId(ctx context.Context, startBlock, endBlock int64, orgIdPrefix string) (<-chan interface{}, error) // ## 6 证书压缩 // *开启证书压缩可以减小交易包大小,提升处理性能* // ### 6.1 启用压缩证书功能 // “`go EnableCertHash() error // ### 6.2 停用压缩证书功能 // “`go DisableCertHash() error // ## 7 层级属性加密类接口 // > 注意:层级属性加密模块 `Id` 使用 `/` 作为分隔符,例如: Org1/Ou1/Member1 // ### 7.1 生成层级属性参数初始化交易 payload // **参数说明** // - orgId: 参与方组织 id // - hibeParams: 传入序列化后的hibeParams byte数组 // “`go CreateHibeInitParamsTxPayloadParams(orgId string, hibeParams []byte) ([]*common.KeyValuePair, error) // ### 7.2 生成层级属性加密交易 payload,加密参数已知 // **参数说明** // - plaintext: 待加密交易消息明文 // - receiverIds: 消息接收者 id 列表,需和 paramsList 一一对应 // - paramsBytesList: 消息接收者对应的加密参数,需和 receiverIds 一一对应 // - txId: 以交易 Id 作为链上存储 hibeMsg 的 Key, 如果不提供存储的信息可能被覆盖 // - keyType: 对明文进行对称加密的方法,请传入 common 中 crypto 包提供的方法,目前提供AES和SM4两种方法 // “`go CreateHibeTxPayloadParamsWithHibeParams(plaintext []byte, receiverIds []string, paramsBytesList [][]byte, txId string, keyType crypto.KeyType) ([]*common.KeyValuePair, error) // ### 7.3 生成层级属性加密交易 payload,参数由链上查询得出 // **参数说明** // - contractName: 合约名 // - queryParamsMethod: 链上查询 hibe.Params 的合约方法 // - plaintext: 待加密交易消息明文 // - receiverIds: 消息接收者 id 列表,需和 paramsList 一一对应 // - paramsList: 消息接收者对应的加密参数,需和 receiverIds 一一对应 // - receiverOrgIds: 链上查询 hibe Params 的 Key 列表,需要和 receiverIds 一一对应 // - txId: 以交易 Id 作为链上存储 hibeMsg 的 Key, 如果不提供存储的信息可能被覆盖 // - keyType: 对明文进行对称加密的方法,请传入 common 中 crypto 包提供的方法,目前提供AES和SM4两种方法 // - timeout: (内部查询 HibeParams 的)超时时间,单位:s,若传入-1,将使用默认超时时间:10s // “`go CreateHibeTxPayloadParamsWithoutHibeParams(contractName, queryParamsMethod string, plaintext []byte, receiverIds []string, receiverOrgIds []string, txId string, keyType crypto.KeyType, timeout int64) ([]*common.KeyValuePair, error) // ### 7.4 查询某一组织的加密公共参数,返回其序列化后的byte数组 // **参数说明** // - contractName: 合约名 // - method: 查询的合约方法名 // - orgId: 参与方 id // - timeout: 查询超时时间,单位:s,若传入-1,将使用默认超时时间:10s // “`go QueryHibeParamsWithOrgId(contractName, method, orgId string, timeout int64) ([]byte, error) // ### 7.5 已知交易id,根据私钥解密密文交易 // **参数说明** // - localId: 本地层级属性加密 id // - hibeParams: hibeParams 序列化后的byte数组 // - hibePrivKey: hibe私钥序列化后的byte数组 // - txId: 层级属性加密交易 id // - keyType: 对加密信息进行对称解密的方法,请和加密时使用的方法保持一致,请传入 common 中 crypto 包提供的方法,目前提供AES和SM4两种方法 // “`go DecryptHibeTxByTxId(localId string, hibeParams []byte, hibePrvKey []byte, txId string, keyType crypto.KeyType) ([]byte, error) // ## 8 数据归档接口 // **(注意:请使用归档工具cmc进行归档操作,以下接口是归档原子接口,并不包括归档完整流程)** // ### 8.1 获取已归档区块高度,该方法已弃用,请优先使用GetArchiveStatus // **参数说明** // - 输出已归档的区块高度 // “`go //Deprecated GetArchivedBlockHeight() (uint64, error) // “` // ### 8.2 获取节点归档状态详细信息 // **参数说明** // - 输出:输出节点支持的归档类型:ExtraDB(外部数据库),ArchiveCenter(归档中心) // - 输出:已归档的区块高度 // - 输出:节点允许的归档高度: 高度必须小于(CurrBlockHeight-UnarchivedHeight),UnarchivedHeight在chainmaker.yml storage中设置 // - 输出:当前节点的归档状态:Normal(正常), Archiving(正在归档), Restoring(正在恢复) // - 输出:当前节点上可恢复区块的暂存文件信息 // “`go GetArchiveStatus() (*store.ArchiveStatus, error) // “` // ### 8.3 构造数据归档区块Payload // **参数说明** // - targetBlockHeight: 归档目标区块高度,节点ArchiveStatus.Process为Normal时才可发送成功 // “`go CreateArchiveBlockPayload(targetBlockHeight uint64) (*common.Payload, error) // ### 8.4 构造归档数据恢复Payload // **参数说明** // - fullBlock: 完整区块数据(对应结构:store.BlockWithRWSet) // “`go CreateRestoreBlockPayload(fullBlock []byte) (*common.Payload, error) // ### 8.6 发送归档请求 // **参数说明** // - payload: 指向payload对象的指针 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - 备注:必须在ArchiveStatus.Process归档状态为Normal时才可调用成功 // “`go SendArchiveBlockRequest(payload *common.Payload, timeout int64) (*common.TxResponse, error) // ### 8.7 归档数据恢复 // **参数说明** // - payload: 指向payload对象的指针 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - 备注:必须在ArchiveStatus.Process归档状态为Normal时才可调用成功 // “`go SendRestoreBlockRequest(payload *common.Payload, timeout int64) (*common.TxResponse, error) // ### 8.8 根据交易Id查询已归档交易 // **参数说明** // - txId: 交易ID // “`go GetArchivedTxByTxId(txId string) (*common.TransactionInfo, error) // ### 8.9 根据区块高度查询已归档区块 // **参数说明** // - blockHeight: 指定区块高度 // - withRWSet: 是否返回读写集 // “`go GetArchivedBlockByHeight(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error) // ### 8.11 根据区块哈希查询已归档区块 // **参数说明** // - blockHash: 指定区块Hash // - withRWSet: 是否返回读写集 // “`go GetArchivedBlockByHash(blockHash string, withRWSet bool) (*common.BlockInfo, error) // ### 8.12 根据交易Id查询已归档区块 // **参数说明** // - txId: 交易ID // - withRWSet: 是否返回读写集 // “`go GetArchivedBlockByTxId(txId string, withRWSet bool) (*common.BlockInfo, error) // ## 9 隐私计算系统合约接口 // ### 9.1 保存隐私合约计算结果,包括合约部署 // **参数说明** // - contractName: 合约名称 // - contractVersion: 合约版本号 // - isDeployment: 是否是部署合约 // - codeHash: 合约字节码hash值 // - reportHash: Enclave report hash值 // - result: 隐私合约执行结果 // - codeHeader: solodity合部署合约时合约字节码的header数据 // - txId: 交易Id // - rwSet: 隐私合约执行产生的读写集 // - sign: Enclave对执行结果数据的结果签名 // - events: 合约执行产生的事件 // - privateReq: 用户调用隐私计算请求时的request序列化字节数组 // - withSyncResult: 是否同步返回调用结果 // - timeout: 发送交易的超时时间 // “`go SaveData(contractName string, contractVersion string, isDeployment bool, codeHash []byte, reportHash []byte, result *common.ContractResult, codeHeader []byte, txId string, rwSet *common.TxRWSet, sign []byte, events *common.StrSlice, privateReq []byte, withSyncResult bool, timeout int64) (*common.TxResponse, error) // ### 9.2 保存远程证明 // **参数说明** // - proof: 远程证明 // - txId: 交易Id // - withSyncResult: 是否同步返回调用结果 // - timeout: 交易发送超时时间 // “`go SaveRemoteAttestationProof(proof, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error) // ### 9.3 构建上传Enclave CA证书的报文 // **参数说明** // - caCert: Enclave CA证书 // - txId: 交易Id // “`go CreateSaveEnclaveCACertPayload(caCert, txId string) (*common.Payload, error) // ### 9.4 获取Enclave CA证书 // “`go GetEnclaveCACert() ([]byte, error) // ### 9.5 隐私计算调用者权限验证 // **参数说明** // - payload: 用户签名验证的payload内容 // - orgIds: 组织Id的slice,注意和signPairs里面SignInfo的证书顺序一致 // - signPairs: 用户多签的签名和证书slice // “`go CheckCallerCertAuth(payload string, orgIds []string, signPairs []*syscontract.SignInfo) (*common.TxResponse, error) // ### 9.6 获取Enclave的report // **参数说明** // - enclaveId: Enclave的Id,当前固定为"global_enclave_id" // “`go GetEnclaveReport(enclaveId string) ([]byte, error) // ### 9.7 获取隐私证明材料 // **参数说明** // - enclaveId: Enclave的Id,当前固定为"global_enclave_id" // “`go GetEnclaveProof(enclaveId string) ([]byte, error) // ### 9.8 获取隐私合约计算结果 // **参数说明** // - contractName: 合约名称 // - key: 计算结果对应的键值 // “`go GetData(contractName, key string) ([]byte, error) // ### 9.9 保存隐私目录 // **参数说明** // - orderId: 隐私目录的主键,供以后查询使用 // - txId: 交易ID // - privateDir: // - withSyncResult: 是否同步等待交易结果 // - timeout: 等待交易结果的超时时间 // “`go SaveDir(orderId, txId string, privateDir *common.StrSlice, withSyncResult bool, timeout int64) (*common.TxResponse, error) // ### 9.10 获取用户部署的隐私合约 // **参数说明** // - contractName: 合约名称 // - codeHash: 代码哈希 // “`go GetContract(contractName, codeHash string) (*common.PrivateGetContract, error) // ### 9.11 获取用户的隐私目录 // **参数说明** // - orderId: 隐私目录的主键 // “`go GetDir(orderId string) ([]byte, error) // ### 9.12 构建上传隐私计算环境的report的报文 // **参数说明** // - enclaveId: 隐私计算环境的标识 // - report: 隐私计算环境的report // - txId: 交易ID // “`go CreateSaveEnclaveReportPayload(enclaveId, report, txId string) (*common.Payload, error) // ### 9.13 获取隐私计算环境的加密公钥 // **参数说明** // - enclaveId: 隐私计算环境的标识 // “`go GetEnclaveEncryptPubKey(enclaveId string) ([]byte, error) // ### 9.14 获取隐私计算环境的验签公钥 // **参数说明** // - enclaveId: 隐私计算环境的标识 // “`go GetEnclaveVerificationPubKey(enclaveId string) ([]byte, error) // ### 9.15 获取隐私证明材料中的Challenge // **参数说明** // - enclaveId: 隐私计算环境的标识 // “`go GetEnclaveChallenge(enclaveId string) ([]byte, error) // ### 9.16 获取隐私证明材料中的Signature // **参数说明** // - enclaveId: 隐私计算环境的标识 // “`go GetEnclaveSignature(enclaveId string) ([]byte, error) // ## 10 系统类接口 // ### 10.1 SDK停止接口 // *关闭连接池连接,释放资源* // “`go Stop() error // ### 10.2 获取链版本 // “`go GetChainMakerServerVersion() (string, error) // ### 10.2 获取链版本 // “`go GetChainMakerServerVersionCustom(ctx context.Context) (string, error) // ## 11 公钥身份类接口 // ### 11.1 构造添加公钥身份请求 // **参数说明** // - pubkey: 公钥信息 // - orgId: 组织id // - role: 角色,支持client,light,common // “`go CreatePubkeyAddPayload(pubkey string, orgId string, role string) (*common.Payload, error) // ### 11.2 构造删除公钥身份请求 // **参数说明** // - pubkey: 公钥信息 // - orgId: 组织id // “`go CreatePubkeyDelPayload(pubkey string, orgId string) (*common.Payload, error) // ### 11.3 构造查询公钥身份请求 // **参数说明** // - pubkey: 公钥信息 // “`go CreatePubkeyQueryPayload(pubkey string) (*common.Payload, error) // ### 11.4 发送公钥身份管理请求(添加、删除) // **参数说明** // - payload: 交易payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go SendPubkeyManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ## 12 多签类接口 // ### 12.1 发起多签请求 // **参数说明** // - payload: 待签名payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go MultiSignContractReq(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // **参数说明** // payer: 指定gas代扣账户 MultiSignContractReqWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, payer *common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 12.2 发起多签投票 // **参数说明** // - payload: 待签名payload // - endorser: 投票人对多签请求 payload 的签名信息 // - isAgree: 投票人对多签请求是否同意,true为同意,false则反对 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go MultiSignContractVote(payload *common.Payload, endorser *common.EndorsementEntry, isAgree bool, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 12.3 根据txId查询多签状态 // **参数说明** // - txId: 需要查询的多签请求交易Id // “`go MultiSignContractQuery(txId string) (*common.TxResponse, error) // ### 12.4 触发执行多签请求 // **参数说明** // - payload: 待签名payload // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - limit: 本次执行多签请求支付的 gas 上限 // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go MultiSignContractTrig(multiSignReqPayload *common.Payload, timeout int64, limit *common.Limit, withSyncResult bool) (*common.TxResponse, error) // **参数说明** // payer: 指定gas代扣账户 MultiSignContractTrigWithPayer(multiSignReqPayload *common.Payload, payer *common.EndorsementEntry, timeout int64, limit *common.Limit, withSyncResult bool) (*common.TxResponse, error) // ### 12.5 根据发起多签请求所需的参数构建payload // **参数说明** // - pairs: 发起多签请求所需的参数 // “`go CreateMultiSignReqPayload(pairs []*common.KeyValuePair) *common.Payload // ### 12.6 根据发起多签请求所需的参数构建payload // **参数说明** // - pairs: 发起多签请求所需的参数 // - gasLimit: 本次交易允许消费的最大gas, 0代表无限制 // “`go CreateMultiSignReqPayloadWithGasLimit(pairs []*common.KeyValuePair, gasLimit uint64) *common.Payload // ### 12.7 发起多签投票 // **参数说明** // - payload: 待签名payload // - endorser: 投票人对多签请求 payload 的签名信息 // - isAgree: 投票人对多签请求是否同意,true为同意,false则反对 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - gasLimit: 交易允许消费的最大 gas, 0 代表无限制 // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go MultiSignContractVoteWithGasLimit(payload *common.Payload, endorser *common.EndorsementEntry, isAgree bool, timeout int64, gasLimit uint64, withSyncResult bool) (*common.TxResponse, error) // **参数说明** // payer: 指定gas代扣账户 MultiSignContractVoteWithGasLimitAndPayer(payload *common.Payload, endorser *common.EndorsementEntry, payer *common.EndorsementEntry, isAgree bool, timeout int64, gasLimit uint64, withSyncResult bool) (*common.TxResponse, error) // ### 12.8 根据txId查询多签状态 // **参数说明** // - txId: 需要查询的多签请求交易Id // - params: 格式化参数 // “`go MultiSignContractQueryWithParams(txId string, params []*common.KeyValuePair) (*common.TxResponse, error) // ## 13 gas管理相关接口 // ### 13.1 构造设置gas管理员payload // **参数说明** // - address: gas管理员的地址 // “`go CreateSetGasAdminPayload(address string) (*common.Payload, error) // ### 13.2 查询gas管理员 // **返回值说明** // - string: gas管理员的账号地址 // “`go GetGasAdmin() (string, error) // ### 13.3 构造 充值gas账户 payload // **参数说明** // - rechargeGasList: 一个或多个gas账户充值指定gas数量 // “`go CreateRechargeGasPayload(rechargeGasList []*syscontract.RechargeGas) (*common.Payload, error) // ### 13.4 查询gas账户余额 // **参数说明** // - address: 查询gas余额的账户地址 // “`go GetGasBalance(address string) (int64, error) // ### 13.5 构造 退还gas账户的gas payload // **参数说明** // - address: 退还gas的账户地址 // - amount: 退还gas的数量 // “`go CreateRefundGasPayload(address string, amount int64) (*common.Payload, error) // ### 13.6 构造 冻结指定gas账户 payload // **参数说明** // - address: 冻结指定gas账户的账户地址 // “`go CreateFrozenGasAccountPayload(address string) (*common.Payload, error) // ### 13.7 构造 解冻指定gas账户 payload // **参数说明** // - address: 解冻指定gas账户的账户地址 // “`go CreateUnfrozenGasAccountPayload(address string) (*common.Payload, error) // ### 13.8 查询gas账户的状态 // **参数说明** // - address: 解冻指定gas账户的账户地址 // **返回值说明** // - bool: true表示账号未被冻结,false表示账号已被冻结 // “`go GetGasAccountStatus(address string) (bool, error) // ### 13.9 发送gas管理类请求 // **参数说明** // - payload: 交易payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go SendGasManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 13.10 为payload添加gas limit // **参数说明** // - payload: 交易payload // - limit: transaction limitation,执行交易时的资源消耗上限 // “`go AttachGasLimit(payload *common.Payload, limit *common.Limit) *common.Payload // ### 13.11 估算交易的gas消耗量 // **参数说明** // - payload: 待估算gas消耗量的交易payload // **返回值说明** // - uint64: 估算出的gas消耗量 // “`go EstimateGas(payload *common.Payload) (uint64, error) // ### 13.12 构造 配置账户基础gas消耗数量 payload // **参数说明** // - amount: 调用合约消耗的基础的 gas 数量 // “`go CreateSetInvokeBaseGasPayload(invokeBaseGas int64) (*common.Payload, error) // ### 13.13 设置链配置的 default gas_price 参数 // **参数说明** // - invokeGasPrice: 调用合约中所带参数消耗的每个字节的 gas 价格,支持格式为10进制整数|小数 // “`go CreateSetInvokeGasPricePayload(invokeGasPrice string) (*common.Payload, error) // ### 13.14 设置链配置的 install_base gas 参数 // **参数说明** // - amount: 安装|升级合约消耗的基础的 gas 数量 // “`go CreateSetInstallBaseGasPayload(installBaseGas int64) (*common.Payload, error) // ### 13.15 设置链配置的 install gas_price 参数 // **参数说明** // - invokeGasPrice: 安装|升级合约中所带参数消耗的每个字节的 gas 价格,支持格式为10进制整数|小数 // “`go CreateSetInstallGasPricePayload(installGasPrice string) (*common.Payload, error) // ## 14 别名相关接口 // ### 14.1 添加别名 // “`go AddAlias() (*common.TxResponse, error) // ### 14.2 构造`更新别名的证书`payload // **参数说明** // - alias: 带更新证书的别名 // - newCertPEM: 新的证书,此新证书将替换掉alias关联的证书 // “`go CreateUpdateCertByAliasPayload(alias, newCertPEM string) *common.Payload // ### 14.3 签名`更新别名的证书`payload // **参数说明** // - payload: 交易payload // “`go SignUpdateCertByAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error) // ### 14.4 发起`更新别名的证书`交易 // **参数说明** // - payload: 交易payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go UpdateCertByAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ### 14.5 查询别名详细信息 // **参数说明** // - aliases: 带查询的证书别名切片,根据这些别名查询返回AliasInfos // “`go QueryCertsAlias(aliases []string) (*common.AliasInfos, error) // ### 14.6 构造`删除别名`payload // **参数说明** // - aliases: 带删除的证书别名切片 // “`go CreateDeleteCertsAliasPayload(aliases []string) *common.Payload // ### 14.7 签名`删除别名`payload // **参数说明** // - payload: 交易payload // “`go SignDeleteAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error) // ### 14.8 发起`删除别名`交易 // **参数说明** // - payload: 交易payload // - endorsers: 背书签名信息列表 // - timeout: 超时时间,单位:s,若传入-1,将使用默认超时时间:10s // - withSyncResult: 是否同步获取交易执行结果 // 当为true时,若成功调用,common.TxResponse.ContractResult.Result为common.TransactionInfo // 当为false时,若成功调用,common.TxResponse.ContractResult为空,可以通过common.TxResponse.TxId查询交易结果 // “`go DeleteCertsAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, withSyncResult bool) (*common.TxResponse, error) // ## 15 交易池相关接口 // ### 15.1 获取交易池状态 // “`go GetPoolStatus() (*txpool.TxPoolStatus, error) // ### 15.2 获取不同交易类型和阶段中的交易Id列表。 // **参数说明** // - txType: 交易类型 在pb的txpool包中进行了定义 // - txStage: 交易阶段 在pb的txpool包中进行了定义 // **返回值说明** // - []string: 交易Id列表 // “`go GetTxIdsByTypeAndStage(txType txpool.TxType, txStage txpool.TxStage) ([]string, error) // ### 15.3 根据txIds获取交易池中存在的txs,并返回交易池缺失的tx的txIds // **参数说明** // - txIds: 交易Id列表 // **返回值说明** // - []*common.Transaction: 交易池中存在的txs // - []string: 交易池缺失的tx的txIds // “`go GetTxsInPoolByTxIds(txIds []string) ([]*common.Transaction, []string, error) // ## 16 Payer相关接口 // ### 16.1 设置Payer // “`go SetContractMethodPayer( payerAddress string, contractName string, methodName string, requestId string, payerOrgId string, payerKeyPem []byte, payerCertPem []byte, gasLimit uint64) ( *common.TxResponse, error) // ### 16.2 取消Payer // “`go UnsetContractMethodPayer( contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error) // ### 16.3 查询Payer // “`go QueryContractMethodPayer( contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error) // ### 16.3 查询交易Payer // “`go QueryTxPayer(tsId string, gasLimit uint64) (*common.TxResponse, error) // ArchiveBlocks 归档指定区块高度范围的区块到归档服务 // @param beginHeight // @param endHeight // @param mode // @param heightNoticeCallback 归档进度通知 // @return error ArchiveBlocks(archiveHeight uint64, mode string, heightNoticeCallback func(ProcessMessage) error) error // RestoreBlocks 从归档服务中恢复到指定高度的区块到节点中 // @param restoreHeight 指定恢复高度 // @param heightNoticeCallback 恢复进度通知 // @return error RestoreBlocks(restoreHeight uint64, mode string, heightNoticeCallback func(ProcessMessage) error) error // ## 17 共识相关接口 // ### 17.1 获取所有共识节点的身份标识 // **返回值说明** // - []string: 共识节点身份标识 // - err: 当查询的节点非共识节点时或共识节点内部查询中出现错误,返回error // “`go GetConsensusValidators() ([]string, error) // ### 17.2 获取节点正在共识的区块高度 // **返回值说明** // - uint64: 节点正在共识的区块高度 // - err: 当查询的节点非共识节点时或共识节点内部查询中出现错误,返回error // “`go GetConsensusHeight() (uint64, error) // ### 17.3 获取共识节点的状态 // **返回值说明** // - []byte: 查询的共识节点状态 // - err: 当查询的节点非共识节点时或共识节点内部查询中出现错误,返回error // “`go GetConsensusStateJSON() ([]byte, error) }
SDKInterface # ChainMaker Go SDK 接口说明
Source Files ¶
- archive_center_grpc_impl.go
- archive_center_http_impl.go
- archive_mysql_impl.go
- conn_pool.go
- sdk_archive.go
- sdk_block_chain.go
- sdk_canonical_tx_result.go
- sdk_cert_alias_manage.go
- sdk_cert_manage.go
- sdk_chain_config.go
- sdk_chainmaker_server.go
- sdk_client.go
- sdk_common.go
- sdk_config.go
- sdk_consensus.go
- sdk_func.go
- sdk_gas_manage.go
- sdk_hibe.go
- sdk_interface.go
- sdk_multisign_contract.go
- sdk_payer_contract.go
- sdk_private_system_contract.go
- sdk_pubkey_manage.go
- sdk_signer.go
- sdk_subscribe.go
- sdk_system_contract.go
- sdk_tx_pool.go
- sdk_tx_result.go
- sdk_user_contract.go
- test_helper.go
Directories ¶
Path | Synopsis |
---|---|
archive-mysql
|
|
model
Package model define archive db model
|
Package model define archive db model |
mysql
Package mysql define mysql db operation
|
Package mysql define mysql db operation |
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
Package utils common utils
|
Package utils common utils |