Versions in this module Expand all Collapse all v2 v2.3.1 Jul 26, 2023 Changes in this version + const SubFailed + const SubResult + const SubSuccess + const TbisFlag + func BuildBeginCrossChainRequestFromTbis(event common.CrossChainEvent, eventInfo *EventInfo, log *zap.SugaredLogger, ...) (req *relay_chain.BeginCrossChainRequest, err error) + func EventKey(eventName, contractName, chainRid string) []byte + func GetCommitParam(chainRID string, proveStatus, contractStatus int, contractResult string) string + func InitEventManager() + type ChainTxContext struct + ChainRID string + ContractResult string + ContractStatus int + ProveStatus int + func NewChainTxContext(chainRID string, proveStatus, contractStatus int, contractResult string) *ChainTxContext + func (c *ChainTxContext) ToContractParam() string + type ChainTxContexts struct + Contexts []*ChainTxContext + func NewChainTxContexts() *ChainTxContexts + func (c *ChainTxContexts) Append(chainTxCtx *ChainTxContext) + func (c *ChainTxContexts) Len() int + func (c *ChainTxContexts) ToContractParam() string + type CommitContract struct + Ctt *InnerContract + Identity string + ParamsContent string + ParamsData []string + ParamsFormat string + func NewCommitContract(identity string, cttName, cttVersion, cttMethod string, ...) *CommitContract + func NewEmptyCommitContract() *CommitContract + func (c *CommitContract) Check() error + func (c *CommitContract) CheckIdentity(chainRID string) error + func (c *CommitContract) GetParamsData() string + type ContractListenData struct + Business string + CommitCtt *CommitContract + CrossID string + EventData string + EventName string + SubEvents []*CrossSubEvent + func NewEmptyContractListenData() *ContractListenData + func (d *ContractListenData) AppendSubEvent(crossSubEvent *CrossSubEvent) + func (d *ContractListenData) CheckAndInit() error + func (d *ContractListenData) CheckAvailability(chainRID string) error + func (d *ContractListenData) GetSubEvents() []*CrossSubEvent + type CrossSubEvent struct + ChainCtt *CommitContract + ChainRID string + ExecIdx int + GatewayID string + func NewCrossSubEvent(chainRID string, dstGatewayID string, chainCtt *CommitContract) *CrossSubEvent + func NewEmptyCrossSubEvent() *CrossSubEvent + func (se *CrossSubEvent) CheckAndInit() error + type EventInfo struct + BlockHeight int64 + ChainRid string + ContractName string + Data []string + Topic string + Tx []byte + TxId string + TxProve string + func (e *EventInfo) ToString() string + type EventManager struct + var EventManagerV1 *EventManager + func (e *EventManager) BuildCrossChainMsg(eventInfo *EventInfo) (req *relay_chain.BeginCrossChainRequest, err error) + func (e *EventManager) DeleteEvent(event *common.CrossChainEvent) error + func (e *EventManager) GetEvent(crossChainEventId string) ([]*common.CrossChainEvent, error) + func (e *EventManager) SaveEvent(event *common.CrossChainEvent, isNew bool) error + func (e *EventManager) SetEventState(crossChainEventId string, state bool, stateMessages string) error + type InnerContract struct + ExtraData map[string]string + Method string + Name string + Version string + func NewEmptyInnerContract() *InnerContract + func NewInnerContract(name, version, method string) *InnerContract + func (c *InnerContract) Abi() (string, bool) + func (c *InnerContract) GetExtraData() string + func (c *InnerContract) Put(key, val string) + func (c *InnerContract) PutBatch(kvs map[string]interface{}) + func (c *InnerContract) Puts(kvs map[string]string) + type KeyValue struct + func NewKeyValue(key, value string) *KeyValue + func NewKeyValueByString(data string) *KeyValue + func (kv *KeyValue) Key() string + func (kv *KeyValue) Value() string + type KeyValues struct + func NewKeyValues() *KeyValues + func NewNewKeyValuesByString(data string) *KeyValues + func (kvs *KeyValues) Append(kv *KeyValue) + func (kvs *KeyValues) Length() int + type TbisEventParser struct + func NewTbisEventParser(log *zap.SugaredLogger) *TbisEventParser + func (t *TbisEventParser) ParseListenEvent(chainRID, data string) (*ContractListenData, error)