protocol

package module

Go to main page

Versions in this module

v3

v3.0.1

Dec 25, 2023

Changes in this version

+ const SYNC_txHash_set_key

+ var RunTimeTypeToVmType = map[common.RuntimeType]string

+ var VmTypeToRunTimeType = map[string]common.RuntimeType

+ func VerifyVmType(vmType string) bool

type AccessControlProvider

+ RefineEndorsements func(endorsements []*common.EndorsementEntry, msg []byte) []*common.EndorsementEntry

type BlockchainStore

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

+ GetHotColdDataSeparationMaxHeight func() (uint64, error)

+ GetLastHeight func() (uint64, error)

type ConsensusEngine

+ Close func() error

type ConsensusStateWrapper

+ IsValid func() bool

type TxSimContext

+ GetGasRemaining func() uint64

+ SubtractGas func(gasUsed uint64) error

type VerifyMode

+ const PROPOSER_VERIFY

+ const SYNC_FILTER_VERIFY

type VmManager

+ OnMessage func(*msgbus.Message)

+ OnQuit func()

+ type WacsiWithGas interface

+ BulletProofsOperation func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) ([]byte, error)

+ CallContract func(caller *common.Contract, requestBody []byte, txSimContext TxSimContext, ...) (*common.ContractResult, uint64, ExecOrderTxType, error)

+ DeleteState func(requestBody []byte, contractName string, txSimContext TxSimContext) error

+ EmitEvent func(requestBody []byte, txSimContext TxSimContext, contractId *common.Contract, ...) (*common.ContractEvent, error)

+ ErrorResult func(contractResult *common.ContractResult, txSimContext TxSimContext, data []byte) int32

+ ExecuteDDL func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ ExecuteQuery func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ ExecuteQueryOne func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) ([]byte, error)

+ ExecuteUpdate func(requestBody []byte, contractName string, method string, ...) error

+ GetState func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) ([]byte, error)

+ KvIterator func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ KvIteratorClose func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ KvIteratorHasNext func(requestBody []byte, txSimContext TxSimContext, memory []byte) error

+ KvIteratorNext func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) ([]byte, error)

+ KvPreIterator func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ LogMessage func(requestBody []byte, txSimContext TxSimContext) int32

+ PaillierOperation func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) ([]byte, error)

+ PutState func(requestBody []byte, contractName string, txSimContext TxSimContext) error

+ RSClose func(requestBody []byte, txSimContext TxSimContext, memory []byte) error

+ RSHasNext func(requestBody []byte, txSimContext TxSimContext, memory []byte) error

+ RSNext func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) ([]byte, error)

+ SuccessResult func(contractResult *common.ContractResult, txSimContext TxSimContext, data []byte) int32

v3.0.0

Dec 23, 2022

Changes in this version

+ const BulletProofsOpTypePedersenAddCommitment

+ const BulletProofsOpTypePedersenAddNum

+ const BulletProofsOpTypePedersenMulNum

+ const BulletProofsOpTypePedersenSubCommitment

+ const BulletProofsOpTypePedersenSubNum

+ const BulletProofsVerify

+ const CallContractDepth

+ const CallContractGasOnce

+ const CertFreezeKey

+ const CertFreezeKeyPrefix

+ const CertRevokeKey

+ const CertRevokeKeyPrefix

+ const ConfigNameOrgId

+ const ConfigNameRoot

+ const ContractAddrTypeParam

+ const ContractAllocateMethod

+ const ContractBlockHeightParam

+ const ContractContextPtrParam

+ const ContractCreatorOrgIdParam

+ const ContractCreatorPkParam

+ const ContractCreatorRoleParam

+ const ContractCreatorTypeParam

+ const ContractCrossCallerParam

+ const ContractDeallocateMethod

+ const ContractEvmParamKey

+ const ContractInitMethod

+ const ContractMethodCallContract

+ const ContractMethodCallContractLen

+ const ContractMethodDeleteState

+ const ContractMethodEmitEvent

+ const ContractMethodErrorResult

+ const ContractMethodExecuteDdl

+ const ContractMethodExecuteQuery

+ const ContractMethodExecuteQueryOne

+ const ContractMethodExecuteQueryOneLen

+ const ContractMethodExecuteUpdate

+ const ContractMethodGetBulletproofsResult

+ const ContractMethodGetBulletproofsResultLen

+ const ContractMethodGetPaillierOperationResult

+ const ContractMethodGetPaillierOperationResultLen

+ const ContractMethodGetState

+ const ContractMethodGetStateLen

