txmanager

Documentation

Index

• Constants
• type ContractManager
  • func (cm *ContractManager) GetABIPath() string
  • func (cm *ContractManager) GetContractAddress() ethcom.Address
  • func (cm *ContractManager) Init() error
  • func (cm *ContractManager) ReadUserToCEvent(data []byte, topics []ethcom.Hash, blockNumber uint64, blockHash ethcom.Hash, ...) (*pubevent.LogUserToC, error)
• type NodeManager
  • func (nm *NodeManager) GetEthSDK() (*sdk.EthSDK, error)
  • func (nm *NodeManager) GetTransactionReceipt(txHashStr string) (map[string]interface{}, error)
  • func (nm *NodeManager) Init(key string, config interface{}, ks *keystore.KeyStore) (err error)
  • func (nm *NodeManager) ListenWsEvent(contractManager *ContractManager, userToCChan chan *pubevent.LogUserToC)
  • func (nm *NodeManager) SendRawTransaction(chainId int, contractAdd ethcom.Address, data []byte, isWait bool) (string, error)
• type TxManager
  • func (tm *TxManager) HandleRollbackToC(_txid []byte, _value *big.Int) error
  • func (tm *TxManager) HandleUserToCEvent(userToC *pubevent.LogUserToC, consortiumManager *cTxManager.TxManager)
  • func (tm *TxManager) Init(ks *keystore.KeyStore) error
  • func (tm *TxManager) ListenEvent(userToCChan chan *pubevent.LogUserToC)
  • func (tm *TxManager) PickNodeManager() (*NodeManager, error)
  • func (tm *TxManager) RandomNode() *NodeManager
  • func (tm *TxManager) SendRawTransaction(isWait bool, methodName string, args ...interface{}) (string, error)
  • func (tm *TxManager) WaitUntilDeltaConfirmations(userToC *pubevent.LogUserToC, consortiumManager *cTxManager.TxManager) (bool, uint64, error)

Constants

const (
	DeltaConfirmations = 3
	WaitTime           = 10 * 60 * time.Second
	ConfirmedCount     = 10
)

Types

type ContractManager

type ContractManager struct {
	// contains filtered or unexported fields
}

func (*ContractManager) GetABIPath

func (cm *ContractManager) GetABIPath() string

func (*ContractManager) GetContractAddress

func (cm *ContractManager) GetContractAddress() ethcom.Address

func (*ContractManager) Init

func (cm *ContractManager) Init() error

func (*ContractManager) ReadUserToCEvent

func (cm *ContractManager) ReadUserToCEvent(data []byte, topics []ethcom.Hash, blockNumber uint64, blockHash ethcom.Hash, txHash ethcom.Hash, txIndex uint, removed bool) (*pubevent.LogUserToC, error)

type NodeManager

type NodeManager struct {
	// contains filtered or unexported fields
}

func (*NodeManager) GetEthSDK

func (nm *NodeManager) GetEthSDK() (*sdk.EthSDK, error)

func (*NodeManager) GetTransactionReceipt

func (nm *NodeManager) GetTransactionReceipt(txHashStr string) (map[string]interface{}, error)

func (*NodeManager) Init

func (nm *NodeManager) Init(key string, config interface{}, ks *keystore.KeyStore) (err error)

func (*NodeManager) ListenWsEvent

func (nm *NodeManager) ListenWsEvent(contractManager *ContractManager, userToCChan chan *pubevent.LogUserToC)

func (*NodeManager) SendRawTransaction

func (nm *NodeManager) SendRawTransaction(chainId int, contractAdd ethcom.Address, data []byte, isWait bool) (string, error)

type TxManager

type TxManager struct {
	// contains filtered or unexported fields
}

func (*TxManager) HandleRollbackToC

func (tm *TxManager) HandleRollbackToC(_txid []byte, _value *big.Int) error

func (*TxManager) HandleUserToCEvent

func (tm *TxManager) HandleUserToCEvent(userToC *pubevent.LogUserToC, consortiumManager *cTxManager.TxManager)

func (*TxManager) Init

func (tm *TxManager) Init(ks *keystore.KeyStore) error

func (*TxManager) ListenEvent

func (tm *TxManager) ListenEvent(userToCChan chan *pubevent.LogUserToC)

func (*TxManager) PickNodeManager

func (tm *TxManager) PickNodeManager() (*NodeManager, error)

func (*TxManager) RandomNode

func (tm *TxManager) RandomNode() *NodeManager

func (*TxManager) SendRawTransaction

func (tm *TxManager) SendRawTransaction(isWait bool, methodName string, args ...interface{}) (string, error)

func (*TxManager) WaitUntilDeltaConfirmations

func (tm *TxManager) WaitUntilDeltaConfirmations(userToC *pubevent.LogUserToC, consortiumManager *cTxManager.TxManager) (bool, uint64, error)