rendezvous

Documentation

Index

• Constants
• type IncomingRendezvousNexus
  • func NewIncomingRendezvousNexus(belowNexus nexus.Nexus, layer layer.Layer, directory *RendezvousDirectory) *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(nexus2 nexus.Nexus))
• type RendezvousDirectory
  • func NewRendezvousDirectory() *RendezvousDirectory
  • func (r *RendezvousDirectory) AddNexus(nexus nexusHelper.Nexus, rendezvousId string)
  • func (r *RendezvousDirectory) GetPeerNexus(nexusId uuid.UUID) *nexusHelper.Nexus
  • func (r *RendezvousDirectory) IsNexusInDirectory(nexus nexusHelper.Nexus) bool
  • func (r *RendezvousDirectory) IsRidPeered(rendezvousId string) bool
  • func (r *RendezvousDirectory) RemoveNexus(nexus nexusHelper.Nexus)

Constants

const IncomingRendezvousNexusName = "IncomingRendezvousNexus"

const OutgoingRendezvousNexusName = "OutgoingRendezvousNexus"

Types

type IncomingRendezvousNexus

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

func NewIncomingRendezvousNexus

func NewIncomingRendezvousNexus(belowNexus nexus.Nexus, layer layer.Layer, directory *RendezvousDirectory) *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.BaseNexus
	// 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(nexus2 nexus.Nexus))

type RendezvousDirectory

type RendezvousDirectory struct {

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

func NewRendezvousDirectory

func NewRendezvousDirectory() *RendezvousDirectory

func (*RendezvousDirectory) AddNexus

func (r *RendezvousDirectory) AddNexus(nexus nexusHelper.Nexus, rendezvousId string)

add and index a nexus

func (*RendezvousDirectory) GetPeerNexus

func (r *RendezvousDirectory) GetPeerNexus(nexusId uuid.UUID) *nexusHelper.Nexus

get matching peer of a given nexus (1:1 mappnig)

func (*RendezvousDirectory) IsNexusInDirectory

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

wether or not nexus is indexed in directory

func (*RendezvousDirectory) IsRidPeered

func (r *RendezvousDirectory) IsRidPeered(rendezvousId string) bool

check if a rendezvous id currently has a peer

func (*RendezvousDirectory) RemoveNexus

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

remove a nexus from the directory