+ const ContractMethodKvIterator

+ const ContractMethodKvIteratorClose

+ const ContractMethodKvIteratorHasNext

+ const ContractMethodKvIteratorNext

+ const ContractMethodKvIteratorNextLen

+ const ContractMethodKvPreIterator

+ const ContractMethodLogMessage

+ const ContractMethodPutState

+ const ContractMethodRSClose

+ const ContractMethodRSHasNext

+ const ContractMethodRSNext

+ const ContractMethodRSNextLen

+ const ContractMethodSuccessResult

+ const ContractRuntimeTypeMethod

+ const ContractSdkSignalResultFail

+ const ContractSdkSignalResultSuccess

+ const ContractSenderOrgIdParam

+ const ContractSenderPkParam

+ const ContractSenderRoleParam

+ const ContractSenderTypeParam

+ const ContractStoreSeparator

+ const ContractTxIdParam

+ const ContractTxTimeStamp

+ const ContractUpgradeMethod

+ const DefaultBlockVersion

+ const DefaultMaxStateKeyLen

+ const DefaultParametersValueMaxSize

+ const DefaultStateRegex

+ const DefaultVersionLen

+ const DefaultVersionRegex

+ const EventDataMaxCount

+ const EventDataMaxLen

+ const EvmGasPrice

+ const EvmMaxStackDepth

+ const GasLimit

+ const Identity

+ const PaillierOpTypeAddCiphertext

+ const PaillierOpTypeAddPlaintext

+ const PaillierOpTypeNumMul

+ const PaillierOpTypeSubCiphertext

+ const PaillierOpTypeSubPlaintext

+ const ParametersKeyMaxCount

+ const PermissionedWithCert

+ const PermissionedWithKey

+ const Public

+ const ResourceNameAdmin

+ const ResourceNameAllTest

+ const ResourceNameArchive

+ const ResourceNameConsensusNode

+ const ResourceNameP2p

+ const ResourceNamePrivateCompute

+ const ResourceNameReadData

+ const ResourceNameSubscribe

+ const ResourceNameTxQuery

+ const ResourceNameTxTransact

+ const ResourceNameUnknown

+ const ResourceNameUpdateConfig

+ const ResourceNameUpdateSelfConfig

+ const ResourceNameWriteData

+ const RoleAdmin

+ const RoleClient

+ const RoleCommonNode

+ const RoleConsensusNode

+ const RoleContract

+ const RoleLight

+ const RuleAll

+ const RuleAny

+ const RuleDelete

+ const RuleForbidden

+ const RuleMajority

+ const RuleSelf

+ const TBFT_blocks_per_proposer

+ const TBFT_propose_delta_timeout_key

+ const TBFT_propose_timeout_key

+ const TimeLimit

+ const TopicMaxLen

+ var ConsensusDBName = "consensus"

+ var ParametersValueMaxLength uint32

+ func CheckEventData(eventData []string) error

+ func CheckKeyFieldStr(key string, field string) error

+ func CheckTopicStr(topic string) error

+ func GetKey(key []byte, field []byte) []byte

+ func GetKeyStr(key string, field string) []byte

+ type AccessControlProvider interface

+ CreatePrincipal func(resourceName string, endorsements []*common.EndorsementEntry, message []byte) (Principal, error)

+ CreatePrincipalForTargetOrg func(resourceName string, endorsements []*common.EndorsementEntry, message []byte, ...) (Principal, error)

+ GetAllPolicy func() (map[string]*pbac.Policy, error)

+ GetHashAlg func() string

+ GetMemberStatus func(member *pbac.Member) (pbac.MemberStatus, error)

+ GetValidEndorsements func(principal Principal) ([]*common.EndorsementEntry, error)

+ LookUpExceptionalPolicy func(resourceName string) (*pbac.Policy, error)

+ LookUpPolicy func(resourceName string) (*pbac.Policy, error)

+ NewMember func(member *pbac.Member) (Member, error)

+ ValidateResourcePolicy func(resourcePolicy *config.ResourcePolicy) bool

+ VerifyPrincipal func(principal Principal) (bool, error)

+ type AuthType uint32

+ type BlockCommitter interface

+ AddBlock func(blk *common.Block) error

+ type BlockProposer interface

+ OnReceiveMaxBFTProposal func(proposal *maxbft.BuildProposal)

+ OnReceiveProposeStatusChange func(proposeStatus bool)

+ OnReceiveRwSetVerifyFailTxs func(rwSetVerifyFailTxs *consensuspb.RwSetVerifyFailTxs)

