Documentation
¶
Index ¶
- Constants
- Variables
- func NewAcrossMessage(source, destination uint64, acrossData *AcrossData) *message.Message
- func NewMayanMessage(source, destination uint64, mayanData *MayanData) *message.Message
- func NewRhinestoneMessage(source, destination uint64, rhinestoneData *RhinestoneData) *message.Message
- type AcrossData
- type AcrossMessageHandler
- type BundleFetcher
- type ConfirmationWatcher
- type Coordinator
- type DepositFetcher
- type EventFilterer
- type MayanContract
- type MayanData
- type MayanMessageHandler
- type RhinestoneData
- type RhinestoneMessageHandler
- type SwapFetcher
- type TokenPricer
- type Watcher
Constants ¶
View Source
const ( AcrossMessage = "AcrossMessage" MayanMessage = "MayanMessage" DOMAIN_NAME = "LiquidityPool" VERSION = "1.0.0" TIMEOUT = 10 * time.Minute BLOCK_RANGE = 1000 )
View Source
const (
TRANSACTION_TIMEOUT = 30 * time.Second
)
Variables ¶
View Source
var (
BPS_DENOMINATOR = big.NewInt(10000)
)
Functions ¶
func NewAcrossMessage ¶
func NewAcrossMessage(source, destination uint64, acrossData *AcrossData) *message.Message
func NewMayanMessage ¶ added in v0.2.0
func NewRhinestoneMessage ¶ added in v0.3.0
func NewRhinestoneMessage(source, destination uint64, rhinestoneData *RhinestoneData) *message.Message
Types ¶
type AcrossData ¶
type AcrossMessageHandler ¶
type AcrossMessageHandler struct {
// contains filtered or unexported fields
}
func NewAcrossMessageHandler ¶
func NewAcrossMessageHandler( chainID uint64, pools map[uint64]common.Address, repayers map[uint64]common.Address, coordinator Coordinator, host host.Host, comm comm.Communication, fetcher signing.SaveDataFetcher, depositFetcher DepositFetcher, confirmationWatcher ConfirmationWatcher, sigChn chan any, ) *AcrossMessageHandler
func (*AcrossMessageHandler) HandleMessage ¶
HandleMessage finds the Across deposit with the according deposit ID and starts the MPC signature process for it. The result will be saved into the signature cache through the result channel.
func (*AcrossMessageHandler) Listen ¶
func (h *AcrossMessageHandler) Listen(ctx context.Context)
type BundleFetcher ¶ added in v0.3.0
type BundleFetcher interface {
GetBundle(bundleID string) (*rhinestone.Bundle, error)
}
type ConfirmationWatcher ¶ added in v0.2.0
type Coordinator ¶
type DepositFetcher ¶ added in v0.3.0
type EventFilterer ¶
type MayanContract ¶ added in v0.2.0
type MayanContract interface {
DecodeFulfillCall(calldata []byte) (*contracts.MayanFulfillParams, *contracts.MayanFulfillMsg, error)
GetOrder(
msg *contracts.MayanFulfillMsg,
swap *mayan.MayanSwap,
srcTokenDecimals uint8,
) (*contracts.MayanOrder, error)
}
type MayanMessageHandler ¶ added in v0.2.0
type MayanMessageHandler struct {
// contains filtered or unexported fields
}
func NewMayanMessageHandler ¶ added in v0.2.0
func NewMayanMessageHandler( chainID uint64, client EventFilterer, liquidityPools map[uint64]common.Address, mayanPools map[uint64]common.Address, coordinator Coordinator, host host.Host, comm comm.Communication, fetcher signing.SaveDataFetcher, confirmationWatcher ConfirmationWatcher, tokenStore config.TokenStore, mayanDecoder MayanContract, swapFetcher SwapFetcher, sigChn chan any, ) *MayanMessageHandler
func (*MayanMessageHandler) HandleMessage ¶ added in v0.2.0
HandleMessage finds the Mayan deposit with the according deposit ID and starts the MPC signature process for it. The result will be saved into the signature cache through the result channel.
func (*MayanMessageHandler) Listen ¶ added in v0.2.0
func (h *MayanMessageHandler) Listen(ctx context.Context)
type RhinestoneData ¶ added in v0.3.0
type RhinestoneMessageHandler ¶ added in v0.3.0
type RhinestoneMessageHandler struct {
// contains filtered or unexported fields
}
func NewRhinestoneMessageHandler ¶ added in v0.3.0
func NewRhinestoneMessageHandler( chainID uint64, coordinator Coordinator, host host.Host, comm comm.Communication, fetcher signing.SaveDataFetcher, tokenStore config.TokenStore, rhinestoneContract contracts.RhinestoneContract, bundleFetcher BundleFetcher, sigChn chan any, ) *RhinestoneMessageHandler
func (*RhinestoneMessageHandler) HandleMessage ¶ added in v0.3.0
HandleMessage verifies the bundle data and signs the unlock hash to use liquidity for the Rhinestone protocol
func (*RhinestoneMessageHandler) Listen ¶ added in v0.3.0
func (h *RhinestoneMessageHandler) Listen(ctx context.Context)
type SwapFetcher ¶ added in v0.2.0
type TokenPricer ¶
type Watcher ¶ added in v0.2.0
type Watcher struct {
// contains filtered or unexported fields
}
func NewWatcher ¶ added in v0.2.0
func NewWatcher( client EventFilterer, tokenPricer TokenPricer, tokenStore config.TokenStore, confirmations map[uint64]uint64, blocktime time.Duration, ) *Watcher
Click to show internal directories.
Click to hide internal directories.