rwset

package

Go to main page

Versions in this module

v1

v1.0.9

Sep 7, 2020

v1.0.8

Jun 5, 2020

v1.0.7

Apr 3, 2020

v1.0.7-hotfix1

May 1, 2020

v1.0.6

Feb 28, 2020

Changes in this version

+ type IDataQuery interface

+ GetAddr1TokenUtxos func(addr common.Address, asset *modules.Asset) (map[modules.OutPoint]*modules.Utxo, error)

+ GetAddrUtxos func(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)

+ GetGlobalProp func() *modules.GlobalProperty

+ GetHeaderByNumber func(number *modules.ChainIndex) (*modules.Header, error)

+ GetNewestUnit func(token modules.AssetId) (common.Hash, *modules.ChainIndex, error)

+ GetStableTransactionOnly func(hash common.Hash) (*modules.Transaction, error)

+ GetStableUnit func(hash common.Hash) (*modules.Unit, error)

+ GetStableUnitByNumber func(number *modules.ChainIndex) (*modules.Unit, error)

+ UnstableHeadUnitProperty func(asset modules.AssetId) (*modules.UnitProperty, error)

+ type IStateQuery interface

+ GetContractState func(contractid []byte, field string) ([]byte, *modules.StateVersion, error)

+ GetContractStatesById func(contractid []byte) (map[string]*modules.ContractStateValue, error)

+ GetContractStatesByPrefix func(contractid []byte, prefix string) (map[string]*modules.ContractStateValue, error)

type KVRWSet

+ func (m *KVRWSet) MarshalText() ([]byte, error)

type KVRead

+ func (m *KVRead) MarshalText() ([]byte, error)

+ type MockIDataQuery struct

+ func NewMockIDataQuery(ctrl *gomock.Controller) *MockIDataQuery

+ func (m *MockIDataQuery) EXPECT() *MockIDataQueryMockRecorder

+ func (m *MockIDataQuery) GetAddr1TokenUtxos(addr common.Address, asset *modules.Asset) (map[modules.OutPoint]*modules.Utxo, error)

+ func (m *MockIDataQuery) GetAddrUtxos(addr common.Address) (map[modules.OutPoint]*modules.Utxo, error)

+ func (m *MockIDataQuery) GetContractState(contractid []byte, field string) ([]byte, *modules.StateVersion, error)

+ func (m *MockIDataQuery) GetContractStatesById(contractid []byte) (map[string]*modules.ContractStateValue, error)

+ func (m *MockIDataQuery) GetContractStatesByPrefix(contractid []byte, prefix string) (map[string]*modules.ContractStateValue, error)

+ func (m *MockIDataQuery) GetGlobalProp() *modules.GlobalProperty

+ func (m *MockIDataQuery) GetHeaderByNumber(number *modules.ChainIndex) (*modules.Header, error)

+ func (m *MockIDataQuery) GetNewestUnit(token modules.AssetId) (common.Hash, *modules.ChainIndex, error)

+ func (m *MockIDataQuery) GetStableTransactionOnly(hash common.Hash) (*modules.Transaction, error)

+ func (m *MockIDataQuery) GetStableUnit(hash common.Hash) (*modules.Unit, error)

+ func (m *MockIDataQuery) GetStableUnitByNumber(number *modules.ChainIndex) (*modules.Unit, error)

+ func (m *MockIDataQuery) UnstableHeadUnitProperty(asset modules.AssetId) (*modules.UnitProperty, error)

+ type MockIDataQueryMockRecorder struct

