provider

Documentation

Index

• Constants
• type Nexus
  • func NewProviderNexus(belowNexus nexus.Nexus) *Nexus
  • func (o *Nexus) IsLayerMessage(message message_base.MoneysocketMessage) bool
  • func (o *Nexus) NotifyPong()
  • func (o *Nexus) NotifyProvider()
  • func (o *Nexus) NotifyProviderNotReady()
  • func (o *Nexus) NotifyProviderReady()
  • func (o *Nexus) OnBinMessage(belowNexus nexus.Nexus, msg []byte)
  • func (o *Nexus) OnMessage(belowNexus nexus.Nexus, msg message_base.MoneysocketMessage)
  • func (o *Nexus) ProviderNowReady()
  • func (o *Nexus) WaitForConsumer(providerFinishedCb func(nexus2 nexus.Nexus))
• type TransactNexus
  • func NewProviderTransactNexus(belowNexus nexus.Nexus, layer layer.Layer) *TransactNexus
  • func (p *TransactNexus) HandleLayerRequest(req request.MoneysocketRequest)
  • func (p *TransactNexus) IsLayerMessage(message msg.MoneysocketMessage) bool
  • func (p *TransactNexus) NotifyInvoice(bolt11, requestReferenceUUID string) error
  • func (p *TransactNexus) NotifyPreimage(preimage, requestReferenceUUID string) error
  • func (p *TransactNexus) NotifyProviderInfo(seed beacon.SharedSeed) error
  • func (p *TransactNexus) OnBinMessage(baseNexus nexus.Nexus, msg []byte)
  • func (p *TransactNexus) OnMessage(belowNexus nexus.Nexus, message msg.MoneysocketMessage)

Constants

const NexusName = "ProviderNexus"

const TransactNexusName = "ProviderTransactNexus"

Types

type Nexus

type Nexus struct {
	*base.NexusBase
	RequestReferenceUUID string

	ProviderFinishedCb func(nx nexus.Nexus)
	// contains filtered or unexported fields
}

func NewProviderNexus

func NewProviderNexus(belowNexus nexus.Nexus) *Nexus

func (*Nexus) IsLayerMessage

func (o *Nexus) IsLayerMessage(message message_base.MoneysocketMessage) bool

func (*Nexus) NotifyPong

func (o *Nexus) NotifyPong()

func (*Nexus) NotifyProvider

func (o *Nexus) NotifyProvider()

func (*Nexus) NotifyProviderNotReady

func (o *Nexus) NotifyProviderNotReady()

func (*Nexus) NotifyProviderReady

func (o *Nexus) NotifyProviderReady()

func (*Nexus) OnBinMessage

func (o *Nexus) OnBinMessage(belowNexus nexus.Nexus, msg []byte)

func (*Nexus) OnMessage

func (o *Nexus) OnMessage(belowNexus nexus.Nexus, msg message_base.MoneysocketMessage)

func (*Nexus) ProviderNowReady

func (o *Nexus) ProviderNowReady()

func (*Nexus) WaitForConsumer

func (o *Nexus) WaitForConsumer(providerFinishedCb func(nexus2 nexus.Nexus))

type TransactNexus

type TransactNexus struct {
	*base.NexusBase
	HandleInvoiceRequest compat.HandleInvoiceRequest
	HandlePayRequest     compat.HandlePayRequest
}

func NewProviderTransactNexus

func NewProviderTransactNexus(belowNexus nexus.Nexus, layer layer.Layer) *TransactNexus

func (*TransactNexus) HandleLayerRequest

func (p *TransactNexus) HandleLayerRequest(req request.MoneysocketRequest)

handle layer request

func (*TransactNexus) IsLayerMessage

func (p *TransactNexus) IsLayerMessage(message msg.MoneysocketMessage) bool

func (*TransactNexus) NotifyInvoice

func (p *TransactNexus) NotifyInvoice(bolt11, requestReferenceUUID string) error

func (*TransactNexus) NotifyPreimage

func (p *TransactNexus) NotifyPreimage(preimage, requestReferenceUUID string) error

func (*TransactNexus) NotifyProviderInfo

func (p *TransactNexus) NotifyProviderInfo(seed beacon.SharedSeed) error

func (*TransactNexus) OnBinMessage

func (p *TransactNexus) OnBinMessage(baseNexus nexus.Nexus, msg []byte)

func (*TransactNexus) OnMessage

func (p *TransactNexus) OnMessage(belowNexus nexus.Nexus, message msg.MoneysocketMessage)