chainmaker_sdk_go

package module

Go to main page

Versions in this module

v2

v2.3.7

Nov 7, 2024

v2.3.6

Sep 14, 2024

Changes in this version

+ func KMSEnabled() bool

type ChainClient

+ func (cc *ChainClient) GetSyncState(withOthersState bool) (*sync.SyncState, error)

+ func (cc *ChainClient) KMSConfig() *KMSConfig

type ChainClientOption

+ func WithKMSConfig(conf *KMSConfig) ChainClientOption

+ func WithUserEncCrtBytes(userEncCrtBytes []byte) ChainClientOption

+ func WithUserEncKeyBytes(userEncKeyBytes []byte) ChainClientOption

+ type KMSConfig struct

+ Address string

+ Enabled bool

+ ExtParams string

+ IsPublic bool

+ Region string

+ SdkScheme string

+ SecretId string

+ SecretKey string

+ func NewKMSConfig(enabled bool, isPublic bool, ...) *KMSConfig

type SDKInterface

+ GetSyncState func(withOthersState bool) (*sync.SyncState, error)

v2.3.5

Jun 25, 2024

Changes in this version

type ChainClient

+ func (cc *ChainClient) GetConsensusHeight() (uint64, error)

+ func (cc *ChainClient) GetConsensusStateJSON() ([]byte, error)

+ func (cc *ChainClient) GetConsensusValidators() ([]string, 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)

type SDKInterface

+ GetConsensusHeight func() (uint64, error)

+ GetConsensusStateJSON func() ([]byte, error)

+ GetConsensusValidators func() ([]string, error)

+ SubscribeTxByPreAlias func(ctx context.Context, startBlock, endBlock int64, aliasPrefix string) (<-chan interface{}, error)

+ SubscribeTxByPreOrgId func(ctx context.Context, startBlock, endBlock int64, orgIdPrefix string) (<-chan interface{}, error)

+ SubscribeTxByPreTxId func(ctx context.Context, startBlock, endBlock int64, txIdPrefix string) (<-chan interface{}, error)

v2.3.4

Mar 29, 2024

Changes in this version

type ArchiveMySqlClient

+ func (a *ArchiveMySqlClient) Close() error

type ArchiveService

+ Close func() error

type ChainClient

+ func (cc *ChainClient) QueryContractMethodPayer(contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)

+ func (cc *ChainClient) QueryTxPayer(txId string, gasLimit uint64) (*common.TxResponse, error)

+ func (cc *ChainClient) SetContractMethodPayer(payerAddress string, contractName string, methodName string, requestId string, ...) (*common.TxResponse, error)

+ func (cc *ChainClient) UnsetContractMethodPayer(contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)

type SDKInterface

+ QueryContractMethodPayer func(contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)

+ QueryTxPayer func(tsId string, gasLimit uint64) (*common.TxResponse, error)

+ SetContractMethodPayer func(payerAddress string, contractName string, methodName string, requestId string, ...) (*common.TxResponse, error)

+ UnsetContractMethodPayer func(contractName string, methodName string, gasLimit uint64) (*common.TxResponse, error)

v2.3.3

Jul 18, 2023

Changes in this version

+ func SM3(data []byte) (string, error)

+ type ArchiveCenterConfig struct

+ ArchiveCenterHttpUrl string

+ ChainGenesisHash string

+ MaxRecvMsgSize int

+ MaxSendMsgSize int

+ ReqeustSecondLimit int

+ RpcAddress string

+ Tls utils.TlsConfig

+ TlsEnable bool

+ func NewArchiveCenterConfig(httpUrl, rpcUrl, chainGenesisHash string, ...) *ArchiveCenterConfig

+ type ArchiveCenterGrpcClient struct