+ OnReceiveTxPoolSignal func(proposeSignal *txpool.TxPoolSignal)

+ ProposeBlock func(proposal *maxbft.BuildProposal) (*consensuspb.ProposalBlock, error)

+ Start func() error

+ Stop func() error

+ type BlockVerifier interface

+ VerifyBlock func(block *common.Block, mode VerifyMode) error

+ VerifyBlockSync func(block *common.Block, mode VerifyMode) (*consensuspb.VerifyResult, error)

+ VerifyBlockWithRwSets func(block *common.Block, rwsets []*common.TxRWSet, mode VerifyMode) error

+ type BlockchainStore interface

+ ArchiveBlock func(archiveHeight uint64) error

+ BlockExists func(blockHash []byte) (bool, error)

+ Close func() error

+ DoHotColdDataSeparation func(startHeight uint64, endHeight uint64) (string, error)

+ GetAccountTxHistory func(accountId []byte) (TxHistoryIterator, error)

+ GetArchivedPivot func() uint64

+ GetBlock func(height uint64) (*common.Block, error)

+ GetBlockByHash func(blockHash []byte) (*common.Block, error)

+ GetBlockByTx func(txId string) (*common.Block, error)

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

+ GetBlockWithRWSets func(height uint64) (*store.BlockWithRWSet, error)

+ GetContractTxHistory func(contractName string) (TxHistoryIterator, error)

+ GetDBHandle func(dbName string) DBHandle

+ GetHeightByHash func(blockHash []byte) (uint64, error)

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

+ GetHotColdDataSeparationJobByID func(jobID string) (store.ArchiveJob, error)

+ GetLastBlock func() (*common.Block, error)

+ GetLastChainConfig func() (*configPb.ChainConfig, error)

+ GetLastConfigBlock func() (*common.Block, error)

+ GetSnapshotStatus func() uint64

+ GetTx func(txId string) (*common.Transaction, error)

+ GetTxConfirmedTime func(txId string) (int64, error)

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

+ GetTxInfoOnly func(txId string) (*commonPb.TransactionInfo, error)

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

+ GetTxRWSet func(txId string) (*common.TxRWSet, error)

+ GetTxRWSetsByHeight func(height uint64) ([]*common.TxRWSet, error)

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

+ GetTxWithRWSet func(txId string) (*common.TransactionWithRWSet, error)

+ InitGenesis func(genesisBlock *store.BlockWithRWSet) error

+ MakeSnapshot func(snapshotHeight uint64) error

+ PutBlock func(block *common.Block, txRWSets []*common.TxRWSet) error

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

+ ReadObjects func(contractName string, keys [][]byte) ([][]byte, error)

+ RestoreBlocks func(serializedBlocks [][]byte) error

+ SelectObject func(contractName string, startKey []byte, limit []byte) (StateIterator, error)

+ TxExists func(txId string) (bool, error)

+ TxExistsInFullDB func(txId string) (bool, uint64, error)

+ TxExistsInIncrementDB func(txId string, startHeight uint64) (bool, error)

+ TxExistsInIncrementDBState func(txId string, startHeight uint64) (bool, bool, error)

+ type ChainConf interface

+ AddVmWatch func(w VmWatcher)

+ AddWatch func(w Watcher)

+ ChainConfig func() *config.ChainConfig

+ CompleteBlock func(block *common.Block) error

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

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

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

+ Init func() error

+ SetChainConfig func(chainConf *config.ChainConfig) error

+ type ChainNodeInfo struct

+ NodeAddress []string

+ NodeTlsCert []byte

+ NodeUid string

+ type ChainNodesInfoProvider interface

+ GetChainNodesInfo func() ([]*ChainNodeInfo, error)

+ type ConsensusEngine interface

+ Start func() error

+ Stop func() error

+ type ConsensusExtendEngine interface

+ InitExtendHandler func(handler ConsensusExtendHandler)

+ type ConsensusExtendHandler interface

+ CreateRWSet func(preBlkHash []byte, proposedBlock *consensuspb.ProposalBlock) error

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

+ VerifyConsensusArgs func(block *common.Block, blockTxRwSet map[string]*common.TxRWSet) error

+ type ConsensusNodeInfo struct

+ NodeID string

+ State ConsensusNodeState

+ type ConsensusNodeState int

+ const ACTIVE

+ const INACTIVE

+ const UNKNOWN

+ type ConsensusState interface

+ GetAllNodeInfos func() []ConsensusNodeInfo

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

+ GetConsensusType func() consensuspb.ConsensusType

+ GetLastHeight func() uint64

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

