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.Base)
  • 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.Base)
  • 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.Base)

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

ToString converts a directory to a string.

type OutgoingRendezvousLayer

type OutgoingRendezvousLayer struct {
	layer.BaseLayer
}

OutgoingRendezvousLayer handles outoging rendezvous TODO this needs to be fully implemented.

func NewOutgoingRendezvousLayer

func NewOutgoingRendezvousLayer() *OutgoingRendezvousLayer

NewOutgoingRendezvousLayer is the outgoing rendezvous layer.

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.Base)

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

func (*OutgoingRendezvousLayer) RendezvousFinishedCb

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

RendezvousFinishedCb is the callback for when a rendezvous is finished.