+ func NewArchiveCenterGrpcClient(config *ArchiveCenterConfig, log utils.Logger) *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 (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 (a *ArchiveCenterGrpcClient) Register(genesisBlock *common.BlockInfo) error

+ func (client *ArchiveCenterGrpcClient) Close() error

+ func (client *ArchiveCenterGrpcClient) GrpcCallOption() []grpc.CallOption

+ type ArchiveCenterHttpClient struct

+ func NewArchiveCenterHttpClient(config *ArchiveCenterConfig, log utils.Logger) *ArchiveCenterHttpClient

+ func (_ *ArchiveCenterHttpClient) Close() error

+ func (a *ArchiveCenterHttpClient) ArchiveBlock(block *common.BlockInfo) error

+ func (a *ArchiveCenterHttpClient) ArchiveBlocks(bi BlockIterator, _ func(ProcessMessage) error) error

+ func (a *ArchiveCenterHttpClient) ArchiveCenterConfig() *ArchiveCenterConfig

+ 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 struct

+ BlockHash string

+ ChainGenesisHash string

+ End uint64

+ Height uint64

+ Start uint64

+ TruncateLength int

+ TruncateModel string

+ TxId string

+ WithRwSet bool

+ type ArchiveCenterResponse struct

+ Code int

+ ErrorMsg string

+ type ArchiveCenterResponseBlockHeader struct

+ Data *common.BlockHeader

+ type ArchiveCenterResponseBlockInfo struct

+ Data *common.BlockInfo

+ type ArchiveCenterResponseBlockWithRwSet struct

+ Data *common.BlockInfo

+ type ArchiveCenterResponseChainConfig struct

+ Data *config.ChainConfig

+ type ArchiveCenterResponseHeight struct

+ Data *uint64

+ type ArchiveCenterResponseMerklePath struct

+ Data []byte

+ type ArchiveCenterResponseTransaction struct

+ Data *common.TransactionInfo

+ type ArchiveCenterResponseTransactionWithRwSet struct

+ Data *common.TransactionInfoWithRWSet

type ArchiveConfig

+ Dest string

+ type ArchiveMySqlClient struct

+ func NewArchiveMySqlClient(chainId string, config *ArchiveConfig, cc SDKInterface, log utils.Logger) *ArchiveMySqlClient

+ func NewArchiveMySqlClient2(chainId, dbDest string, secretKey string, cc SDKInterface, log utils.Logger) *ArchiveMySqlClient

+ func (a *ArchiveMySqlClient) ArchiveBlock(block *common.BlockInfo) error

+ func (a *ArchiveMySqlClient) ArchiveBlocks(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) 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

+ func WithDest(dest string) ArchiveOption

+ func WithType(archiveType string) ArchiveOption

+ type ArchiveService interface

+ ArchiveBlock func(block *common.BlockInfo) error

+ ArchiveBlocks func(bi BlockIterator, heightNoticeCallback func(ProcessMessage) error) error

+ GetArchivedStatus func() (archivedHeight uint64, inArchive bool, code uint32, err error)

+ GetBlockByHash func(blockHash string, withRWSet bool) (*common.BlockInfo, error)

+ GetBlockByHeight func(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)

+ GetBlockByTxId func(txId string, withRWSet bool) (*common.BlockInfo, error)

+ GetChainConfigByBlockHeight func(blockHeight uint64) (*config.ChainConfig, error)

+ GetTxByTxId func(txId string) (*common.TransactionInfo, error)

+ GetTxWithRWSetByTxId func(txId string) (*common.TransactionInfoWithRWSet, error)

+ Register func(genesis *common.BlockInfo) error

+ type BlockIterator interface

+ Current func() uint64

+ Next func() bool

+ Release func()

+ Total func() uint64

+ Value func() (*common.BlockInfo, error)

type ChainClient

+ func (cc *ChainClient) ArchiveBlocks(archiveHeight uint64, mode string, heightNotice func(ProcessMessage) error) error

+ func (cc *ChainClient) ArchiveCenterConfig() *ArchiveCenterConfig

+ func (cc *ChainClient) CreateMultiSignReqPayloadWithGasLimit(pairs []*common.KeyValuePair, gasLimit uint64) *common.Payload

+ func (cc *ChainClient) CreateRestoreBlocksPayload(fullBlocks [][]byte) (*common.Payload, error)

+ func (cc *ChainClient) CreateSetInstallBaseGasPayload(amount int64) (*common.Payload, error)

+ func (cc *ChainClient) CreateSetInstallGasPricePayload(gasPrice string) (*common.Payload, error)

+ func (cc *ChainClient) CreateSetInvokeGasPricePayload(gasPrice string) (*common.Payload, 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) GetChainMakerServerVersionCustom(ctx context.Context) (string, error)

+ func (cc *ChainClient) IsArchiveCenterQueryFist() bool

+ func (cc *ChainClient) MultiSignContractQueryWithParams(txId string, params []*common.KeyValuePair) (*common.TxResponse, error)

+ func (cc *ChainClient) MultiSignContractReqWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxResponse, error)

+ func (cc *ChainClient) MultiSignContractTrigWithPayer(multiSignReqPayload *common.Payload, payer *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) RestoreBlocks(restoreHeight uint64, _ string, ...) error

+ func (cc *ChainClient) SendContractManageRequestWithPayer(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxResponse, error)

type ChainClientOption

+ func WithArchiveCenterHttpConfig(conf *ArchiveCenterConfig) ChainClientOption

+ func WithArchiveCenterQueryFirst(first bool) ChainClientOption

+ type ProcessMessage struct

+ CurrentHeight uint64

+ Error error

+ Total uint64

type SDKInterface

+ ArchiveBlocks func(archiveHeight uint64, mode string, ...) error

+ CreateMultiSignReqPayloadWithGasLimit func(pairs []*common.KeyValuePair, gasLimit uint64) *common.Payload

+ CreateSetInstallBaseGasPayload func(installBaseGas int64) (*common.Payload, error)

+ CreateSetInstallGasPricePayload func(installGasPrice string) (*common.Payload, error)

+ CreateSetInvokeGasPricePayload func(invokeGasPrice string) (*common.Payload, error)

+ GetArchiveStatus func() (*store.ArchiveStatus, error)

+ GetChainMakerServerVersionCustom func(ctx context.Context) (string, error)

+ MultiSignContractQueryWithParams func(txId string, params []*common.KeyValuePair) (*common.TxResponse, error)

+ MultiSignContractReqWithPayer func(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxResponse, error)

+ MultiSignContractTrigWithPayer func(multiSignReqPayload *common.Payload, payer *common.EndorsementEntry, ...) (*common.TxResponse, error)

+ MultiSignContractVoteWithGasLimit func(payload *common.Payload, endorser *common.EndorsementEntry, isAgree bool, ...) (*common.TxResponse, error)

+ MultiSignContractVoteWithGasLimitAndPayer func(payload *common.Payload, endorser *common.EndorsementEntry, ...) (*common.TxResponse, error)

