event

type BTCData struct {
	BTCNodeAddress   string
	BTCRPCPort       string
	BTCRPCUsername   string
	BTCRPCPassword   string
	BTCChainnet      string
	BlockCypherToken string
}

type BroadcastReply struct {
	TxHash action.Address `json:"txHash"`
	// OK indicates whether this broadcast was a request.
	// For TxSync, it indicates success of CheckTx. Does not guarantee inclusion of a block
	// For TxAsync, it always returns true
	// For TxCommit, it indicates the success of both CheckTx and DeliverTx. If the broadcast fails is false.
	OK     bool   `json:"ok"`
	Height *int64 `json:"height,omitempty"`
	Log    string `json:"log"`
}

type InternalBroadcastRequest struct {
	RawTx action.RawTx `json:"rawTx"`
}

type JobAddSignature struct {
	Type string

	TrackerName string

	JobID string

	Status jobs.Status
}

type JobBTCBroadcast struct {
	Type string

	TrackerName string

	JobID string

	Status jobs.Status

	RetryCount int
}

type JobBTCCheckFinality struct {
	Type string

	TrackerName string
	JobID       string
	CheckAfter  int64

	Status jobs.Status
}

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

type JobETHBroadcast struct {
	TrackerName ethereum.TrackerName
	JobID       string
	RetryCount  int
	Status      jobs.Status
}

type JobETHCheckFinality struct {
	TrackerName ethereum.TrackerName
	JobID       string
	RetryCount  int
	Status      jobs.Status
}

type JobETHSignRedeem struct {
	TrackerName ethereum.TrackerName
	JobID       string
	RetryCount  int
	Status      jobs.Status
	TxHash      *ethereum.TransactionHash
}

type JobETHVerifyRedeem struct {
	TrackerName ethereum.TrackerName
	JobID       string
	RetryCount  int
	Status      jobs.Status
}

type JobProcess func(job jobs.Job) jobs.Job

type JobsContext struct {
	Service *Service
	Logger  *log.Logger

	Trackers   *bitcoin.TrackerStore
	Validators *identity.ValidatorStore

	BTCPrivKey *keys.PrivateKey
	ETHPrivKey *keys.PrivateKey
	BTCParams  *chaincfg.Params

	ValidatorAddress action.Address
	LockScripts      *bitcoin.LockScriptStore
	EthereumTrackers *ethereum.TrackerStore

	BTCData BTCData
	// contains filtered or unexported fields
}

type Option struct {
	BtcInterval time.Duration
	EthInterval time.Duration
}

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