rendezvous

Documentation

Index

• Constants
• type Directory
  • func NewRendezvousDirectory() *Directory
  • func (r *Directory) AddNexus(nexus nexusHelper.Nexus, rendezvousID string)
  • func (r *Directory) GetPeerNexus(nexusID uuid.UUID) *nexusHelper.Nexus
  • func (r *Directory) IsNexusInDirectory(nexus nexusHelper.Nexus) bool
  • func (r *Directory) IsRidPeered(rendezvousID string) bool
  • func (r *Directory) RemoveNexus(nexus nexusHelper.Nexus)
  • func (r *Directory) ToString() string
• type IncomingRendezvousNexus
  • func NewIncomingRendezvousNexus(belowNexus nexus.Nexus, layer layer.Layer, directory *Directory) *IncomingRendezvousNexus
  • func (i *IncomingRendezvousNexus) EndRendezvous()
  • func (i *IncomingRendezvousNexus) IsLayerMessage(msg message_base.MoneysocketMessage) bool
  • func (i *IncomingRendezvousNexus) OnBinMessage(belowNexus nexus.Nexus, msgByte []byte)
  • func (i *IncomingRendezvousNexus) OnMessage(belowNexus nexus.Nexus, msg message_base.MoneysocketMessage)
  • func (i *IncomingRendezvousNexus) RendezvousAcheived()
  • func (i *IncomingRendezvousNexus) WaitForRendezvous(rendezvousFinishedCb func(nexus.Nexus))
• type OutgoingRendezvousNexus
  • func NewOutgoingRendezvousNexus(belowNexus nexus.Nexus, layer layer.Layer) *OutgoingRendezvousNexus
  • func (o OutgoingRendezvousNexus) IsLayerMessage(msg message_base.MoneysocketMessage) bool
  • func (o *OutgoingRendezvousNexus) OnBinMessage(belowNexus nexus.Nexus, msg []byte)
  • func (o *OutgoingRendezvousNexus) OnMessage(belowNexus nexus.Nexus, msg message_base.MoneysocketMessage)
  • func (o *OutgoingRendezvousNexus) StartRendezvous(rendevousID string, rendezvousFinishedCb func(nexus nexus.Nexus))

Constants

const IncomingRendezvousNexusName = "IncomingRendezvousNexus"

const OutgoingRendezvousNexusName = "OutgoingRendezvousNexus"

Types

type Directory

type Directory struct {

	// NexusesByUUID is a map from uuid to corresponding nexus
	NexusesByUUID map[string]nexusHelper.Nexus
	// RidsByUUIDs is a map from nexus uuid to corresponding rendezvous id
	RidsByUUIDs map[string]string
	// UnpeeredUUIDsByRid is a map of uuids that are currently unpaired sorted by rendezvous id
	UnpeeredUUIDsByRid map[string]string
	// UUIDPeers is a map of nexus to the uuid of the corresponding peer
	UUIDPeers map[string]string
	// RIDSPeered is a list of rids which are currently peered
	RIDSPeered []string
	// contains filtered or unexported fields
}

RendezvousDirectory stores nexus peering data

func NewRendezvousDirectory

func NewRendezvousDirectory() *Directory

NewRendezvousDirectory creates a new RendezvousDirectory

func (*Directory) AddNexus

func (r *Directory) AddNexus(nexus nexusHelper.Nexus, rendezvousID string)

AddNexus adds and indexes a nexus

func (*Directory) GetPeerNexus

func (r *Directory) GetPeerNexus(nexusID uuid.UUID) *nexusHelper.Nexus

GetPeerNexus get matching peer of a given nexus (1:1 mapping)

func (*Directory) IsNexusInDirectory

func (r *Directory) IsNexusInDirectory(nexus nexusHelper.Nexus) bool

IsNexusInDirectory determines wether or not nexus is indexed in directory

func (*Directory) IsRidPeered

func (r *Directory) IsRidPeered(rendezvousID string) bool

IsRidPeered checks if a rendezvous id currently has a peer

func (*Directory) RemoveNexus

func (r *Directory) RemoveNexus(nexus nexusHelper.Nexus)

RemoveNexus removes a nexus from the directory

func (*Directory) ToString

func (r *Directory) ToString() string

ToString gets the number of nexuses/peered/unpeered

type IncomingRendezvousNexus

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

func NewIncomingRendezvousNexus

func NewIncomingRendezvousNexus(belowNexus nexus.Nexus, layer layer.Layer, directory *Directory) *IncomingRendezvousNexus

func (*IncomingRendezvousNexus) EndRendezvous

func (i *IncomingRendezvousNexus) EndRendezvous()

func (*IncomingRendezvousNexus) IsLayerMessage

func (i *IncomingRendezvousNexus) IsLayerMessage(msg message_base.MoneysocketMessage) bool

func (*IncomingRendezvousNexus) OnBinMessage

func (i *IncomingRendezvousNexus) OnBinMessage(belowNexus nexus.Nexus, msgByte []byte)

func (*IncomingRendezvousNexus) OnMessage

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

func (*IncomingRendezvousNexus) RendezvousAcheived

func (i *IncomingRendezvousNexus) RendezvousAcheived()

called by other peer

func (*IncomingRendezvousNexus) WaitForRendezvous

func (i *IncomingRendezvousNexus) WaitForRendezvous(rendezvousFinishedCb func(nexus.Nexus))

type OutgoingRendezvousNexus

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

func NewOutgoingRendezvousNexus

func NewOutgoingRendezvousNexus(belowNexus nexus.Nexus, layer layer.Layer) *OutgoingRendezvousNexus

func (OutgoingRendezvousNexus) IsLayerMessage

func (o OutgoingRendezvousNexus) IsLayerMessage(msg message_base.MoneysocketMessage) bool

func (*OutgoingRendezvousNexus) OnBinMessage

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

func (*OutgoingRendezvousNexus) OnMessage

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

func (*OutgoingRendezvousNexus) StartRendezvous

func (o *OutgoingRendezvousNexus) StartRendezvous(rendevousID string, rendezvousFinishedCb func(nexus nexus.Nexus))