agency

type ApplyTxFunc func(int, pb.Transaction, InvalidReason, *TxOpt) *pb.Receipt

type Contract interface{}

type ContractConstructor func() Contract

type ContractInfo struct {
	Name        string
	Constructor ContractConstructor
}

type HAClient interface {
	//Check whethe there is a master pier connect to the BitXHub.
	CheckMasterPier(address string) (*pb.Response, error)

	//Set the master pier connect to the BitXHub.
	SetMasterPier(address string, index string, timeout int64) (*pb.Response, error)

	//Update the master pier status
	HeartBeat(address string, index string) (*pb.Response, error)
}

type InvalidReason string

type PierHA interface {
	Start() error

	Stop() error

	IsMain() <-chan bool
}

type PierHAConstructor func(client HAClient, pierID string) PierHA

type RegisterContractFunc func() map[string]Contract

type Registry interface{}

type RegistryConstructor func(storage.Storage, logrus.FieldLogger) Registry

type TxOpt struct {
	Contracts map[string]Contract
}

type TxsExecutor interface {
	ApplyTransactions(txs []pb.Transaction, invalidTxs map[int]InvalidReason) []*pb.Receipt

	GetBoltContracts() map[string]Contract

	AddNormalTx(hash *types.Hash)

	GetNormalTxs() []*types.Hash

	AddInterchainCounter(to string, index uint64)

	GetInterchainCounter() map[string][]uint64

	GetDescription() string
}

type TxsExecutorConstructor func(ApplyTxFunc, RegisterContractFunc, logrus.FieldLogger) TxsExecutor