swap

Documentation

Index

• Constants
• type SwapOption
  • func DefaultOptions() []SwapOption
  • func WithMode(mode int) SwapOption
  • func WithThreshold(payment, disconnect int) SwapOption
• type SwapParameters
• type WakuSwap
  • func NewWakuSwap(log *zap.Logger, opts ...SwapOption) *WakuSwap
  • func (s *WakuSwap) Credit(peerId string, n int)
  • func (s *WakuSwap) Debit(peerId string, n int)
  • func (s *WakuSwap) IsStarted() bool
  • func (s *WakuSwap) Start(ctx context.Context) error
  • func (s *WakuSwap) Stop()

Constants

const (
	SoftMode int = 0
	MockMode int = 1
	HardMode int = 2
)

const WakuSwapID_v200 = protocol.ID("/vac/waku/swap/2.0.0-beta1")

Types

type SwapOption

type SwapOption func(*SwapParameters)

func DefaultOptions

func DefaultOptions() []SwapOption

func WithMode

func WithMode(mode int) SwapOption

func WithThreshold

func WithThreshold(payment, disconnect int) SwapOption

type SwapParameters

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

type WakuSwap

type WakuSwap struct {
	Accounting map[string]int
	// contains filtered or unexported fields
}

func NewWakuSwap

func NewWakuSwap(log *zap.Logger, opts ...SwapOption) *WakuSwap

func (*WakuSwap) Credit

func (s *WakuSwap) Credit(peerId string, n int)

func (*WakuSwap) Debit

func (s *WakuSwap) Debit(peerId string, n int)

func (*WakuSwap) IsStarted

func (s *WakuSwap) IsStarted() bool

func (*WakuSwap) Start

func (s *WakuSwap) Start(ctx context.Context) error

func (*WakuSwap) Stop

func (s *WakuSwap) Stop()