Documentation
¶
Index ¶
- Constants
- Variables
- type BxhAdapter
- func (b *BxhAdapter) GetServiceIDList() ([]string, error)
- func (b *BxhAdapter) ID() string
- func (b *BxhAdapter) MonitorIBTP() chan *pb.IBTP
- func (b *BxhAdapter) MonitorUpdatedMeta() chan *[]byte
- func (b *BxhAdapter) Name() string
- func (b *BxhAdapter) QueryIBTP(id string, isReq bool) (*pb.IBTP, error)
- func (b *BxhAdapter) QueryInterchain(serviceID string) (*pb.Interchain, error)
- func (b *BxhAdapter) SendIBTP(ibtp *pb.IBTP) error
- func (b *BxhAdapter) SendUpdatedMeta(byte []byte) error
- func (b *BxhAdapter) Start() error
- func (b *BxhAdapter) Stop() error
Constants ¶
View Source
const ( TargetAppchainNotAvailable = "target appchain not available" SrcBitXHubNotAvailable = "source bitxhub not available" TargetBitXHubNotAvailable = "target bitxhub not available" SrcServiceNotAvailable = "1080007" InvalidTargetService = "invalid target service" )
Variables ¶
View Source
var ( ErrIBTPNotFound = fmt.Errorf("receipt from bitxhub failed") ErrMetaOutOfDate = fmt.Errorf("interchain meta is out of date") )
Functions ¶
This section is empty.
Types ¶
type BxhAdapter ¶
type BxhAdapter struct {
// contains filtered or unexported fields
}
BxhAdapter represents the necessary data for sync tx from bitxhub
func New ¶
func New(mode, appchainId string, client rpcx.Client, logger logrus.FieldLogger, tss *repo.TSS) (*BxhAdapter, error)
New creates instance of WrapperSyncer given agent interacting with bitxhub, validators addresses of bitxhub and local storage
func (*BxhAdapter) GetServiceIDList ¶
func (b *BxhAdapter) GetServiceIDList() ([]string, error)
func (*BxhAdapter) ID ¶ added in v1.18.0
func (b *BxhAdapter) ID() string
func (*BxhAdapter) MonitorIBTP ¶
func (b *BxhAdapter) MonitorIBTP() chan *pb.IBTP
func (*BxhAdapter) MonitorUpdatedMeta ¶ added in v1.18.0
func (b *BxhAdapter) MonitorUpdatedMeta() chan *[]byte
func (*BxhAdapter) Name ¶
func (b *BxhAdapter) Name() string
func (*BxhAdapter) QueryInterchain ¶
func (b *BxhAdapter) QueryInterchain(serviceID string) (*pb.Interchain, error)
func (*BxhAdapter) SendUpdatedMeta ¶ added in v1.18.0
func (b *BxhAdapter) SendUpdatedMeta(byte []byte) error
func (*BxhAdapter) Start ¶
func (b *BxhAdapter) Start() error
func (*BxhAdapter) Stop ¶
func (b *BxhAdapter) Stop() error
Source Files
Click to show internal directories.
Click to hide internal directories.