+ type ConsensusStateWrapper interface

+ GetAllNodeInfos func() []ConsensusNodeInfo

+ IsVaild func() bool

+ Wrap func(ConsensusState)

+ type ContractWacsiCommon interface

+ CallContract func() int32

+ ErrorResult func() int32

+ LogMessage func() int32

+ SuccessResult func() int32

+ type ContractWacsiKV interface

+ DeleteState func() int32

+ GetState func() int32

+ KvIterator func() int32

+ KvIteratorClose func() int32

+ KvIteratorHasNext func() int32

+ KvIteratorNext func() int32

+ KvPreIterator func() int32

+ PutState func() int32

+ type ContractWacsiSQL interface

+ ExecuteDDL func() int32

+ ExecuteQuery func() int32

+ ExecuteQueryOne func() int32

+ ExecuteUpdate func() int32

+ RSClose func() int32

+ RSHasNext func() int32

+ RSNext func() int32

+ type CoreEngine interface

+ GetBlockCommitter func() BlockCommitter

+ GetBlockProposer func() BlockProposer

+ GetBlockVerifier func() BlockVerifier

+ GetMaxbftHelper func() MaxbftHelper

+ Start func()

+ Stop func()

+ type DBHandle interface

+ Close func() error

+ CompactRange func(start, limit []byte) error

+ Delete func(key []byte) error

+ Get func(key []byte) ([]byte, error)

+ GetDbType func() string

+ GetKeys func(keys [][]byte) ([][]byte, error)

+ GetWriteBatchSize func() uint64

+ Has func(key []byte) (bool, error)

+ NewIteratorWithPrefix func(prefix []byte) (Iterator, error)

+ NewIteratorWithRange func(start []byte, limit []byte) (Iterator, error)

+ Put func(key []byte, value []byte) error

+ WriteBatch func(batch StoreBatcher, sync bool) error

+ type DPoS interface

+ CreateDPoSRWSet func(preBlkHash []byte, proposedBlock *consensuspb.ProposalBlock) error

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

+ VerifyConsensusArgs func(block *common.Block, blockTxRwSet map[string]*common.TxRWSet) error

+ type DirectMsgHandler func(from string, msgData []byte) error

+ type ExecOrderTxType int

+ const ExecOrderTxTypeChargeGas

+ const ExecOrderTxTypeCoinbase

+ const ExecOrderTxTypeIterator

+ const ExecOrderTxTypeNormal

+ type Government interface

+ GetGovernanceContract func() (*consensuspb.GovernanceContract, error)

+ Verify func(consensusType consensuspb.ConsensusType, chainConfig *config.ChainConfig) error

+ type ImportLedgerSnapshot interface

+ ImportSnapshot func(chainID string, snapshotPath string, height uint64) error

+ type Iterator interface

+ Error func() error

+ First func() bool

+ Key func() []byte

+ Next func() bool

+ Release func()

+ Value func() []byte

+ type KeyHistoryIterator interface

+ Next func() bool

+ Release func()

+ Value func() (*store.KeyModification, error)

+ type LedgerCache interface

+ CurrentHeight func() (uint64, error)

+ GetLastCommittedBlock func() *common.Block

+ SetLastCommittedBlock func(b *common.Block)

+ type Logger interface

+ Debug func(args ...interface{})

+ DebugDynamic func(getStr func() string)

+ Debugf func(format string, args ...interface{})