+ RestoreBlocks func(restoreHeight uint64, mode string, ...) error

+ SendContractManageRequestWithPayer func(payload *common.Payload, endorsers []*common.EndorsementEntry, ...) (*common.TxResponse, error)

v2.3.2

Feb 20, 2023

Changes in this version

type ChainClient

+ func (cc *ChainClient) CreateChainConfigEnableMultiSignManualRunPayload(enable bool) (*common.Payload, error)

+ func (cc *ChainClient) MultiSignContractTrig(multiSignReqPayload *common.Payload, timeout int64, limit *common.Limit, ...) (*common.TxResponse, error)

type SDKInterface

+ GetBlockByHeightTruncate func(blockHeight uint64, withRWSet bool, truncateLength int, truncateModel string) (*common.BlockInfo, error)

+ MultiSignContractTrig func(multiSignReqPayload *common.Payload, timeout int64, limit *common.Limit, ...) (*common.TxResponse, error)

v2.3.1

Sep 6, 2022

v2.3.0

Sep 1, 2022

Changes in this version

+ const ZXLAddressPrefix

+ 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 GetEVMAddressFromPKHex(pkHex string, hashType crypto.HashType) (string, error)

+ func GetEVMAddressFromPKPEM(pkPEM string, hashType crypto.HashType) (string, error)

+ func NewCanonicalTxFetcherPools(config *ChainClientConfig) (map[string]ConnectionPool, error)

+ type CertAliasSigner struct

+ Cert *bcx509.Certificate

+ CertAlias string

+ OrgId string

+ PrivateKey crypto.PrivateKey

+ func (signer *CertAliasSigner) NewMember() (*accesscontrol.Member, error)

+ func (signer *CertAliasSigner) Sign(payload *common.Payload) ([]byte, error)

+ type CertHashSigner struct

+ Cert *bcx509.Certificate

+ CertHash []byte

+ OrgId string

+ PrivateKey crypto.PrivateKey

+ func (signer *CertHashSigner) NewMember() (*accesscontrol.Member, error)

+ func (signer *CertHashSigner) Sign(payload *common.Payload) ([]byte, error)

+ type CertModeSigner struct

+ Cert *bcx509.Certificate

+ OrgId string

+ PrivateKey crypto.PrivateKey

+ func (signer *CertModeSigner) NewMember() (*accesscontrol.Member, error)

+ func (signer *CertModeSigner) Sign(payload *common.Payload) ([]byte, error)

type ChainClient

+ ConfigModel *utils.ChainClientConfigModel

+ func (cc *ChainClient) CreateChainConfigOptimizeChargeGasPayload(enable bool) (*common.Payload, error)

+ func (cc *ChainClient) CreateSetInvokeBaseGasPayload(amount int64) (*common.Payload, error)

+ func (cc *ChainClient) EstimateGas(payload *common.Payload) (uint64, error)

+ func (cc *ChainClient) GenerateTxRequestBySigner(payload *common.Payload, endorsers []*common.EndorsementEntry, signer Signer) (*common.TxRequest, error)

+ func (cc *ChainClient) GetBlockByHeightTruncate(blockHeight uint64, withRWSet bool, truncateLength int, truncateModel string) (*common.BlockInfo, error)

+ func (cc *ChainClient) GetChainConfigPermissionList() ([]*config.ResourcePolicy, error)

+ func (cc *ChainClient) GetPoolStatus() (*txpool.TxPoolStatus, 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) GetTxsInPoolByTxIds(txIds []string) ([]*common.Transaction, []string, error)

+ func (cc *ChainClient) InvokeContractBySigner(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)

type ChainClientConfig

+ ConfigModel *utils.ChainClientConfigModel

type ChainClientOption

+ func WithCryptoConfig(conf *CryptoConfig) ChainClientOption

+ func WithEnableSyncCanonicalTxResult(enable bool) ChainClientOption

+ func WithEnableTxResultDispatcher(enable bool) ChainClientOption

+ func WithUserEncKeyPwd(pwd string) ChainClientOption

+ func WithUserKeyPwd(pwd string) ChainClientOption

+ func WithUserSignKeyPwd(pwd string) ChainClientOption

type CryptoConfig

+ func NewCryptoConfig(opts ...CryptoOption) *CryptoConfig

+ type PermissionedWithKeyModeSigner struct

+ HashType crypto.HashType

+ OrgId string

+ PrivateKey crypto.PrivateKey

+ func (signer *PermissionedWithKeyModeSigner) NewMember() (*accesscontrol.Member, error)

+ func (signer *PermissionedWithKeyModeSigner) Sign(payload *common.Payload) ([]byte, error)

type Pkcs11Config

+ Type string

+ type PublicModeSigner struct

+ HashType crypto.HashType

+ PrivateKey crypto.PrivateKey

+ func (signer *PublicModeSigner) NewMember() (*accesscontrol.Member, error)

+ func (signer *PublicModeSigner) Sign(payload *common.Payload) ([]byte, error)

type RPCClientOption

+ func WithRPCClientGetTxTimeout(timeout int64) RPCClientOption

+ func WithRPCClientSendTxTimeout(timeout int64) RPCClientOption

type SDKInterface

+ CreateChainConfigOptimizeChargeGasPayload func(enable bool) (*common.Payload, error)

