rtunnels

Documentation

Index

• Variables
• func AddRTunnel(tun *RTunnel)
• func RemoveRTunnel(ID uint64)
• type RTunnel
  • func GetRTunnel(ID uint64) *RTunnel
  • func NewRTunnel(id uint64, sID string, writer io.WriteCloser, readers ...io.ReadCloser) *RTunnel
  • func (c *RTunnel) Close()
  • func (c *RTunnel) IncReadSequence()
  • func (c *RTunnel) IncWriteSequence()
  • func (c *RTunnel) ReadSequence() uint64
  • func (c *RTunnel) WriteSequence() uint64

Variables

var (
	Rtunnels map[uint64]*RTunnel = make(map[uint64]*RTunnel)
)

Functions

func AddRTunnel

func AddRTunnel(tun *RTunnel)

AddTunnel - Add tunnel to mapping

func RemoveRTunnel

func RemoveRTunnel(ID uint64)

RemoveTunnel - Add tunnel to mapping

Types

type RTunnel

type RTunnel struct {
	ID        uint64
	SessionID string
	// Reader       io.ReadCloser
	Readers []io.ReadCloser

	Writer io.WriteCloser
	// contains filtered or unexported fields
}

RTunnel - Duplex byte read/write

func GetRTunnel

func GetRTunnel(ID uint64) *RTunnel

Tunnel - Add tunnel to mapping

func NewRTunnel

func NewRTunnel(id uint64, sID string, writer io.WriteCloser, readers ...io.ReadCloser) *RTunnel

func (*RTunnel) Close

func (c *RTunnel) Close()

Close - close RTunnel reader and writer

func (*RTunnel) IncReadSequence

func (c *RTunnel) IncReadSequence()

func (*RTunnel) IncWriteSequence

func (c *RTunnel) IncWriteSequence()

func (*RTunnel) ReadSequence

func (c *RTunnel) ReadSequence() uint64

func (*RTunnel) WriteSequence

func (c *RTunnel) WriteSequence() uint64