cross

Documentation

Index

• Constants
• Variables
• type Config
  • func (config *Config) Sanitize() Config
• type ProtocolChain
• type ServiceContext

Constants

const (
	LogDir   = "crosslog"
	TxLogDir = "crosstxlog"
	DataDir  = "crossdata"
)

Variables

var (
	ErrVerifyCtx       = errors.New("verify ctx failed")
	ErrInvalidSignCtx  = fmt.Errorf("[%w]: verify signature failed", ErrVerifyCtx)
	ErrDuplicateSign   = fmt.Errorf("[%w]: signatures already exist", ErrVerifyCtx)
	ErrExpiredCtx      = fmt.Errorf("[%w]: ctx is expired", ErrVerifyCtx)
	ErrAlreadyExistCtx = fmt.Errorf("[%w]: ctx is already exist", ErrVerifyCtx)
	ErrLocalSignCtx    = fmt.Errorf("[%w]: remote ctx signed by local anchor", ErrVerifyCtx)
	ErrFinishedCtx     = fmt.Errorf("[%w]: ctx is already finished", ErrVerifyCtx)
	ErrReorgCtx        = fmt.Errorf("[%w]: ctx is on sidechain", ErrVerifyCtx)
	ErrInternal        = fmt.Errorf("[%w]: internal error", ErrVerifyCtx)
	ErrRepetitionCtx   = fmt.Errorf("[%w]: repetition cross transaction", ErrVerifyCtx) // 合约重复接单

)

var DefaultConfig = Config{
	SyncMode: synchronise.ALL,
}

Types

type Config

type Config struct {
	MainContract common.Address       `json:"mainContract"`
	SubContract  common.Address       `json:"subContract"`
	Signer       common.Address       `json:"signer"`
	Anchors      []common.Address     `json:"anchors"`
	SyncMode     synchronise.SyncMode `json:"syncMode"`
}

func (*Config) Sanitize

func (config *Config) Sanitize() Config

type ProtocolChain

type ProtocolChain interface {
	ChainID() *big.Int
	GenesisHash() common.Hash
	RegisterAPIs([]rpc.API) //TODO: 改成由backend自己注册API
}

type ServiceContext

type ServiceContext struct {
	Config        *Config
	ProtocolChain ProtocolChain
	Subscriber    trigger.Subscriber
	Retriever     trigger.ChainRetriever
	Executor      trigger.Executor
}