executor

package

v1.0.0-rc1 Latest Latest Go to latest Published: Apr 1, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/meshplus/pier

Links

Open Source Insights

Documentation ¶

Index ¶

type ChannelExecutor
- func NewChannelExecutor(agent agent.Agent, client client.Client, meta *rpcx.Appchain, ...) (*ChannelExecutor, error)
type Executor

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ChannelExecutor ¶

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

ChannelExecutor represents the necessary data for executing interchain txs in appchain

func NewChannelExecutor ¶

func NewChannelExecutor(agent agent.Agent, client client.Client, meta *rpcx.Appchain, storage storage.Storage) (*ChannelExecutor, error)

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

func (*ChannelExecutor) GetIBTPByID ¶

func (e *ChannelExecutor) GetIBTPByID(id string) (*pb.IBTP, error)

GetIBTPByID recover missing ibtp from local storage. If not found, query bitxhub.

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
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mock_executor Package mock_executor is a generated GoMock package.	Package mock_executor is a generated GoMock package.

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