swapper

package

v1.0.0-beta Latest Latest Go to latest Published: Jan 30, 2019 License: GPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/republicprotocol/swapperd

Links

Open Source Insights

Documentation ¶

Index ¶

func New(cap int, storage Storage, builder immediate.ContractBuilder, ...) tau.Task
func NewSwapper(delayedSwapperTask, immediateSwapperTask, statusTask tau.Task, storage Storage) tau.Reducer
type Bootload
- func (Bootload) IsMessage()
type Storage
type SwapRequest
- func (SwapRequest) IsMessage()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(cap int, storage Storage, builder immediate.ContractBuilder, callback delayed.DelayCallback) tau.Task

func NewSwapper ¶

func NewSwapper(delayedSwapperTask, immediateSwapperTask, statusTask tau.Task, storage Storage) tau.Reducer

Types ¶

type Bootload ¶

type Bootload struct {
	Password string
}

func (Bootload) IsMessage ¶

func (Bootload) IsMessage()

type Storage ¶

type Storage interface {
	LoadCosts(id swap.SwapID) (blockchain.Cost, blockchain.Cost)
	Receipts() ([]swap.SwapReceipt, error)
	PutReceipt(receipt swap.SwapReceipt) error

	PutSwap(blob swap.SwapBlob) error
	DeletePendingSwap(swap.SwapID) error
	PendingSwaps() ([]swap.SwapBlob, error)
	UpdateReceipt(receiptUpdate swap.ReceiptUpdate) error
}

type SwapRequest ¶

type SwapRequest swap.SwapBlob

func (SwapRequest) IsMessage ¶

func (SwapRequest) IsMessage()

Source Files ¶

View all Source files

swapper.go

Directories ¶

Path	Synopsis
delayed
immediate
status

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL