protocol

package module

Go to main page

Versions in this module

v2

v2.3.4

Mar 28, 2024

Changes in this version

type AccessControlProvider

+ GetAddressFromCache func(pkBytes []byte) (string, crypto.PublicKey, error)

+ GetCertFromCache func(keyBytes []byte) ([]byte, error)

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

+ IsRuleSupportedByMultiSign func(resourceName string, blockVersion uint32) error

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

+ VerifyMsgPrincipal func(principal Principal, blockVersion uint32) (bool, error)

+ VerifyMultiSignTxPrincipal func(mInfo *syscontract.MultiSignInfo, blockVersion uint32) (syscontract.MultiSignStatus, error)

+ VerifyPrincipalLT2330 func(principal Principal, blockVersion uint32) (bool, error)

+ VerifyTxPrincipal func(tx *common.Transaction, resourceId string, blockVersion uint32) (bool, error)

type Net

+ DeleteAC func(chainId string)

+ StopPubSub func(chainId string)

type NetService

+ CancelReceiveMsg func(msgType net.NetMsg_MsgType) error

v2.3.3

Jul 18, 2023

Changes in this version

+ const SYNC_txHash_set_key

type AccessControlProvider

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

type BlockchainStore

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

+ GetLastHeight func() (uint64, error)

type TxSimContext

+ GetGasRemaining func() uint64

+ SubtractGas func(gasUsed uint64) error

type VerifyMode

+ const PROPOSER_VERIFY

+ const SYNC_FILTER_VERIFY

+ 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

v2.3.2

Feb 20, 2023

Changes in this version

type ChainConf

+ SetChainConfig func(chainConf *config.ChainConfig) error

type Snapshot

+ GetLastChainConfig func() *config.ChainConfig

type StoreBatcher

+ Remove func(key []byte)

type TxSimContext

+ GetLastChainConfig func() *config.ChainConfig

+ GetSnapshot func() Snapshot

v2.3.1

Oct 10, 2022

Changes in this version

type BlockchainStore

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

v2.3.0

Sep 1, 2022

Changes in this version

+ const ContractCrossCallerParam

+ const RoleContract

type AccessControlProvider

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

type BlockProposer

+ OnReceiveRwSetVerifyFailTxs func(rwSetVerifyFailTxs *consensuspb.RwSetVerifyFailTxs)

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

type BlockVerifier

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

type BlockchainStore

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

type CoreEngine

+ GetBlockProposer func() BlockProposer

type DBHandle

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

type MaxbftHelper

+ DiscardBlocks func(baseHeight uint64)

type Member

+ GetPk func() crypto.PublicKey

type ProposalCache

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

type Snapshot

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

+ GetBlockFingerprint func() string

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

type SnapshotManager

+ ClearSnapshot func(block *common.Block) error

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

type SyncService

+ ListenSyncToIdealHeight func() <-chan struct{}

+ StartBlockSync func()

+ StopBlockSync func()

type TxPool

+ AddTxBatchesToPendingCache func(batchIds []string, 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)

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

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

+ RetryAndRemoveTxBatches func(retryBatchIds []string, removeBatchIds []string)

type TxSimContext

+ GetBlockFingerprint func() string

+ GetCrossInfo func() uint64

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

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

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

+ HasUsed func(runtimeType common.RuntimeType) bool

+ RecordRuntimeTypeIntoCrossInfo func(runtimeType common.RuntimeType)

+ RemoveRuntimeTypeFromCrossInfo func()

type VmInstancesManager

+ AfterSchedule func(blockFingerprint string, blockHeight uint64)

+ BeforeSchedule func(blockFingerprint string, blockHeight uint64)

type VmManager

+ AfterSchedule func(blockFingerprint string, blockHeight uint64)

+ BeforeSchedule func(blockFingerprint string, blockHeight uint64)

+ type Wacsi interface

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

