local

Documentation

Index

• Constants
• type IncomingLocalNexus
  • func NewIncomingLocalNexus(belowNexus *JoinedLocalNexus, layer layer.Base) *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 (j *JoinedLocalNexus) InitiateClose()
  • func (j *JoinedLocalNexus) SendBinFromIncoming(msg []byte)
  • func (j *JoinedLocalNexus) SendFromIncoming(msg base2.MoneysocketMessage)
  • func (j *JoinedLocalNexus) SendFromOutgoing(msg base2.MoneysocketMessage)
  • func (j *JoinedLocalNexus) SetIncomingNexus(incomingNexus compat.RevokableNexus)
  • func (j *JoinedLocalNexus) SetOutgoingNexus(outgoingNexus compat.RevokableNexus)
• type Nexus
  • func NewLocalNexus(belowNexus nexus.Nexus, layer layer.Base) *Nexus
  • func (l *Nexus) OnMessage(belowNexus nexus.Nexus, msg base_moneysocket.MoneysocketMessage)
  • func (l *Nexus) SendBin(msg []byte) error
• type OutgoingLocalNexus
  • func NewOutgoingLocalNexus(belowNexus *JoinedLocalNexus, layer layer.Base, 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"

IncomingLocalNexusName handles nexuses.

const JoinedLocalNexusName = "JoinedLocalNexus"

JoinedLocalNexusName is a joined local nexus.

const LocalNexusName = "LocalNexusName"

LocalNexusName is a local nexus.

const OutgoingLocalNexusName = "OutgoingLocalNexus"

OutgoingLocalNexusName is the name of an outgoing local enxus.

Types

type IncomingLocalNexus

type IncomingLocalNexus struct {
	*base.NexusBase
}

IncomingLocalNexus is the local nexus.

func NewIncomingLocalNexus

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

NewIncomingLocalNexus creates an incoming local nexus.

func (*IncomingLocalNexus) OnBinMessage

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

OnBinMessage processes a binary message.

func (*IncomingLocalNexus) OnMessage

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

OnMessage processes a message.

func (*IncomingLocalNexus) RevokeFromLayer

func (i *IncomingLocalNexus) RevokeFromLayer()

RevokeFromLayer revokes a layer from a message.

func (*IncomingLocalNexus) Send

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

Send sends a message.

type JoinedLocalNexus

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

JoinedLocalNexus is a joined local nexus.

func NewJoinedLocalNexus

func NewJoinedLocalNexus() *JoinedLocalNexus

NewJoinedLocalNexus sets an incoming nexus.

func (*JoinedLocalNexus) InitiateClose

func (j *JoinedLocalNexus) InitiateClose()

InitiateClose initiates a close w/ the incoming/outgoing nexus.

func (*JoinedLocalNexus) SendBinFromIncoming

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

SendBinFromIncoming sends a binary message.

func (*JoinedLocalNexus) SendFromIncoming

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

SendFromIncoming sends a message from an incoming nexus.

func (*JoinedLocalNexus) SendFromOutgoing

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

SendFromOutgoing sends a message from an outgoing message.

func (*JoinedLocalNexus) SetIncomingNexus

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

SetIncomingNexus sets the incoming nexus.

func (*JoinedLocalNexus) SetOutgoingNexus

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

SetOutgoingNexus sets the outgoing nexus.

type Nexus

type Nexus struct {
	*base.NexusBase
}

Nexus is a local nexus.

func NewLocalNexus

func NewLocalNexus(belowNexus nexus.Nexus, layer layer.Base) *Nexus

NewLocalNexus creates a new local nexus.

func (*Nexus) OnMessage

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

OnMessage processes a message.

func (*Nexus) SendBin

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

SendBin sends a binary message.

type OutgoingLocalNexus

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

OutgoingLocalNexus is an outgoing local nexus.

func NewOutgoingLocalNexus

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

NewOutgoingLocalNexus creates an outgoing local nexus.

func (OutgoingLocalNexus) OnBinMessage

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

OnBinMessage processes a mmessage after it's sent.

func (*OutgoingLocalNexus) OnMessage

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

OnMessage processes messages for this layer.

func (*OutgoingLocalNexus) RevokeFromLayer

func (o *OutgoingLocalNexus) RevokeFromLayer()

RevokeFromLayer revokes a message from the layer.

func (OutgoingLocalNexus) Send

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

Send gets the message from a nexus.

func (OutgoingLocalNexus) SharedSeed

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

SharedSeed gets the shared seed.