+ CreateSetInvokeBaseGasPayload func(amount int64) (*common.Payload, error)

+ EstimateGas func(payload *common.Payload) (uint64, error)

+ GetChainConfigPermissionList func() ([]*config.ResourcePolicy, error)

+ GetPoolStatus func() (*txpool.TxPoolStatus, error)

+ GetTxIdsByTypeAndStage func(txType txpool.TxType, txStage txpool.TxStage) ([]string, error)

+ GetTxsInPoolByTxIds func(txIds []string) ([]*common.Transaction, []string, error)

+ type Signer interface

+ NewMember func() (*accesscontrol.Member, error)

+ Sign func(payload *common.Payload) (signature []byte, err error)

v2.2.1

May 17, 2022

Changes in this version

type ChainClient

+ func (cc *ChainClient) IsEnableNormalKey() bool

type ChainClientOption

+ func WithEnableNormalKey(enableNormalKey bool) ChainClientOption

v2.2.0

Mar 16, 2022

Changes in this version

+ const DefaultRpcClientMaxSendMessageSize

+ const KEY_ALIAS

+ const KEY_ALIASES

+ const KEY_CERT

+ func GetZXAddressFromCertPEM(certPEM string) (string, error)

+ func GetZXAddressFromCertPath(certPath string) (string, error)

+ func GetZXAddressFromPKHex(pkHex string) (string, error)

+ func GetZXAddressFromPKPEM(pkPEM string) (string, error)

type ChainClient

+ func (cc *ChainClient) AddAlias() (*common.TxResponse, error)

+ 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) CreateChainConfigAlterAddrTypePayload(addrType string) (*common.Payload, error)

+ func (cc *ChainClient) CreateChainConfigEnableOrDisableGasPayload() (*common.Payload, error)

+ func (cc *ChainClient) CreateDeleteCertsAliasPayload(aliases []string) *common.Payload

+ func (cc *ChainClient) CreateFrozenGasAccountPayload(address string) (*common.Payload, error)

+ func (cc *ChainClient) CreatePayload(txId string, txType common.TxType, contractName, method string, ...) *common.Payload

+ func (cc *ChainClient) CreateRechargeGasPayload(rechargeGasList []*syscontract.RechargeGas) (*common.Payload, error)

+ func (cc *ChainClient) CreateRefundGasPayload(address string, amount int64) (*common.Payload, error)

+ func (cc *ChainClient) CreateSetGasAdminPayload(address 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) DeleteCertsAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ func (cc *ChainClient) EnableAlias() error

+ func (cc *ChainClient) GenerateTxRequest(payload *common.Payload, endorsers []*common.EndorsementEntry) (*common.TxRequest, error)

+ func (cc *ChainClient) GetCertPEM() []byte

+ 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) GetLocalCertAlias() string

+ func (cc *ChainClient) GetPrivateKey() crypto.PrivateKey

+ func (cc *ChainClient) GetPublicKey() crypto.PublicKey

+ func (cc *ChainClient) GetSyncResult(txId string) (*common.Result, error)

+ func (cc *ChainClient) GetTxWithRWSetByTxId(txId string) (*common.TransactionInfoWithRWSet, error)

+ func (cc *ChainClient) InvokeContractWithLimit(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)

+ func (cc *ChainClient) QueryCertsAlias(aliases []string) (*common.AliasInfos, error)

+ func (cc *ChainClient) SendGasManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ func (cc *ChainClient) SignDeleteAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error)

+ func (cc *ChainClient) SignUpdateCertByAliasPayload(payload *common.Payload) (*common.EndorsementEntry, error)

+ func (cc *ChainClient) UpdateCertByAlias(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

type ChainClientOption

+ func WithChainClientAlias(alias string) ChainClientOption

type RPCClientOption

+ func WithRPCClientMaxSendMessageSize(size int) RPCClientOption

type SDKInterface

+ AddAlias func() (*common.TxResponse, error)

+ AttachGasLimit func(payload *common.Payload, limit *common.Limit) *common.Payload

+ CreateChainConfigAlterAddrTypePayload func(addrType string) (*common.Payload, error)

+ CreateChainConfigEnableOrDisableGasPayload func() (*common.Payload, error)

+ CreateDeleteCertsAliasPayload func(aliases []string) *common.Payload

+ CreateFrozenGasAccountPayload func(address string) (*common.Payload, error)

+ CreateRechargeGasPayload func(rechargeGasList []*syscontract.RechargeGas) (*common.Payload, error)

+ CreateRefundGasPayload func(address string, amount int64) (*common.Payload, error)

+ CreateSetGasAdminPayload func(address string) (*common.Payload, error)

+ CreateUnfrozenGasAccountPayload func(address string) (*common.Payload, error)

+ CreateUpdateCertByAliasPayload func(alias, newCertPEM string) *common.Payload

+ DeleteCertsAlias func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ GetGasAccountStatus func(address string) (bool, error)

+ GetGasAdmin func() (string, error)

+ GetGasBalance func(address string) (int64, error)

+ GetTxWithRWSetByTxId func(txId string) (*common.TransactionInfoWithRWSet, error)

+ InvokeContractWithLimit func(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)

+ QueryCertsAlias func(aliases []string) (*common.AliasInfos, error)

+ SendGasManageRequest func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ SignDeleteAliasPayload func(payload *common.Payload) (*common.EndorsementEntry, error)

+ SignUpdateCertByAliasPayload func(payload *common.Payload) (*common.EndorsementEntry, error)

+ UpdateCertByAlias func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

v2.1.0

Nov 6, 2021

Changes in this version

+ const DefaultAuthType

+ const DefaultRetryInterval

+ const DefaultRetryLimit

+ var AuthTypeToStringMap = map[AuthType]string

+ var StringToAuthTypeMap = map[string]AuthType

+ func GetEVMAddressFromPrivateKeyBytes(privateKeyBytes []byte, hashType string) (string, error)

+ func GetEVMAddressFromPrivateKeyPath(privateKeyFilePath, hashType string) (string, error)

+ func GetP11Handle() *pkcs11.P11Handle

+ type AuthType uint32

+ const PermissionedWithCert

+ const PermissionedWithKey

+ const Public

type ChainClient

+ func (cc *ChainClient) CreateMultiSignReqPayload(pairs []*common.KeyValuePair) *common.Payload

+ func (cc *ChainClient) CreateNativeContractAccessGrantPayload(grantContractList []string) (*common.Payload, error)

+ func (cc *ChainClient) CreateNativeContractAccessRevokePayload(revokeContractList []string) (*common.Payload, error)

+ 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) GetAuthType() AuthType