+ CallContract func(requestBody []byte, txSimContext TxSimContext, memory []byte, data []byte, ...) (*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

v2.2.2

May 16, 2022

Changes in this version

type BlockchainStore

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

+ TxExistsInIncrementDB func(txId string, startHeight uint64) (bool, 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, error)

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

+ SetHeight func(height uint64)

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

v2.2.1

Apr 19, 2022

v2.2.0

Mar 15, 2022

Changes in this version

+ const ContractAddrTypeParam

+ const ContractCreatorTypeParam

+ const ContractSenderTypeParam

+ const DefaultParametersValueMaxSize

type BlockProposer

+ OnReceiveMaxBFTProposal func(proposal *maxbft.BuildProposal)

type BlockVerifier

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

type BlockchainStore

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

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

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

+ GetTxWithRWSet func(txId string) (*common.TransactionWithRWSet, 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 ConsensusState interface

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

+ GetLastHeight func() uint64

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

type CoreEngine

+ GetMaxbftHelper func() MaxbftHelper

type DBHandle

+ GetDbType func() string

type ExecOrderTxType

+ const ExecOrderTxTypeChargeGas

+ type MaxbftHelper interface

+ DiscardAboveHeight func(baseHeight uint64)

type SqlDBHandle

+ GetSqlDbType func() string

type SqlDBTransaction

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

type StoreBatcher

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

+ Has func(key []byte) bool

+ type StoreHelper interface

+ BeginDbTransaction func(BlockchainStore, string)

+ GetPoolCapacity func() int

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

type TxSimContext

+ GetBlockTimestamp func() int64

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

v2.1.1

Nov 29, 2021

Changes in this version

+ const ContractTxTimeStamp

+ type ExecOrderTxType int

+ const ExecOrderTxTypeIterator

+ const ExecOrderTxTypeNormal

type Snapshot

+ GetBlockTimestamp func() int64

+ GetSpecialTxTable func() []*common.Transaction

type TxSimContext

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

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

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

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

type VmInstancesManager

+ StartVM func() error

+ StopVM func() error

type VmManager

+ Start func() error

+ Stop func() error

v2.1.0

Nov 5, 2021

Changes in this version

+ const DefaultMaxStateKeyLen

+ const Identity

+ const PermissionedWithCert

+ const PermissionedWithKey

+ const Public

type AccessControlProvider

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

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

+ type AuthType uint32

type DBHandle

+ GetWriteBatchSize func() uint64

+ type MemberQuery interface

+ GetMemberExtraData func(member *accesscontrol.Member) (*accesscontrol.MemberExtraData, 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 NetType

+ const Liquid

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

+ type RuntimeInstance interface

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

type StateSqlOperation

+ CreateDatabase func(contractName string) error

+ DropDatabase func(contractName string) error

+ GetContractDbName func(contractName string) string

type StoreBatcher

+ SplitBatch func(batchCnt uint64) []StoreBatcher

+ type VmInstancesManager interface

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

v2.0.0

Sep 1, 2021

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 ContractAllocateMethod

+ const ContractBlockHeightParam

+ const ContractContextPtrParam

+ const ContractCreatorOrgIdParam

+ const ContractCreatorPkParam

+ const ContractCreatorRoleParam

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

+ const ContractTxIdParam

+ const ContractUpgradeMethod

+ const DefaultBlockVersion

+ const DefaultStateLen

+ const DefaultStateRegex

+ const DefaultVersionLen

+ const DefaultVersionRegex

+ const EventDataMaxCount

+ const EventDataMaxLen

+ const EvmGasPrice

+ const EvmMaxStackDepth

+ const GasLimit

+ const PaillierOpTypeAddCiphertext

+ const PaillierOpTypeAddPlaintext

+ const PaillierOpTypeNumMul

+ const PaillierOpTypeSubCiphertext

+ const PaillierOpTypeSubPlaintext

+ const ParametersKeyMaxCount

+ const ParametersValueMaxLength

+ const RAFTAddtionalDataKey

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

+ const RuleAll

+ const RuleAny

+ const RuleDelete

+ const RuleForbidden

+ const RuleMajority

+ const RuleSelf

+ const TBFTAddtionalDataKey

+ const TBFT_blocks_per_proposer

+ const TBFT_propose_delta_timeout_key

+ const TBFT_propose_timeout_key

+ const TimeLimit

+ const TopicMaxLen

+ var ConsensusDBName = "consensus"

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

+ GetHashAlg func() string

+ GetMemberStatus func(member *pbac.Member) (pbac.MemberStatus, 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 BlockCommitter interface

+ AddBlock func(blk *common.Block) error

+ type BlockProposer interface

+ OnReceiveChainedBFTProposal func(proposal *chainedbft.BuildProposal)

+ OnReceiveProposeStatusChange func(proposeStatus bool)

+ OnReceiveTxPoolSignal func(proposeSignal *txpool.TxPoolSignal)

+ Start func() error

+ Stop func() error

+ type BlockVerifier interface

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

+ type BlockchainStore interface

+ ArchiveBlock func(archiveHeight uint64) error

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

+ Close func() 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)

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

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

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

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

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

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

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

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

+ InitGenesis func(genesisBlock *store.BlockWithRWSet) error

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

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

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

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

+ TxExists func(txId string) (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

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

+ GetBlockVerifier func() BlockVerifier

+ GetHotStuffHelper func() HotStuffHelper

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

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

+ NewIteratorWithPrefix func(prefix []byte) Iterator

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

+ 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, netMsg *net.NetMsg) error

+ type Government interface

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

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

+ type HotStuffHelper interface

+ DiscardAboveHeight func(baseHeight uint64)

+ 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 Member interface

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

+ GetMemberId func() string

+ GetOrgId func() string

+ GetRole func() Role

+ GetUid func() string

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

+ type MsgHandler func(from string, msg []byte, msgType net.NetMsg_MsgType) 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 GRpc

+ const Libp2p

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

+ DiscardAboveHeight 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, netMsg *net.NetMsg) error

+ type Role string

+ type Rule string

+ type SigningMember interface

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

+ type Snapshot interface

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

+ BuildDAG func(isSql bool) *common.DAG

+ GetBlockHeight func() uint64

+ GetBlockProposer func() *accesscontrol.Member

+ GetBlockchainStore func() BlockchainStore

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

+ GetPreSnapshot func() Snapshot

+ GetSnapshotSize func() int

+ 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

+ 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

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

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

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

+ 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

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

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

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

+ Len func() int

+ Merge func(batcher StoreBatcher)

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

+ type SyncService interface

+ Start func() error

+ Stop func()

+ type SysContractQuery interface

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

+ GetContractBytecode func(name string) ([]byte, 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

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

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

+ GetTxByTxId func(txId string) (tx *common.Transaction, inBlockHeight uint64)

+ GetTxsByTxIds func(txIds []string) (txsRet map[string]*common.Transaction, txsHeightRet map[string]uint64)

+ RetryAndRemoveTxs func(retryTxs []*common.Transaction, removeTxs []*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(contract *common.Contract, method string, byteCode []byte, ...) (*common.ContractResult, common.TxStatusCode)

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

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

+ GetAccessControl func() (AccessControlProvider, error)

+ GetBlockHeight func() uint64

+ GetBlockProposer func() *pbac.Member

+ GetBlockVersion func() uint32

+ GetBlockchainStore func() BlockchainStore

+ GetChainNodesInfoProvider func() (ChainNodesInfoProvider, error)

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

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

+ GetCreator func(namespace string) *pbac.Member

+ GetCurrentResult func() []byte

+ GetDepth func() int

+ GetSender func() *pbac.Member

+ GetStateKvHandle func(int32) (StateIterator, bool)

+ GetStateSqlHandle func(int32) (SqlRows, bool)

+ GetTx func() *common.Transaction

+ GetTxExecSeq func() int

+ GetTxRWSet func(runVmSuccess bool) *common.TxRWSet

+ GetTxResult func() *common.Result

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

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

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

+ SetStateKvHandle func(int32, StateIterator)

+ SetStateSqlHandle func(int32, SqlRows)

+ 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 VmManager interface

+ GetAccessControl func() AccessControlProvider

+ GetChainNodesInfoProvider func() ChainNodesInfoProvider

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

+ type VmWatcher interface

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

+ ContractNames func() []string

+ Module func() string

+ type Watcher interface

+ Module func() string

+ Watch func(chainConfig *config.ChainConfig) error

Other modules containing this package

chainmaker.org/chainmaker/protocol/v3

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