tunnel

Documentation

Index

• type Session
  • func NewSession(masterSecret []byte, sessionID string) *Session
  • func (s Session) Decrypt(blob []byte) ([]byte, error)
  • func (s Session) Encrypt(blob []byte) ([]byte, error)
• type Tunnel
  • func NewTunnel(session *Session, baseName *name.Name, downstream component.Component) *Tunnel
  • func (c *Tunnel) Inject(msg *messages.MessageWrapper)
  • func (c *Tunnel) Pop() *messages.MessageWrapper
  • func (c *Tunnel) ProcessEgressMessages()
  • func (c *Tunnel) ProcessIngressMessages()
  • func (c *Tunnel) Push(msg *messages.MessageWrapper)
• type TunnelComponent
  • func NewTunnelComponent(exitComponent component.Component) *TunnelComponent
  • func (c *TunnelComponent) AddSession(session *Session, baseName *name.Name)
  • func (c *TunnelComponent) Inject(msg *messages.MessageWrapper)
  • func (c *TunnelComponent) Pop() *messages.MessageWrapper
  • func (c *TunnelComponent) ProcessEgressMessages()
  • func (c *TunnelComponent) ProcessIngressMessages()
  • func (c *TunnelComponent) Push(msg *messages.MessageWrapper)

Types

type Session

type Session struct {
	SessionID string
	// contains filtered or unexported fields
}

func NewSession

func NewSession(masterSecret []byte, sessionID string) *Session

func (Session) Decrypt

func (s Session) Decrypt(blob []byte) ([]byte, error)

func (Session) Encrypt

func (s Session) Encrypt(blob []byte) ([]byte, error)

type Tunnel

type Tunnel struct {
	// contains filtered or unexported fields
}

func NewTunnel

func NewTunnel(session *Session, baseName *name.Name, downstream component.Component) *Tunnel

func (*Tunnel) Inject

func (c *Tunnel) Inject(msg *messages.MessageWrapper)

func (*Tunnel) Pop

func (c *Tunnel) Pop() *messages.MessageWrapper

func (*Tunnel) ProcessEgressMessages

func (c *Tunnel) ProcessEgressMessages()

func (*Tunnel) ProcessIngressMessages

func (c *Tunnel) ProcessIngressMessages()

func (*Tunnel) Push

func (c *Tunnel) Push(msg *messages.MessageWrapper)

type TunnelComponent

type TunnelComponent struct {
	// contains filtered or unexported fields
}

func NewTunnelComponent

func NewTunnelComponent(exitComponent component.Component) *TunnelComponent

func (*TunnelComponent) AddSession

func (c *TunnelComponent) AddSession(session *Session, baseName *name.Name)

func (*TunnelComponent) Inject

func (c *TunnelComponent) Inject(msg *messages.MessageWrapper)

func (*TunnelComponent) Pop

func (c *TunnelComponent) Pop() *messages.MessageWrapper

func (*TunnelComponent) ProcessEgressMessages

func (c *TunnelComponent) ProcessEgressMessages()

func (*TunnelComponent) ProcessIngressMessages

func (c *TunnelComponent) ProcessIngressMessages()

func (*TunnelComponent) Push

func (c *TunnelComponent) Push(msg *messages.MessageWrapper)