+ func (cc *ChainClient) GetContractInfo(contractName string) (*common.Contract, error)

+ func (cc *ChainClient) GetContractList() ([]*common.Contract, error)

+ func (cc *ChainClient) GetDisabledNativeContractList() ([]string, error)

+ func (cc *ChainClient) GetHashType() string

+ func (cc *ChainClient) GetMerklePathByTxId(txId string) ([]byte, error)

+ func (cc *ChainClient) MultiSignContractQuery(txId string) (*common.TxResponse, error)

+ func (cc *ChainClient) MultiSignContractReq(payload *common.Payload) (*common.TxResponse, error)

+ func (cc *ChainClient) MultiSignContractVote(multiSignReqPayload *common.Payload, endorser *common.EndorsementEntry) (*common.TxResponse, error)

+ func (cc *ChainClient) Pkcs11Config() *Pkcs11Config

+ func (cc *ChainClient) SendPubkeyManageRequest(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

type ChainClientOption

+ func WithAuthType(authType string) ChainClientOption

+ func WithPkcs11Config(conf *Pkcs11Config) ChainClientOption

+ func WithRetryInterval(interval int) ChainClientOption

+ func WithRetryLimit(limit int) ChainClientOption

+ type CryptoConfig struct

+ type CryptoOption func(config *CryptoConfig)

+ func WithHashAlgo(hashType string) CryptoOption

+ type Pkcs11Config struct

+ Enabled bool

+ Hash string

+ Label string

+ Library string

+ Password string

+ SessionCacheSize int

+ func NewPkcs11Config(enabled bool, libPath, label, password string, sessionCacheSize int, ...) *Pkcs11Config

type SDKInterface

+ CreateMultiSignReqPayload func(pairs []*common.KeyValuePair) *common.Payload

+ CreateNativeContractAccessGrantPayload func(grantContractList []string) (*common.Payload, error)

+ CreateNativeContractAccessRevokePayload func(revokeContractList []string) (*common.Payload, error)

+ CreatePubkeyAddPayload func(pubkey string, orgId string, role string) (*common.Payload, error)

+ CreatePubkeyDelPayload func(pubkey string, orgId string) (*common.Payload, error)

+ CreatePubkeyQueryPayload func(pubkey string) (*common.Payload, error)

+ GetContractInfo func(contractName string) (*common.Contract, error)

+ GetContractList func() ([]*common.Contract, error)

+ GetDisabledNativeContractList func() ([]string, error)

+ GetMerklePathByTxId func(txId string) ([]byte, error)

+ MultiSignContractQuery func(txId string) (*common.TxResponse, error)

+ MultiSignContractReq func(payload *common.Payload) (*common.TxResponse, error)

+ MultiSignContractVote func(payload *common.Payload, endorser *common.EndorsementEntry) (*common.TxResponse, error)

+ SendPubkeyManageRequest func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

v2.0.0

Sep 1, 2021

Changes in this version

+ const ContractResultCode_OK

+ const DefaultGetTxTimeout

+ const DefaultRpcClientMaxReceiveMessageSize

+ const DefaultSendTxTimeout

+ const HibeMsgCipherTextKey

+ const HibeMsgIdKey

+ const HibeMsgKey

+ const HibeParamsKey

+ const HibeParamsValueKey

+ const MaxConnCnt

+ func GetEVMAddressFromCertBytes(certBytes []byte) (string, error)

+ func GetEVMAddressFromCertPath(certFilePath string) (string, error)

+ func SignPayload(keyBytes, crtBytes []byte, payload *common.Payload) (*common.EndorsementEntry, error)

+ func SignPayloadWithPath(keyFilePath, crtFilePath string, payload *common.Payload) (*common.EndorsementEntry, error)

+ type ArchiveConfig struct

+ func NewArchiveConfig(opts ...ArchiveOption) *ArchiveConfig

+ type ArchiveOption func(config *ArchiveConfig)

+ func WithSecretKey(key string) ArchiveOption

+ type ChainClient struct

+ func CreateChainClient(pool ConnectionPool, userCrtBytes, privKey, userCrtHash []byte, ...) (*ChainClient, error)

+ func NewChainClient(opts ...ChainClientOption) (*ChainClient, error)

+ func (cc *ChainClient) AddCert() (*common.TxResponse, 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) CreateChainConfigBlockUpdatePayload(txTimestampVerify 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) 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(trustRootOrgId string) (*common.Payload, error)

+ func (cc *ChainClient) CreateChainConfigTrustRootUpdatePayload(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)

+ func (cc *ChainClient) CreateContractCreatePayload(contractName, version, byteCode string, runtime common.RuntimeType, ...) (*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, byteCode string, runtime common.RuntimeType, ...) (*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) CreateRestoreBlockPayload(fullBlock []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) DecryptHibeTxByTxId(localId string, hibeParams []byte, hibePrvKey []byte, txId string, ...) ([]byte, error)

+ func (cc *ChainClient) DeleteCert(certHashes []string) (*common.TxResponse, error)

+ func (cc *ChainClient) DisableCertHash() error

+ func (cc *ChainClient) EasyCodecItemToParamsMap(items []*serialize.EasyCodecItem) map[string][]byte

+ func (cc *ChainClient) EnableCertHash() 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) GetArchivedBlockFromMySQL(blockHeight uint64) (*store.BlockWithRWSet, error)

