appchain_adapter

Documentation

Index

• Constants
• func NewAppchainAdapter(mode string, config *repo.Config, logger logrus.FieldLogger, ...) (adapt.Adapt, error)
• type AppchainAdapter
  • func (a *AppchainAdapter) GetChainID() string
  • func (a *AppchainAdapter) GetDirectTransactionMeta(IBTPid string) (uint64, uint64, uint64, error)
  • func (a *AppchainAdapter) GetPluginClient() plugins.Client
  • func (a *AppchainAdapter) GetServiceIDList() ([]string, error)
  • func (a *AppchainAdapter) ID() string
  • func (a *AppchainAdapter) MonitorIBTP() chan *pb.IBTP
  • func (a *AppchainAdapter) MonitorUpdatedMeta() chan *[]byte
  • func (a *AppchainAdapter) Name() string
  • func (a *AppchainAdapter) QueryIBTP(id string, isReq bool) (*pb.IBTP, error)
  • func (a *AppchainAdapter) QueryInterchain(serviceID string) (*pb.Interchain, error)
  • func (a *AppchainAdapter) RollbackInDirectMode(ibtp *pb.IBTP) error
  • func (a *AppchainAdapter) SendIBTP(ibtp *pb.IBTP) error
  • func (a *AppchainAdapter) SendUpdatedMeta(byte []byte) error
  • func (a *AppchainAdapter) Start() error
  • func (a *AppchainAdapter) Stop() error

Constants

const IBTP_CH_SIZE = 1024

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

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

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