swapper

Documentation

Index

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

Functions

func New

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

func NewSwapper

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

Types

type Bootload

type Bootload struct {
	Password string
}

func (Bootload) IsMessage

func (Bootload) IsMessage()

type ReceiptUpdate

type ReceiptUpdate swap.ReceiptUpdate

func (ReceiptUpdate) IsMessage

func (ReceiptUpdate) IsMessage()

type Storage

type Storage interface {
	LoadCosts(id swap.SwapID) (blockchain.Cost, blockchain.Cost)
	PutSwap(blob swap.SwapBlob) error
	DeletePendingSwap(swap.SwapID) error
	PendingSwaps() ([]swap.SwapBlob, error)
}

type SwapRequest

type SwapRequest swap.SwapBlob

func (SwapRequest) IsMessage

func (SwapRequest) IsMessage()