+ func (cc *ChainClient) GetArchivedBlockHeight() (uint64, error)

+ func (cc *ChainClient) GetArchivedFullBlockByHeight(blockHeight uint64) (*store.BlockWithRWSet, error)

+ func (cc *ChainClient) GetArchivedTxByTxId(txId string) (*common.TransactionInfo, error)

+ 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) 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) GetChainConfig() (*config.ChainConfig, error)

+ func (cc *ChainClient) GetChainConfigByBlockHeight(blockHeight uint64) (*config.ChainConfig, error)

+ func (cc *ChainClient) GetChainConfigSequence() (uint64, error)

+ func (cc *ChainClient) GetChainInfo() (*discovery.ChainInfo, error)

+ func (cc *ChainClient) GetChainMakerServerVersion() (string, error)

+ func (cc *ChainClient) GetContract(contractName, codeHash string) (*common.PrivateGetContract, 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) 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) GetFromArchiveStore(blockHeight uint64) (*store.BlockWithRWSet, error)

+ func (cc *ChainClient) GetFullBlockByHeight(blockHeight uint64) (*store.BlockWithRWSet, error)

+ func (cc *ChainClient) GetLastBlock(withRWSet bool) (*common.BlockInfo, error)

+ func (cc *ChainClient) GetLastConfigBlock(withRWSet bool) (*common.BlockInfo, error)

+ func (cc *ChainClient) GetNodeChainList() (*discovery.ChainList, error)

+ func (cc *ChainClient) GetTxByTxId(txId string) (*common.TransactionInfo, error)

+ func (cc *ChainClient) GetTxRequest(contractName, method, txId string, kvs []*common.KeyValuePair) (*common.TxRequest, 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) InvokeSystemContract(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)

+ func (cc *ChainClient) QueryCert(certHashes []string) (*common.CertInfos, error)

+ func (cc *ChainClient) QueryContract(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*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) 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) SendMultiSigningRequest(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) SignArchivePayload(payload *common.Payload) (*common.Payload, 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) SignPayload(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, topic string, contractName string) (<-chan interface{}, error)

+ func (cc *ChainClient) SubscribeTx(ctx context.Context, startBlock, endBlock int64, contractName string, ...) (<-chan interface{}, error)

+ type ChainClientConfig struct

+ type ChainClientOption func(*ChainClientConfig)

+ func AddChainClientNodeConfig(nodeConfig *NodeConfig) ChainClientOption

+ func WithArchiveConfig(conf *ArchiveConfig) ChainClientOption

+ func WithChainClientChainId(chainId string) ChainClientOption

+ func WithChainClientLogger(logger utils.Logger) ChainClientOption

+ func WithChainClientOrgId(orgId string) ChainClientOption

+ func WithConfPath(confPath string) ChainClientOption

+ func WithRPCClientConfig(conf *RPCClientConfig) ChainClientOption

+ func WithUserCrtBytes(userCrtBytes []byte) ChainClientOption

+ func WithUserCrtFilePath(userCrtFilePath string) ChainClientOption

+ func WithUserKeyBytes(userKeyBytes []byte) ChainClientOption

+ func WithUserKeyFilePath(userKeyFilePath string) ChainClientOption

+ func WithUserSignCrtBytes(userSignCrtBytes []byte) ChainClientOption

+ func WithUserSignCrtFilePath(userSignCrtFilePath string) ChainClientOption

+ func WithUserSignKeyBytes(userSignKeyBytes []byte) ChainClientOption

+ func WithUserSignKeyFilePath(userSignKeyFilePath string) ChainClientOption

+ type ClientConnectionPool struct

+ func NewConnPool(config *ChainClientConfig) (*ClientConnectionPool, error)

+ func NewConnPoolWithOptions(opts ...ChainClientOption) (*ClientConnectionPool, error)

+ func (pool *ClientConnectionPool) Close() error

+ type ConnectionPool interface

+ Close func() error

+ type NodeConfig struct

+ func NewNodeConfig(opts ...NodeOption) *NodeConfig