+ Debugw func(msg string, keysAndValues ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Errorw func(msg string, keysAndValues ...interface{})

+ Fatal func(args ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Fatalw func(msg string, keysAndValues ...interface{})

+ Info func(args ...interface{})

+ InfoDynamic func(getStr func() string)

+ Infof func(format string, args ...interface{})

+ Infow func(msg string, keysAndValues ...interface{})

+ Panic func(args ...interface{})

+ Panicf func(format string, args ...interface{})

+ Panicw func(msg string, keysAndValues ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ Warnw func(msg string, keysAndValues ...interface{})

+ type MaxbftHelper interface

+ DiscardBlocks func(baseHeight uint64)

+ type Member interface

+ GetMember func() (*pbac.Member, error)

+ GetMemberId func() string

+ GetOrgId func() string

+ GetPk func() crypto.PublicKey

+ GetRole func() Role

+ GetUid func() string

+ Verify func(hashType string, msg []byte, sig []byte) error

+ type MemberQuery interface

+ GetMemberExtraData func(member *accesscontrol.Member) (*accesscontrol.MemberExtraData, error)

+ type MsgHandler func(from string, msg []byte, msgType net.NetMsg_MsgType) error

+ type Net interface

+ AddAC func(chainId string, ac AccessControlProvider)

+ AddSeed func(seed string) error

+ BroadcastWithChainId func(chainId string, topic string, netMsg []byte) error

+ CancelDirectMsgHandle func(chainId string, msgFlag string) error

+ CancelSubscribeWithChainId func(chainId string, topic string) error

+ ChainNodesInfo func(chainId string) ([]*ChainNodeInfo, error)

+ DirectMsgHandle func(chainId string, msgFlag string, handler DirectMsgHandler) error

+ GetNodeUid func() string

+ GetNodeUidByCertId func(certId string) (string, error)

+ InitPubSub func(chainId string, maxMessageSize int) error

+ IsRunning func() bool

+ ReVerifyPeers func(chainId string)

+ RefreshSeeds func(seeds []string) error

+ SendMsg func(chainId string, node string, msgFlag string, netMsg []byte) error

+ SetChainCustomTrustRoots func(chainId string, roots [][]byte)

+ SetMsgPriority func(msgFlag string, priority uint8)

+ Start func() error

+ Stop func() error

+ SubscribeWithChainId func(chainId string, topic string, handler PubSubMsgHandler) error

+ type NetService interface

+ BroadcastMsg func(msg []byte, msgType net.NetMsg_MsgType) error

+ CancelConsensusSubscribe func(msgType net.NetMsg_MsgType) error

+ CancelSubscribe func(msgType net.NetMsg_MsgType) error

+ ConsensusBroadcastMsg func(msg []byte, msgType net.NetMsg_MsgType) error

+ ConsensusSubscribe func(msgType net.NetMsg_MsgType, handler MsgHandler) error

+ GetChainNodesInfoProvider func() ChainNodesInfoProvider

+ GetNodeUidByCertId func(certId string) (string, error)

+ ReceiveMsg func(msgType net.NetMsg_MsgType, handler MsgHandler) error

+ SendMsg func(msg []byte, msgType net.NetMsg_MsgType, to ...string) error

+ Start func() error

+ Stop func() error

+ Subscribe func(msgType net.NetMsg_MsgType, handler MsgHandler) error

+ type NetType int

+ const Libp2p

+ const Liquid

+ type Principal interface

+ GetEndorsement func() []*common.EndorsementEntry

+ GetMessage func() []byte

+ GetResourceName func() string

+ GetTargetOrgId func() string

+ type ProposalCache interface

+ ClearProposedBlockAt func(height uint64)

+ ClearTheBlock func(block *common.Block)

+ DiscardBlocks func(baseHeight uint64) []*common.Block

+ GetProposedBlock func(b *common.Block) (*common.Block, map[string]*common.TxRWSet, map[string][]*common.ContractEvent)

+ GetProposedBlockByHashAndHeight func(hash []byte, height uint64) (*common.Block, map[string]*common.TxRWSet)

+ GetProposedBlocksAt func(height uint64) []*common.Block

+ GetSelfProposedBlockAt func(height uint64) *common.Block

+ HasProposedBlockAt func(height uint64) bool

+ IsProposedAt func(height uint64) bool

+ KeepProposedBlock func(hash []byte, height uint64) []*common.Block

+ ResetProposedAt func(height uint64)

+ SetProposedAt func(height uint64)

+ SetProposedBlock func(b *common.Block, rwSetMap map[string]*common.TxRWSet, ...) error

+ type PubSubMsgHandler func(publisher string, msgData []byte) error

+ type RemoveRES int

+ const DOUBLE_SPEND

+ const EVIL

+ const NORMAL

+ const OTHER

+ const TIMEOUT

+ type Role string

+ type Rule string

+ type RuntimeInstance interface

+ Invoke func(contractId *common.Contract, method string, byteCode []byte, ...) (*common.ContractResult, ExecOrderTxType)

+ type SigningMember interface

+ Sign func(hashType string, msg []byte) ([]byte, error)

+ type Snapshot interface

+ ApplyBlock func(block *common.Block, txRWSetMap map[string]*common.TxRWSet)

+ ApplyTxSimContext func(TxSimContext, ExecOrderTxType, bool, bool) (bool, int)

+ BuildDAG func(isSql bool, txRWSetTable []*common.TxRWSet) *common.DAG

+ GetBlockFingerprint func() string

+ GetBlockHeight func() uint64

+ GetBlockProposer func() *accesscontrol.Member

+ GetBlockTimestamp func() int64

+ GetBlockchainStore func() BlockchainStore

+ GetKey func(txExecSeq int, contractName string, key []byte) ([]byte, error)

+ GetKeys func(txExecSeq int, keys []*vmPb.BatchKey) ([]*vmPb.BatchKey, error)

+ GetLastChainConfig func() *config.ChainConfig

+ GetPreSnapshot func() Snapshot

+ GetSnapshotSize func() int

+ GetSpecialTxTable func() []*common.Transaction

+ GetTxRWSetTable func() []*common.TxRWSet

+ GetTxResultMap func() map[string]*common.Result

+ GetTxTable func() []*common.Transaction

+ IsSealed func() bool

+ Seal func()

+ SetPreSnapshot func(Snapshot)

+ type SnapshotManager interface

+ ClearSnapshot func(block *common.Block) error

+ GetSnapshot func(prevBlock *common.Block, block *common.Block) Snapshot

+ NewSnapshot func(prevBlock *common.Block, block *common.Block) Snapshot

+ NotifyBlockCommitted func(block *common.Block) error

+ type Spv interface

+ Start func() error

+ Stop func()

+ type SqlDBHandle interface

+ BeginDbTransaction func(txName string) (SqlDBTransaction, error)

+ CommitDbTransaction func(txName string) error

+ CreateDatabaseIfNotExist func(dbName string) (bool, error)

+ CreateTableIfNotExist func(obj interface{}) error

+ Dump func(dumpDir string, fileNamePre string) (string, error)

+ ExecSql func(sql string, values ...interface{}) (int64, error)

+ GetDbTransaction func(txName string) (SqlDBTransaction, error)

+ GetSqlDbType func() string

+ QueryMulti func(sql string, values ...interface{}) (SqlRows, error)

+ QuerySingle func(sql string, values ...interface{}) (SqlRow, error)

+ RollbackDbTransaction func(txName string) error

+ Save func(value interface{}) (int64, error)

+ type SqlDBTransaction interface

+ BeginDbSavePoint func(savePointName string) error

+ ChangeContextDb func(dbName string) error

+ ExecSql func(sql string, values ...interface{}) (int64, error)

+ QueryMulti func(sql string, values ...interface{}) (SqlRows, error)

+ QuerySingle func(sql string, values ...interface{}) (SqlRow, error)

+ RollbackDbSavePoint func(savePointName string) error

+ Save func(value interface{}) (int64, error)

+ SaveBatch func(values []interface{}) (int64, error)

+ type SqlRow interface

+ Data func() (map[string][]byte, error)

+ IsEmpty func() bool

+ ScanColumns func(dest ...interface{}) error

+ type SqlRows interface

+ Close func() error

+ Data func() (map[string][]byte, error)

+ Next func() bool

+ ScanColumns func(dest ...interface{}) error

+ type SqlType int8

+ const SqlTypeDdl

+ const SqlTypeDml

+ const SqlTypeDql

+ type SqlVerifier interface

+ VerifyDDLSql func(sql string) error

+ VerifyDMLSql func(sql string) error

+ VerifyDQLSql func(sql string) error

+ type StateIterator interface

+ Next func() bool

+ Release func()

+ Value func() (*store.KV, error)

+ type StateSqlOperation interface

+ BeginDbTransaction func(txName string) (SqlDBTransaction, error)

+ CommitDbTransaction func(txName string) error

+ CreateDatabase func(contractName string) error

+ DropDatabase func(contractName string) error

+ ExecDdlSql func(contractName, sql, version string) error

+ GetContractDbName func(contractName string) string

+ GetDbTransaction func(txName string) (SqlDBTransaction, error)

+ QueryMulti func(contractName, sql string, values ...interface{}) (SqlRows, error)

+ QuerySingle func(contractName, sql string, values ...interface{}) (SqlRow, error)

+ RollbackDbTransaction func(txName string) error

+ type StoreBatcher interface

+ Delete func(key []byte)

+ Get func(key []byte) ([]byte, error)

+ Has func(key []byte) bool

+ KVs func() map[string][]byte

+ Len func() int

+ Merge func(batcher StoreBatcher)

+ Put func(key []byte, value []byte)

+ Remove func(key []byte)

+ SplitBatch func(batchCnt uint64) []StoreBatcher

+ type StoreHelper interface

+ BeginDbTransaction func(BlockchainStore, string)

+ GetPoolCapacity func() int

+ RollBack func(*common.Block, BlockchainStore) error

+ type SyncService interface

+ ListenSyncToIdealHeight func() <-chan struct{}

+ Start func() error

+ StartBlockSync func()

+ Stop func()

+ StopBlockSync func()

+ type SysContractQuery interface

+ GetContractByName func(name string) (*commonPb.Contract, error)

+ GetContractBytecode func(name string) ([]byte, error)

+ type TxFilter interface

+ Add func(txId string) error

+ Adds func(txIds []string) error

+ AddsAndSetHeight func(txId []string, height uint64) (result error)

+ Close func()

+ GetHeight func() uint64

+ IsExists func(txId string, ruleType ...common.RuleType) (bool, *txfilter.Stat, error)

+ IsExistsAndReturnHeight func(txId string, ruleType ...common.RuleType) (bool, uint64, *txfilter.Stat, error)

+ SetHeight func(height uint64)

+ ValidateRule func(txId string, ruleType ...common.RuleType) error

+ type TxHistoryIterator interface

+ Next func() bool

+ Release func()

+ Value func() (*store.TxHistory, error)

+ type TxPool interface

+ AddTx func(tx *common.Transaction, source TxSource) error

+ AddTxBatchesToPendingCache func(batchIds []string, blockHeight uint64)

+ AddTxsToPendingCache func(txs []*common.Transaction, blockHeight uint64)

+ FetchTxBatches func(blockHeight uint64) (batchIds []string, txsTable [][]*common.Transaction)

+ FetchTxs func(blockHeight uint64) (txs []*common.Transaction)

+ GetAllTxsByBatchIds func(batchIds []string, proposerId string, height uint64, timeoutMs int) (txsTable [][]*common.Transaction, err error)

+ GetAllTxsByTxIds func(txIds []string, proposerId string, height uint64, timeoutMs int) (txsRet map[string]*common.Transaction, err error)

+ GetPoolStatus func() (txPoolStatus *txpool.TxPoolStatus)

+ GetTxIdsByTypeAndStage func(txType, txStage int32) (txIds []string)

+ GetTxStatus func(txId string) (txWithStatus txpool.TxStatus)

+ GetTxsByTxIds func(txIds []string) (txsRet map[string]*common.Transaction, txsMis map[string]struct{})

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

+ ReGenTxBatchesWithRemoveTxs func(blockHeight uint64, batchIds []string, removeTxs []*common.Transaction, ...) (newBatchIds []string, newTxsTable [][]*common.Transaction)

+ ReGenTxBatchesWithRetryTxs func(blockHeight uint64, batchIds []string, retryTxs []*common.Transaction) (newBatchIds []string, newTxsTable [][]*common.Transaction)

+ RemoveTxBatches func(removeBatchIds []string, removeRES RemoveRES)

+ RemoveTxs func(removeTxs []*common.Transaction, removeRES RemoveRES)

+ RemoveTxsInTxBatches func(batchIds []string, removeTxs []*common.Transaction, removeRES RemoveRES)

+ RetryTxBatches func(retryBatchIds []string)

+ RetryTxs func(retryTxs []*common.Transaction)

+ Start func() error

+ Stop func() error

+ TxExists func(tx *common.Transaction) bool

+ type TxScheduler interface

+ Halt func()

+ Schedule func(block *common.Block, txBatch []*common.Transaction, snapshot Snapshot) (map[string]*common.TxRWSet, map[string][]*common.ContractEvent, error)

+ SimulateWithDag func(block *common.Block, snapshot Snapshot) (map[string]*common.TxRWSet, map[string]*common.Result, error)

+ type TxSimContext interface

+ CallContract func(caller, contract *common.Contract, method string, byteCode []byte, ...) (*common.ContractResult, ExecOrderTxType, common.TxStatusCode)

+ Del func(name string, key []byte) error

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

+ GetAccessControl func() (AccessControlProvider, error)

+ GetBlockFingerprint func() string

+ GetBlockHeight func() uint64

+ GetBlockProposer func() *pbac.Member

+ GetBlockTimestamp func() int64

+ GetBlockVersion func() uint32

+ GetBlockchainStore func() BlockchainStore

+ GetChainNodesInfoProvider func() (ChainNodesInfoProvider, error)

+ GetConsensusStateWrapper func() ConsensusStateWrapper

+ GetContractByName func(name string) (*common.Contract, error)

+ GetContractBytecode func(name string) ([]byte, error)

+ GetCreator func(namespace string) *pbac.Member

+ GetCrossInfo func() uint64

+ GetCurrentResult func() []byte

+ GetDepth func() int

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

+ GetIterHandle func(index int32) (interface{}, bool)

+ GetKeys func(keys []*vmPb.BatchKey) ([]*vmPb.BatchKey, error)

+ GetLastChainConfig func() *config.ChainConfig

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

+ GetSender func() *pbac.Member

+ GetSnapshot func() Snapshot

+ GetStrAddrFromPbMember func(pbMember *pbac.Member) (string, error)

+ GetTx func() *common.Transaction

+ GetTxExecSeq func() int

+ GetTxRWMapByContractName func(contractName string) (map[string]*common.TxRead, map[string]*common.TxWrite)

+ GetTxRWSet func(runVmSuccess bool) *common.TxRWSet

+ GetTxResult func() *common.Result

+ HasUsed func(runtimeType common.RuntimeType) bool

+ Put func(name string, key []byte, value []byte) error

+ PutIntoReadSet func(contractName string, key []byte, value []byte)

+ PutRecord func(contractName string, value []byte, sqlType SqlType)

+ RecordRuntimeTypeIntoCrossInfo func(runtimeType common.RuntimeType)

+ RemoveRuntimeTypeFromCrossInfo func()

+ Select func(name string, startKey []byte, limit []byte) (StateIterator, error)

+ SetIterHandle func(index int32, iter interface{})

+ SetTxExecSeq func(int)

+ SetTxResult func(*common.Result)

+ type TxSource int

+ const INTERNAL

+ const P2P

+ const RPC

+ type Verifier interface

+ Verify func(consensusType consensus.ConsensusType, chainConfig *config.ChainConfig) error

+ type VerifyMode int

+ const CONSENSUS_VERIFY

+ const SYNC_VERIFY

+ func (i VerifyMode) String() string

+ type VmInstancesManager interface

+ AfterSchedule func(blockFingerprint string, blockHeight uint64)

+ BeforeSchedule func(blockFingerprint string, blockHeight uint64)

+ NewRuntimeInstance func(txSimContext TxSimContext, chainId, method, codePath string, ...) (RuntimeInstance, error)

+ StartVM func() error

+ StopVM func() error

+ type VmManager interface

+ AfterSchedule func(blockFingerprint string, blockHeight uint64)

+ BeforeSchedule func(blockFingerprint string, blockHeight uint64)

+ GetAccessControl func() AccessControlProvider

+ GetChainNodesInfoProvider func() ChainNodesInfoProvider

+ GetConsensusStateWrapper func() ConsensusStateWrapper

+ RunContract func(contract *common.Contract, method string, byteCode []byte, ...) (*common.ContractResult, ExecOrderTxType, common.TxStatusCode)

+ Start func() error

+ Stop func() error

+ type VmWatcher interface

+ Callback func(contractName string, payloadBytes []byte) error

+ ContractNames func() []string

+ Module func() string

+ type Wacsi interface

+ BulletProofsOperation func(requestBody []byte, memory []byte, data []byte, isLen bool) ([]byte, error)

+ CallContract func(caller *common.Contract, requestBody []byte, txSimContext TxSimContext, ...) (*common.ContractResult, uint64, ExecOrderTxType, error)

+ DeleteState func(requestBody []byte, contractName string, txSimContext TxSimContext) error

+ EmitEvent func(requestBody []byte, txSimContext TxSimContext, contractId *common.Contract, ...) (*common.ContractEvent, error)

+ ErrorResult func(contractResult *common.ContractResult, data []byte) int32

+ ExecuteDDL func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ ExecuteQuery func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ ExecuteQueryOne func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) ([]byte, error)

+ ExecuteUpdate func(requestBody []byte, contractName string, method string, ...) error

+ GetState func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) ([]byte, error)

+ KvIterator func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ KvIteratorClose func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ KvIteratorHasNext func(requestBody []byte, txSimContext TxSimContext, memory []byte) error

+ KvIteratorNext func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) ([]byte, error)

+ KvPreIterator func(requestBody []byte, contractName string, txSimContext TxSimContext, ...) error

+ PaillierOperation func(requestBody []byte, memory []byte, data []byte, isLen bool) ([]byte, error)

+ PutState func(requestBody []byte, contractName string, txSimContext TxSimContext) error

+ RSClose func(requestBody []byte, txSimContext TxSimContext, memory []byte) error

+ RSHasNext func(requestBody []byte, txSimContext TxSimContext, memory []byte) error

+ RSNext func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) ([]byte, error)

+ SuccessResult func(contractResult *common.ContractResult, data []byte) int32

+ type Watcher interface

+ Module func() string

+ Watch func(chainConfig *config.ChainConfig) error

Other modules containing this package

chainmaker.org/chainmaker/protocol/v2

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