tunnel

Documentation

Overview

Package tunnel implements the tunneling logic for copying data between two network connections both sides.

Index

• Constants
• func Tunnel(pipeName string, left io.ReadWriter, right io.ReadWriter)
• type MsgReadWriter
  • func NewMsgReadWriter(base io.ReadWriter) (rw *MsgReadWriter)
  • func (rw *MsgReadWriter) Read(b []byte) (n int, err error)
  • func (rw *MsgReadWriter) Write(b []byte) (n int, err error)

Constants

const MaxMessageLength = 1320

MaxMessageLength is the maximum length that is safe to use. TODO(leninalive): Make it configurable.

const MaxPaddingLength = 256

MaxPaddingLength is the maximum size of a random padding that's added to every message.

const MinMessageLength = 100

MinMessageLength is the minimum message size. If the message is smaller, it will be padded with random bytes.

Functions

func Tunnel

func Tunnel(pipeName string, left io.ReadWriter, right io.ReadWriter)

Tunnel passes data between two connections.

Types

type MsgReadWriter

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

MsgReadWriter is a wrapper over io.ReadWriter that encodes messages written to and read from the base writer.

func NewMsgReadWriter

func NewMsgReadWriter(base io.ReadWriter) (rw *MsgReadWriter)

NewMsgReadWriter creates a new instance of *MsgReadWriter.

func (*MsgReadWriter) Read

func (rw *MsgReadWriter) Read(b []byte) (n int, err error)

Read implements the io.ReadWriter interface for *MsgReadWriter.

func (*MsgReadWriter) Write

func (rw *MsgReadWriter) Write(b []byte) (n int, err error)

Write implements the io.ReadWriter interface for *MsgReadWriter.