+ func (mr *MockIDataQueryMockRecorder) GetAddr1TokenUtxos(addr, asset interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetAddrUtxos(addr interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetContractState(contractid, field interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetContractStatesById(contractid interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetContractStatesByPrefix(contractid, prefix interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetGlobalProp() *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetHeaderByNumber(number interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetNewestUnit(token interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetStableTransactionOnly(hash interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetStableUnit(hash interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) GetStableUnitByNumber(number interface{}) *gomock.Call

+ func (mr *MockIDataQueryMockRecorder) UnstableHeadUnitProperty(asset interface{}) *gomock.Call

+ type MockIStateQuery struct

+ func NewMockIStateQuery(ctrl *gomock.Controller) *MockIStateQuery

+ func (m *MockIStateQuery) EXPECT() *MockIStateQueryMockRecorder

+ func (m *MockIStateQuery) GetContractState(contractid []byte, field string) ([]byte, *modules.StateVersion, error)

+ func (m *MockIStateQuery) GetContractStatesById(contractid []byte) (map[string]*modules.ContractStateValue, error)

+ func (m *MockIStateQuery) GetContractStatesByPrefix(contractid []byte, prefix string) (map[string]*modules.ContractStateValue, error)

+ type MockIStateQueryMockRecorder struct

+ func (mr *MockIStateQueryMockRecorder) GetContractState(contractid, field interface{}) *gomock.Call

+ func (mr *MockIStateQueryMockRecorder) GetContractStatesById(contractid interface{}) *gomock.Call

+ func (mr *MockIStateQueryMockRecorder) GetContractStatesByPrefix(contractid, prefix interface{}) *gomock.Call

type RWSetBuilder

+ func (b *RWSetBuilder) GetWriteSet(contractId []byte, key string) ([]byte, error)

+ func (b *RWSetBuilder) GetWriteSets(contractId []byte) ([]*KVWrite, error)

type RwSetTxMgr

+ func (m *RwSetTxMgr) GetTxSimulator(txId string) (TxSimulator, error)

type RwSetTxSimulator

+ func (s *RwSetTxSimulator) GetAllStates(contractid []byte, ns string) (map[string]*modules.ContractStateValue, error)

+ func (s *RwSetTxSimulator) GetContractState(contractid []byte, field string) ([]byte, *modules.StateVersion, error)

+ func (s *RwSetTxSimulator) GetContractStatesByPrefix(contractid []byte, prefix string) (map[string]*modules.ContractStateValue, error)

+ func (s *RwSetTxSimulator) Rollback() error

type TxManager

+ GetTxSimulator func(txId string) (TxSimulator, error)

type TxSimulator

+ Close func()

+ GetAllStates func(contractId []byte, ns string) (map[string]*modules.ContractStateValue, error)

+ Rollback func() error

v1.0.5

Jan 16, 2020

Changes in this version

type RwSetTxSimulator

+ func (s *RwSetTxSimulator) GetStableTransactionByHash(ns string, hash common.Hash) (*modules.Transaction, error)

+ func (s *RwSetTxSimulator) GetStableUnit(ns string, hash common.Hash, unitNumber uint64) (*modules.Unit, error)

type TxSimulator

+ GetStableTransactionByHash func(ns string, hash common.Hash) (*modules.Transaction, error)

+ GetStableUnit func(ns string, hash common.Hash, unitNumber uint64) (*modules.Unit, error)

v1.0.5-hotfix1

Jan 19, 2020

v1.0.4

Nov 27, 2019

v1.0.3

Oct 14, 2019

v1.0.2

Aug 30, 2019

Changes in this version

type RwSetTxSimulator

+ func (s *RwSetTxSimulator) GetGlobalProp() ([]byte, error)

type TxSimulator

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

v1.0.1

Aug 1, 2019

v1.0.0

Jun 30, 2019

Changes in this version

+ var ChainId = "palletone"

+ func Init()

+ type KVRWSet struct

+ Reads map[string]*KVRead

+ Writes map[string]*KVWrite

+ func (*KVRWSet) Descriptor() ([]byte, []int)

+ func (*KVRWSet) ProtoMessage()

+ func (m *KVRWSet) GetReads() map[string]*KVRead

+ func (m *KVRWSet) GetWrites() map[string]*KVWrite

+ func (m *KVRWSet) Reset()

+ func (m *KVRWSet) String() string

+ type KVRead struct

+ ContractId []byte

+ func NewKVRead(contractId []byte, key string, version *modules.StateVersion) *KVRead

+ func (*KVRead) Descriptor() ([]byte, []int)

+ func (*KVRead) ProtoMessage()

+ func (m *KVRead) GetKey() string

+ func (m *KVRead) GetValue() []byte

+ func (m *KVRead) GetVersion() *modules.StateVersion

+ func (m *KVRead) Reset()

+ func (m *KVRead) String() string

+ type KVWrite struct

+ ContractId []byte

+ func (*KVWrite) Descriptor() ([]byte, []int)

+ func (*KVWrite) ProtoMessage()

+ func (m *KVWrite) GetIsDelete() bool

+ func (m *KVWrite) GetKey() string

+ func (m *KVWrite) GetValue() []byte

+ func (m *KVWrite) Reset()

+ func (m *KVWrite) String() string

+ type RWSetBuilder struct

+ func NewRWSetBuilder() *RWSetBuilder

+ func (b *RWSetBuilder) AddSupplyToken(ns string, assetId, uniqueId []byte, amt uint64, createAddr common.Address) error

+ func (b *RWSetBuilder) AddToReadSet(contractId []byte, ns string, key string, version *modules.StateVersion)

+ func (b *RWSetBuilder) AddToWriteSet(contractId []byte, ns string, key string, value []byte)

+ func (b *RWSetBuilder) AddTokenPayOut(ns string, addr string, asset *modules.Asset, amount uint64, lockTime uint32)

+ func (b *RWSetBuilder) DefineToken(ns string, tokenType int32, define []byte, createAddr common.Address)

+ func (b *RWSetBuilder) GetTokenDefine(ns string) *modules.TokenDefine

+ func (b *RWSetBuilder) GetTokenPayOut(ns string) []*modules.TokenPayOut

+ func (b *RWSetBuilder) GetTokenSupply(ns string) []*modules.TokenSupply

+ type RwSetTxMgr struct

+ var RwM *RwSetTxMgr

+ func NewRwSetMgr(name string) (*RwSetTxMgr, error)

+ func (m *RwSetTxMgr) BaseTxSim() map[string]TxSimulator

+ func (m *RwSetTxMgr) Close()

+ func (m *RwSetTxMgr) CloseTxSimulator(chainid, txid string) error

+ func (m *RwSetTxMgr) NewTxSimulator(idag dag.IDag, chainid string, txid string, is_sys bool) (TxSimulator, error)

+ type RwSetTxSimulator struct

+ func NewBasedTxSimulator(idag dag.IDag, hash common.Hash) *RwSetTxSimulator

+ func (h *RwSetTxSimulator) Done()

+ func (h *RwSetTxSimulator) GetTxSimulationResults() ([]byte, error)

+ func (s *RwSetTxSimulator) CheckDone() error

+ func (s *RwSetTxSimulator) Close()

+ func (s *RwSetTxSimulator) DefineToken(ns string, tokenType int32, define []byte, creator string) error

+ func (s *RwSetTxSimulator) DeleteState(contractId []byte, ns string, key string) error

+ func (s *RwSetTxSimulator) GetChainParameters() ([]byte, error)

+ func (s *RwSetTxSimulator) GetContractStatesById(contractid []byte) (map[string]*modules.ContractStateValue, error)

+ func (s *RwSetTxSimulator) GetPayOutData(ns string) ([]*modules.TokenPayOut, error)

+ func (s *RwSetTxSimulator) GetRwData(ns string) ([]*KVRead, []*KVWrite, error)

+ func (s *RwSetTxSimulator) GetState(contractid []byte, ns string, key string) ([]byte, error)

+ func (s *RwSetTxSimulator) GetStatesByPrefix(contractid []byte, ns string, prefix string) ([]*modules.KeyValue, error)

+ func (s *RwSetTxSimulator) GetTimestamp(ns string, rangeNumber uint32) ([]byte, error)

+ func (s *RwSetTxSimulator) GetTokenBalance(ns string, addr common.Address, asset *modules.Asset) (map[modules.Asset]uint64, error)

+ func (s *RwSetTxSimulator) GetTokenDefineData(ns string) (*modules.TokenDefine, error)

+ func (s *RwSetTxSimulator) GetTokenSupplyData(ns string) ([]*modules.TokenSupply, error)

+ func (s *RwSetTxSimulator) PayOutToken(ns string, address string, token *modules.Asset, amount uint64, ...) error

+ func (s *RwSetTxSimulator) SetState(contractId []byte, ns string, key string, value []byte) error

+ func (s *RwSetTxSimulator) String() string

+ func (s *RwSetTxSimulator) SupplyToken(ns string, assetId, uniqueId []byte, amt uint64, creator string) error

+ type TxManager interface

+ Close func()

+ CloseTxSimulator func(chainid, txid string) error

+ NewTxSimulator func(idag dag.IDag, chainid string, txid string, is_sys bool) (TxSimulator, error)

+ type TxSimulator interface

+ CheckDone func() error

+ DefineToken func(ns string, tokenType int32, define []byte, creator string) error

+ DeleteState func(contractid []byte, ns string, key string) error

+ Done func()

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

+ GetContractStatesById func(contractid []byte) (map[string]*modules.ContractStateValue, error)

+ GetPayOutData func(ns string) ([]*modules.TokenPayOut, error)

+ GetRwData func(ns string) ([]*KVRead, []*KVWrite, error)

+ GetState func(contractid []byte, ns string, key string) ([]byte, error)

+ GetStatesByPrefix func(contractid []byte, ns string, prefix string) ([]*modules.KeyValue, error)

+ GetTimestamp func(ns string, rangeNumber uint32) ([]byte, error)

+ GetTokenBalance func(ns string, addr common.Address, asset *modules.Asset) (map[modules.Asset]uint64, error)

+ GetTokenDefineData func(ns string) (*modules.TokenDefine, error)

+ GetTokenSupplyData func(ns string) ([]*modules.TokenSupply, error)

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

+ PayOutToken func(ns string, address string, token *modules.Asset, amount uint64, ...) error

+ SetState func(contractid []byte, ns string, key string, value []byte) error

+ String func() string

+ SupplyToken func(ns string, assetId, uniqueId []byte, amt uint64, creator string) error

+ type Version struct

+ type VersionedValue struct

+ Value []byte

+ Version *Version

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