local

Documentation

Index

• Constants
• type IncomingLocalNexus
  • func NewIncomingLocalNexus(belowNexus *JoinedLocalNexus, layer layer.Layer) *IncomingLocalNexus
  • func (i *IncomingLocalNexus) OnBinMessage(belowNexus nexus.Nexus, msgBytes []byte)
  • func (i *IncomingLocalNexus) OnMessage(belowNexus nexus.Nexus, msg moneysocket_message.MoneysocketMessage)
  • func (i *IncomingLocalNexus) RevokeFromLayer()
  • func (i *IncomingLocalNexus) Send(msg moneysocket_message.MoneysocketMessage) error
• type JoinedLocalNexus
  • func NewJoinedLocalNexus() *JoinedLocalNexus
  • func (n *JoinedLocalNexus) InitiateClose()
  • func (j *JoinedLocalNexus) SendBinFromIncoming(msg []byte)
  • func (j *JoinedLocalNexus) SendFromIncoming(msg base2.MoneysocketMessage)
  • func (j *JoinedLocalNexus) SendFromOutgoing(msg base2.MoneysocketMessage)
  • func (n *JoinedLocalNexus) SetIncomingNexus(incomingNexus compat.RevokableNexus)
  • func (n *JoinedLocalNexus) SetOutgoingNexus(outgoingNexus compat.RevokableNexus)
• type LocalNexus
  • func NewLocalNexus(belowNexus nexus.Nexus, layer layer.Layer) *LocalNexus
  • func (l *LocalNexus) OnMessage(belowNexus nexus.Nexus, msg base_moneysocket.MoneysocketMessage)
  • func (l *LocalNexus) SendBin(msg []byte) error
• type OutgoingLocalNexus
  • func NewOutgoingLocalNexus(belowNexus *JoinedLocalNexus, layer layer.Layer, sharedSeed beacon.SharedSeed) *OutgoingLocalNexus
  • func (o OutgoingLocalNexus) OnBinMessage(belowNexus nexus.Nexus, msg []byte)
  • func (o *OutgoingLocalNexus) OnMessage(belowNexus nexus.Nexus, msg base_moneysocket.MoneysocketMessage)
  • func (o *OutgoingLocalNexus) RevokeFromLayer()
  • func (o OutgoingLocalNexus) Send(msg base_moneysocket.MoneysocketMessage) error
  • func (o OutgoingLocalNexus) SharedSeed() *beacon.SharedSeed

Constants

const IncomingLocalNexusName = "IncomingLocalNexus"

const JoinedLocalNexusName = "JoinedLocalNexus"

const LocalNexusName = "LocalNexusName"

const OutgoingLocalNexusName = "OutgoingLocalNexus"

Types

type IncomingLocalNexus

type IncomingLocalNexus struct {
	*base.BaseNexus
	// contains filtered or unexported fields
}

func NewIncomingLocalNexus

func NewIncomingLocalNexus(belowNexus *JoinedLocalNexus, layer layer.Layer) *IncomingLocalNexus

func (*IncomingLocalNexus) OnBinMessage

func (i *IncomingLocalNexus) OnBinMessage(belowNexus nexus.Nexus, msgBytes []byte)

func (*IncomingLocalNexus) OnMessage

func (i *IncomingLocalNexus) OnMessage(belowNexus nexus.Nexus, msg moneysocket_message.MoneysocketMessage)

func (*IncomingLocalNexus) RevokeFromLayer

func (i *IncomingLocalNexus) RevokeFromLayer()

func (*IncomingLocalNexus) Send

func (i *IncomingLocalNexus) Send(msg moneysocket_message.MoneysocketMessage) error

type JoinedLocalNexus

type JoinedLocalNexus struct {
	*base.BaseNexus
	// contains filtered or unexported fields
}

func NewJoinedLocalNexus

func NewJoinedLocalNexus() *JoinedLocalNexus

func (*JoinedLocalNexus) InitiateClose

func (n *JoinedLocalNexus) InitiateClose()

func (*JoinedLocalNexus) SendBinFromIncoming

func (j *JoinedLocalNexus) SendBinFromIncoming(msg []byte)

func (*JoinedLocalNexus) SendFromIncoming

func (j *JoinedLocalNexus) SendFromIncoming(msg base2.MoneysocketMessage)

func (*JoinedLocalNexus) SendFromOutgoing

func (j *JoinedLocalNexus) SendFromOutgoing(msg base2.MoneysocketMessage)

func (*JoinedLocalNexus) SetIncomingNexus

func (n *JoinedLocalNexus) SetIncomingNexus(incomingNexus compat.RevokableNexus)

func (*JoinedLocalNexus) SetOutgoingNexus

func (n *JoinedLocalNexus) SetOutgoingNexus(outgoingNexus compat.RevokableNexus)

type LocalNexus

type LocalNexus struct {
	*base.BaseNexus
}

func NewLocalNexus

func NewLocalNexus(belowNexus nexus.Nexus, layer layer.Layer) *LocalNexus

func (*LocalNexus) OnMessage

func (l *LocalNexus) OnMessage(belowNexus nexus.Nexus, msg base_moneysocket.MoneysocketMessage)

func (*LocalNexus) SendBin

func (l *LocalNexus) SendBin(msg []byte) error

type OutgoingLocalNexus

type OutgoingLocalNexus struct {
	*base.BaseNexus
	// contains filtered or unexported fields
}

func NewOutgoingLocalNexus

func NewOutgoingLocalNexus(belowNexus *JoinedLocalNexus, layer layer.Layer, sharedSeed beacon.SharedSeed) *OutgoingLocalNexus

func (OutgoingLocalNexus) OnBinMessage

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

func (*OutgoingLocalNexus) OnMessage

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

func (*OutgoingLocalNexus) RevokeFromLayer

func (o *OutgoingLocalNexus) RevokeFromLayer()

func (OutgoingLocalNexus) Send

func (o OutgoingLocalNexus) Send(msg base_moneysocket.MoneysocketMessage) error

func (OutgoingLocalNexus) SharedSeed

func (o OutgoingLocalNexus) SharedSeed() *beacon.SharedSeed