+ type NodeOption func(config *NodeConfig)

+ func WithNodeAddr(addr string) NodeOption

+ func WithNodeCACerts(caCerts []string) NodeOption

+ func WithNodeCAPaths(caPaths []string) NodeOption

+ func WithNodeConnCnt(connCnt int) NodeOption

+ func WithNodeTLSHostName(tlsHostName string) NodeOption

+ func WithNodeUseTLS(useTLS bool) NodeOption

+ type RPCClientConfig struct

+ func NewRPCClientConfig(opts ...RPCClientOption) *RPCClientConfig

+ type RPCClientOption func(config *RPCClientConfig)

+ func WithRPCClientMaxReceiveMessageSize(size int) RPCClientOption

+ type SDKInterface interface

+ AddCert func() (*common.TxResponse, error)

+ CheckCallerCertAuth func(payload string, orgIds []string, signPairs []*syscontract.SignInfo) (*common.TxResponse, error)

+ CreateArchiveBlockPayload func(targetBlockHeight uint64) (*common.Payload, error)

+ CreateCertManageFrozenPayload func(certs []string) *common.Payload

+ CreateCertManagePayload func(method string, kvs []*common.KeyValuePair) *common.Payload

+ CreateCertManageRevocationPayload func(certCrl string) *common.Payload

+ CreateCertManageUnfrozenPayload func(certs []string) *common.Payload

+ CreateChainConfigBlockUpdatePayload func(txTimestampVerify bool, ...) (*common.Payload, error)

+ CreateChainConfigConsensusExtAddPayload func(kvs []*common.KeyValuePair) (*common.Payload, error)

+ CreateChainConfigConsensusExtDeletePayload func(keys []string) (*common.Payload, error)

+ CreateChainConfigConsensusExtUpdatePayload func(kvs []*common.KeyValuePair) (*common.Payload, error)

+ CreateChainConfigConsensusNodeIdAddPayload func(nodeOrgId string, nodeIds []string) (*common.Payload, error)

+ CreateChainConfigConsensusNodeIdDeletePayload func(nodeOrgId, nodeId string) (*common.Payload, error)

+ CreateChainConfigConsensusNodeIdUpdatePayload func(nodeOrgId, nodeOldNodeId, nodeNewNodeId string) (*common.Payload, error)

+ CreateChainConfigConsensusNodeOrgAddPayload func(nodeOrgId string, nodeIds []string) (*common.Payload, error)

+ CreateChainConfigConsensusNodeOrgDeletePayload func(nodeOrgId string) (*common.Payload, error)

+ CreateChainConfigConsensusNodeOrgUpdatePayload func(nodeOrgId string, nodeIds []string) (*common.Payload, error)

+ CreateChainConfigCoreUpdatePayload func(txSchedulerTimeout, txSchedulerValidateTimeout uint64) (*common.Payload, error)

+ CreateChainConfigPermissionAddPayload func(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error)

+ CreateChainConfigPermissionDeletePayload func(permissionResourceName string) (*common.Payload, error)

+ CreateChainConfigPermissionUpdatePayload func(permissionResourceName string, policy *accesscontrol.Policy) (*common.Payload, error)

+ CreateChainConfigTrustMemberAddPayload func(trustMemberOrgId, trustMemberNodeId, trustMemberRole, trustMemberInfo string) (*common.Payload, error)

+ CreateChainConfigTrustMemberDeletePayload func(trustMemberInfo string) (*common.Payload, error)

+ CreateChainConfigTrustRootAddPayload func(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)

+ CreateChainConfigTrustRootDeletePayload func(trustRootOrgId string) (*common.Payload, error)

+ CreateChainConfigTrustRootUpdatePayload func(trustRootOrgId string, trustRootCrt []string) (*common.Payload, error)

+ CreateContractCreatePayload func(contractName, version, byteCode string, runtime common.RuntimeType, ...) (*common.Payload, error)

+ CreateContractFreezePayload func(contractName string) (*common.Payload, error)

+ CreateContractRevokePayload func(contractName string) (*common.Payload, error)

+ CreateContractUnfreezePayload func(contractName string) (*common.Payload, error)

+ CreateContractUpgradePayload func(contractName, version, byteCode string, runtime common.RuntimeType, ...) (*common.Payload, error)

+ CreateHibeInitParamsTxPayloadParams func(orgId string, hibeParams []byte) ([]*common.KeyValuePair, error)

+ CreateHibeTxPayloadParamsWithHibeParams func(plaintext []byte, receiverIds []string, paramsBytesList [][]byte, txId string, ...) ([]*common.KeyValuePair, error)

+ CreateHibeTxPayloadParamsWithoutHibeParams func(contractName, queryParamsMethod string, plaintext []byte, receiverIds []string, ...) ([]*common.KeyValuePair, error)

+ CreateRestoreBlockPayload func(fullBlock []byte) (*common.Payload, error)

+ CreateSaveEnclaveCACertPayload func(caCert, txId string) (*common.Payload, error)

+ CreateSaveEnclaveReportPayload func(enclaveId, report, txId string) (*common.Payload, error)

+ DecryptHibeTxByTxId func(localId string, hibeParams []byte, hibePrvKey []byte, txId string, ...) ([]byte, error)

+ DeleteCert func(certHashes []string) (*common.TxResponse, error)

