tunl

Documentation

Index

• Constants
• Variables
• type AddrType
• type Address
  • func NewAddress(a string) (*Address, error)
  • func (a Address) ToProtoString() string
  • func (a Address) ToString() string
  • func (a Address) Type() AddrType
• type CommandCallback
• type DisconnectCallback
• type ErrorCallback
• type TunlConn
  • func NewTunlConn(conn net.Conn) *TunlConn
  • func (t *TunlConn) Close() error
  • func (t *TunlConn) HandleConnection()
  • func (t *TunlConn) HandleExpire()
  • func (t *TunlConn) Read() ([]byte, error)
  • func (t *TunlConn) Send(m proto.Message) (n int, err error)
  • func (t *TunlConn) SetExpireAt(e time.Time)
  • func (t *TunlConn) SetOnCommand(c CommandCallback)
  • func (t *TunlConn) SetOnDisconnected(c DisconnectCallback)
  • func (t *TunlConn) SetOnError(c ErrorCallback)
  • func (t *TunlConn) Write(data []byte) (n int, err error)

Constants

const (
	ErrorServerFull int32 = 2000 + iota
	ErrorUnauthorized
	ErrorSessionExpired
	ErrorClientResponse
	ErrorServerRequest
)

const ReaderSize = 1 << 20

Variables

var ErrorConnectionClosed = errors.New("connection closed")

Types

type AddrType

type AddrType byte

const (
	IP AddrType = iota
	PORT
	URL
	DIR
)

type Address

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

func NewAddress

func NewAddress(a string) (*Address, error)

func (Address) ToProtoString

func (a Address) ToProtoString() string

func (Address) ToString

func (a Address) ToString() string

func (Address) Type

func (a Address) Type() AddrType

type CommandCallback

type CommandCallback func(cmd *commands.Transfer)

type DisconnectCallback

type DisconnectCallback func()

type ErrorCallback

type ErrorCallback func(err error)

type TunlConn

type TunlConn struct {
	ID   string
	Conn net.Conn

	ExpireAt    time.Time
	ConnectedAt time.Time

	IsClosed bool
	// contains filtered or unexported fields
}

func NewTunlConn

func NewTunlConn(conn net.Conn) *TunlConn

func (*TunlConn) Close

func (t *TunlConn) Close() error

func (*TunlConn) HandleConnection

func (t *TunlConn) HandleConnection()

func (*TunlConn) HandleExpire

func (t *TunlConn) HandleExpire()

func (*TunlConn) Read

func (t *TunlConn) Read() ([]byte, error)

func (*TunlConn) Send

func (t *TunlConn) Send(m proto.Message) (n int, err error)

func (*TunlConn) SetExpireAt

func (t *TunlConn) SetExpireAt(e time.Time)

func (*TunlConn) SetOnCommand

func (t *TunlConn) SetOnCommand(c CommandCallback)

func (*TunlConn) SetOnDisconnected

func (t *TunlConn) SetOnDisconnected(c DisconnectCallback)

func (*TunlConn) SetOnError

func (t *TunlConn) SetOnError(c ErrorCallback)

func (*TunlConn) Write

func (t *TunlConn) Write(data []byte) (n int, err error)