appchain_adapter

package
v1.24.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 7, 2022 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const IBTP_CH_SIZE = 1024

Variables

This section is empty.

Functions

func NewAppchainAdapter

func NewAppchainAdapter(mode string, config *repo.Config, logger logrus.FieldLogger, crypto txcrypto.Cryptor) (adapt.Adapt, error)

Types

type AppchainAdapter

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

func (*AppchainAdapter) GetChainID

func (a *AppchainAdapter) GetChainID() string

func (*AppchainAdapter) GetDirectTransactionMeta added in v1.21.0

func (a *AppchainAdapter) GetDirectTransactionMeta(IBTPid string) (uint64, uint64, uint64, error)

GetDirectTransactionMeta get transaction start timestamp, timeout period and transaction status in direct mode

func (*AppchainAdapter) GetPluginClient added in v1.22.0

func (a *AppchainAdapter) GetPluginClient() plugins.Client

func (*AppchainAdapter) GetServiceIDList

func (a *AppchainAdapter) GetServiceIDList() ([]string, error)

func (*AppchainAdapter) ID

func (a *AppchainAdapter) ID() string

func (*AppchainAdapter) MonitorIBTP

func (a *AppchainAdapter) MonitorIBTP() chan *pb.IBTP

func (*AppchainAdapter) MonitorUpdatedMeta

func (a *AppchainAdapter) MonitorUpdatedMeta() chan *[]byte

func (*AppchainAdapter) Name

func (a *AppchainAdapter) Name() string

func (*AppchainAdapter) QueryIBTP

func (a *AppchainAdapter) QueryIBTP(id string, isReq bool) (*pb.IBTP, error)

func (*AppchainAdapter) QueryInterchain

func (a *AppchainAdapter) QueryInterchain(serviceID string) (*pb.Interchain, error)

func (*AppchainAdapter) RollbackInDirectMode

func (a *AppchainAdapter) RollbackInDirectMode(ibtp *pb.IBTP) error

func (*AppchainAdapter) SendIBTP

func (a *AppchainAdapter) SendIBTP(ibtp *pb.IBTP) error

func (*AppchainAdapter) SendUpdatedMeta

func (a *AppchainAdapter) SendUpdatedMeta(byte []byte) error

func (*AppchainAdapter) Start

func (a *AppchainAdapter) Start() error

func (*AppchainAdapter) Stop

func (a *AppchainAdapter) Stop() error

Jump to

Keyboard shortcuts

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