executor

Documentation

Index

• type ChannelExecutor
  • func New(client client.Client, pierID string, storage storage.Storage, ...) (*ChannelExecutor, error)
  • func (e *ChannelExecutor) HandleIBTP(ibtp *pb.IBTP) *pb.IBTP
  • func (e *ChannelExecutor) QueryLatestMeta() map[string]uint64
  • func (e *ChannelExecutor) QueryReceipt(from string, idx uint64, originalIBTP *pb.IBTP) (*pb.IBTP, error)
  • func (e *ChannelExecutor) Start() error
  • func (e *ChannelExecutor) Stop() error
• type Executor

Types

type ChannelExecutor

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

ChannelExecutor represents the necessary data for executing interchain txs in appchain

func New

func New(client client.Client, pierID string, storage storage.Storage, cryptor txcrypto.Cryptor) (*ChannelExecutor, error)

New creates new instance of Executor. agent is for interacting with counterpart chain client is for interacting with appchain, meta is for recording interchain tx meta information and ds is for persisting some runtime messages

func (*ChannelExecutor) HandleIBTP

func (e *ChannelExecutor) HandleIBTP(ibtp *pb.IBTP) *pb.IBTP

applyIBTP handle ibtps of any type

func (*ChannelExecutor) QueryLatestMeta

func (e *ChannelExecutor) QueryLatestMeta() map[string]uint64

func (*ChannelExecutor) QueryReceipt

func (e *ChannelExecutor) QueryReceipt(from string, idx uint64, originalIBTP *pb.IBTP) (*pb.IBTP, error)

getReceipt only generates one receipt given source chain id and interchain tx index

func (*ChannelExecutor) Start

func (e *ChannelExecutor) Start() error

Start implements Executor

func (*ChannelExecutor) Stop

func (e *ChannelExecutor) Stop() error

Stop implements Executor

type Executor

type Executor interface {
	// Start starts the service of executor
	Start() error

	// Stop stops the service of executor
	Stop() error

	// HandleIBTP handles interchain ibtps from other appchains
	// and return the receipt ibtp for ack or callback
	HandleIBTP(ibtp *pb.IBTP) *pb.IBTP

	// QueryLatestMeta queries latest index map of ibtps executed on appchain
	QueryLatestMeta() map[string]uint64

	// QueryReceipt query receipt for original interchain ibtp
	QueryReceipt(from string, idx uint64, originalIBTP *pb.IBTP) (*pb.IBTP, error)
}