rendezvous

Documentation

Index

• type IncomingRendezvousLayer
  • func NewIncomingRendezvousLayer() *IncomingRendezvousLayer
  • func (o *IncomingRendezvousLayer) AnnounceNexus(belowNexus nexus.Nexus)
  • func (o *IncomingRendezvousLayer) GetPeerNexus(rendezvousNexus nexus.Nexus) *nexus.Nexus
  • func (o *IncomingRendezvousLayer) RegisterAboveLayer(belowLayer layer.Layer)
  • func (o *IncomingRendezvousLayer) RendezvousFinishedCb(rendezvousNexus nexus.Nexus)
  • func (o *IncomingRendezvousLayer) RevokeNexus(belowNexus nexus.Nexus)
  • func (o *IncomingRendezvousLayer) ToString() string
• type OutgoingRendezvousLayer
  • func NewOutgoingRendezvousLayer() *OutgoingRendezvousLayer
  • func (o *OutgoingRendezvousLayer) AnnounceNexus(belowNexus nexus.Nexus)
  • func (o *OutgoingRendezvousLayer) RegisterAboveLayer(belowLayer layer.Layer)
  • func (o *OutgoingRendezvousLayer) RendezvousFinishedCb(rendzvousNexus nexus.Nexus)

Types

type IncomingRendezvousLayer

type IncomingRendezvousLayer struct {
	*layer.BaseLayer
	// contains filtered or unexported fields
}

IncomingRendezvousLayer is responsible for managing rendezvous' between peernexuses

func NewIncomingRendezvousLayer

func NewIncomingRendezvousLayer() *IncomingRendezvousLayer

NewIncomingRendezvousLayer creates an IncomingRendezvousLayer

func (*IncomingRendezvousLayer) AnnounceNexus

func (o *IncomingRendezvousLayer) AnnounceNexus(belowNexus nexus.Nexus)

AnnounceNexus creates a new rendezvous.IncomingRendezvousNexus and registers it

func (*IncomingRendezvousLayer) GetPeerNexus

func (o *IncomingRendezvousLayer) GetPeerNexus(rendezvousNexus nexus.Nexus) *nexus.Nexus

GetPeerNexus is the gets the peered nexus from the directory for a nexus (using uuid)

func (*IncomingRendezvousLayer) RegisterAboveLayer

func (o *IncomingRendezvousLayer) RegisterAboveLayer(belowLayer layer.Layer)

RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below layer

func (*IncomingRendezvousLayer) RendezvousFinishedCb

func (o *IncomingRendezvousLayer) RendezvousFinishedCb(rendezvousNexus nexus.Nexus)

RendezvousFinishedCb is the callback for after a rendezvous is finished

func (*IncomingRendezvousLayer) RevokeNexus

func (o *IncomingRendezvousLayer) RevokeNexus(belowNexus nexus.Nexus)

RevokeNexus removes the nexus from directories/layers

func (*IncomingRendezvousLayer) ToString

func (o *IncomingRendezvousLayer) ToString() string

type OutgoingRendezvousLayer

type OutgoingRendezvousLayer struct {
	layer.BaseLayer
}

TODO this needs to be fully implemented

func NewOutgoingRendezvousLayer

func NewOutgoingRendezvousLayer() *OutgoingRendezvousLayer

func (*OutgoingRendezvousLayer) AnnounceNexus

func (o *OutgoingRendezvousLayer) AnnounceNexus(belowNexus nexus.Nexus)

AnnounceNexus creates a new rendezvous.OutgoingRendezvousNexus and registers it a rendezvous is started and if completed OutgoingRendezvousLayer.RendezvousFinishedCb is called

func (*OutgoingRendezvousLayer) RegisterAboveLayer

func (o *OutgoingRendezvousLayer) RegisterAboveLayer(belowLayer layer.Layer)

RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below layer

func (*OutgoingRendezvousLayer) RendezvousFinishedCb

func (o *OutgoingRendezvousLayer) RendezvousFinishedCb(rendzvousNexus nexus.Nexus)