+ DisableCertHash func() error

+ EnableCertHash func() error

+ GetArchivedBlockByHash func(blockHash string, withRWSet bool) (*common.BlockInfo, error)

+ GetArchivedBlockByHeight func(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)

+ GetArchivedBlockByTxId func(txId string, withRWSet bool) (*common.BlockInfo, error)

+ GetArchivedBlockHeight func() (uint64, error)

+ GetArchivedFullBlockByHeight func(blockHeight uint64) (*store.BlockWithRWSet, error)

+ GetArchivedTxByTxId func(txId string) (*common.TransactionInfo, error)

+ GetBlockByHash func(blockHash string, withRWSet bool) (*common.BlockInfo, error)

+ GetBlockByHeight func(blockHeight uint64, withRWSet bool) (*common.BlockInfo, error)

+ GetBlockByTxId func(txId string, withRWSet bool) (*common.BlockInfo, error)

+ GetBlockHeaderByHeight func(blockHeight uint64) (*common.BlockHeader, error)

+ GetBlockHeightByHash func(blockHash string) (uint64, error)

+ GetBlockHeightByTxId func(txId string) (uint64, error)

+ GetCertHash func() ([]byte, error)

+ GetChainConfig func() (*config.ChainConfig, error)

+ GetChainConfigByBlockHeight func(blockHeight uint64) (*config.ChainConfig, error)

+ GetChainConfigSequence func() (uint64, error)

+ GetChainInfo func() (*discovery.ChainInfo, error)

+ GetChainMakerServerVersion func() (string, error)

+ GetContract func(contractName, codeHash string) (*common.PrivateGetContract, error)

+ GetCurrentBlockHeight func() (uint64, error)

+ GetData func(contractName, key string) ([]byte, error)

+ GetDir func(orderId string) ([]byte, error)

+ GetEnclaveCACert func() ([]byte, error)

+ GetEnclaveChallenge func(enclaveId string) ([]byte, error)

+ GetEnclaveEncryptPubKey func(enclaveId string) ([]byte, error)

+ GetEnclaveProof func(enclaveId string) ([]byte, error)

+ GetEnclaveReport func(enclaveId string) ([]byte, error)

+ GetEnclaveSignature func(enclaveId string) ([]byte, error)

+ GetEnclaveVerificationPubKey func(enclaveId string) ([]byte, error)

+ GetFullBlockByHeight func(blockHeight uint64) (*store.BlockWithRWSet, error)

+ GetLastBlock func(withRWSet bool) (*common.BlockInfo, error)

+ GetLastConfigBlock func(withRWSet bool) (*common.BlockInfo, error)

+ GetNodeChainList func() (*discovery.ChainList, error)

+ GetTxByTxId func(txId string) (*common.TransactionInfo, error)

+ GetTxRequest func(contractName, method, txId string, kvs []*common.KeyValuePair) (*common.TxRequest, error)

+ InvokeContract func(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)

+ InvokeSystemContract func(contractName, method, txId string, kvs []*common.KeyValuePair, timeout int64, ...) (*common.TxResponse, error)

+ QueryCert func(certHashes []string) (*common.CertInfos, error)

+ QueryContract func(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error)

+ QueryHibeParamsWithOrgId func(contractName, method, orgId string, timeout int64) ([]byte, error)

+ QuerySystemContract func(contractName, method string, kvs []*common.KeyValuePair, timeout int64) (*common.TxResponse, error)

+ SaveData func(contractName string, contractVersion string, isDeployment bool, ...) (*common.TxResponse, error)

+ SaveDir func(orderId, txId string, privateDir *common.StrSlice, withSyncResult bool, ...) (*common.TxResponse, error)

+ SaveRemoteAttestationProof func(proof, txId string, withSyncResult bool, timeout int64) (*common.TxResponse, error)

+ SendArchiveBlockRequest func(payload *common.Payload, timeout int64) (*common.TxResponse, error)

+ SendCertManageRequest func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ SendChainConfigUpdateRequest func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ SendContractManageRequest func(payload *common.Payload, endorsers []*common.EndorsementEntry, timeout int64, ...) (*common.TxResponse, error)

+ SendRestoreBlockRequest func(payload *common.Payload, timeout int64) (*common.TxResponse, error)

+ SendTxRequest func(txRequest *common.TxRequest, timeout int64, withSyncResult bool) (*common.TxResponse, error)

+ SignArchivePayload func(payload *common.Payload) (*common.Payload, error)

+ SignCertManagePayload func(payload *common.Payload) (*common.EndorsementEntry, error)

+ SignChainConfigPayload func(payload *common.Payload) (*common.EndorsementEntry, error)

+ SignContractManagePayload func(payload *common.Payload) (*common.EndorsementEntry, error)

+ Stop func() error

+ Subscribe func(ctx context.Context, payloadBytes *common.Payload) (<-chan interface{}, error)

+ SubscribeBlock func(ctx context.Context, startBlock, endBlock int64, withRWSet, onlyHeader bool) (<-chan interface{}, error)

+ SubscribeContractEvent func(ctx context.Context, topic string, contractName string) (<-chan interface{}, error)

+ SubscribeTx func(ctx context.Context, startBlock, endBlock int64, contractName string, ...) (<-chan interface{}, error)

Other modules containing this package

chainmaker.org/chainmaker/sdk-go/v3

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL