agent

Documentation

Index

• type BxhClient
  • func CreateClient(agent rpcx.Client) *BxhClient
  • func (client *BxhClient) CommitCallback(ibtp *pb.IBTP) error
  • func (client *BxhClient) GetCallbackMeta() (map[string]uint64, error)
  • func (client *BxhClient) GetIBTP() chan *pb.IBTP
  • func (client *BxhClient) GetInMessage(from string, idx uint64) ([][]byte, error)
  • func (client *BxhClient) GetInMeta() (map[string]uint64, error)
  • func (client *BxhClient) GetOutMessage(to string, idx uint64) (*pb.IBTP, error)
  • func (client *BxhClient) GetOutMeta() (map[string]uint64, error)
  • func (client *BxhClient) GetReceipt(ibtp *pb.IBTP) (*pb.IBTP, error)
  • func (client *BxhClient) IncreaseInMeta(ibtp *pb.IBTP) (*pb.IBTP, error)
  • func (client *BxhClient) Initialize(configPath string, pierID string, extra []byte) error
  • func (client *BxhClient) Name() string
  • func (client *BxhClient) RollbackIBTP(ibtp *pb.IBTP, isSrcChain bool) (*pb.RollbackIBTPResponse, error)
  • func (client *BxhClient) Start() error
  • func (client *BxhClient) Stop() error
  • func (client *BxhClient) SubmitIBTP(ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)
  • func (client *BxhClient) Type() string

Types

type BxhClient

type BxhClient struct {
	rpcx.Appchain
	// contains filtered or unexported fields
}

BxhClient represents plugin client fo relaychain, by packing operations of relaychain to an appchain plugin-client, we can easily excute ibtp.Payload on relaychain just like what we used to do on an appchain.

func CreateClient

func CreateClient(agent rpcx.Client) *BxhClient

CreateClient creates plugin client from agent

func (*BxhClient) CommitCallback

func (client *BxhClient) CommitCallback(ibtp *pb.IBTP) error

CommitCallback .

func (*BxhClient) GetCallbackMeta

func (client *BxhClient) GetCallbackMeta() (map[string]uint64, error)

GetCallbackMeta gets an index map, which implicates the greatest index of executed callback txs for each receiving chain TODO

func (*BxhClient) GetIBTP

func (client *BxhClient) GetIBTP() chan *pb.IBTP

GetIBTP .

func (*BxhClient) GetInMessage

func (client *BxhClient) GetInMessage(from string, idx uint64) ([][]byte, error)

GetInMessage gets receipt by index and source chain_id TODO

func (*BxhClient) GetInMeta

func (client *BxhClient) GetInMeta() (map[string]uint64, error)

GetInMeta gets an index map, which implicates the greatest index of ingoing interchain txs for each source chain

func (*BxhClient) GetOutMessage

func (client *BxhClient) GetOutMessage(to string, idx uint64) (*pb.IBTP, error)

GetOutMessage .

func (*BxhClient) GetOutMeta

func (client *BxhClient) GetOutMeta() (map[string]uint64, error)

GetOutMeta .

func (*BxhClient) GetReceipt

func (client *BxhClient) GetReceipt(ibtp *pb.IBTP) (*pb.IBTP, error)

func (*BxhClient) IncreaseInMeta

func (client *BxhClient) IncreaseInMeta(ibtp *pb.IBTP) (*pb.IBTP, error)

func (*BxhClient) Initialize

func (client *BxhClient) Initialize(configPath string, pierID string, extra []byte) error

Initialize .

func (*BxhClient) Name

func (client *BxhClient) Name() string

Name .

func (*BxhClient) RollbackIBTP

func (client *BxhClient) RollbackIBTP(ibtp *pb.IBTP, isSrcChain bool) (*pb.RollbackIBTPResponse, error)

func (*BxhClient) Start

func (client *BxhClient) Start() error

Start .

func (*BxhClient) Stop

func (client *BxhClient) Stop() error

Stop .

func (*BxhClient) SubmitIBTP

func (client *BxhClient) SubmitIBTP(ibtp *pb.IBTP) (*pb.SubmitIBTPResponse, error)

SubmitIBTP submits the inter-relaychain ibtp to relaychain to execute ibtp.Payload

func (*BxhClient) Type

func (client *BxhClient) Type() string

Type .