crew

Documentation

Index

• Constants
• func EnableConnecting(my *hub.Hub)
• func HandleSluiceRequest(connInfo *network.Connection, conn net.Conn)
• type ConnectOp
  • func NewConnectOp(t terminal.OpTerminal, request *ConnectRequest, conn net.Conn) (*ConnectOp, *terminal.Error)
  • func (op *ConnectOp) Abandon(err *terminal.Error)
  • func (op *ConnectOp) Ctx() context.Context
  • func (op *ConnectOp) Deliver(c *container.Container) *terminal.Error
  • func (op *ConnectOp) End(err *terminal.Error)
  • func (op *ConnectOp) FmtID() string
  • func (op *ConnectOp) Type() string
• type ConnectRequest
  • func (r *ConnectRequest) Address() string
  • func (r *ConnectRequest) String() string
• type Tunnel
• type TunnelContext
• type TunnelContextHop
• type TunnelContextHopIPInfo

Constants

const ConnectOpType string = "connect"

Functions

func EnableConnecting

func EnableConnecting(my *hub.Hub)

func HandleSluiceRequest

func HandleSluiceRequest(connInfo *network.Connection, conn net.Conn)

Types

type ConnectOp

type ConnectOp struct {
	terminal.OpBase
	*terminal.DuplexFlowQueue
	// contains filtered or unexported fields
}

func NewConnectOp

func NewConnectOp(t terminal.OpTerminal, request *ConnectRequest, conn net.Conn) (*ConnectOp, *terminal.Error)

func (*ConnectOp) Abandon

func (op *ConnectOp) Abandon(err *terminal.Error)

func (*ConnectOp) Ctx

func (op *ConnectOp) Ctx() context.Context

func (*ConnectOp) Deliver

func (op *ConnectOp) Deliver(c *container.Container) *terminal.Error

func (*ConnectOp) End

func (op *ConnectOp) End(err *terminal.Error)

func (*ConnectOp) FmtID

func (op *ConnectOp) FmtID() string

func (*ConnectOp) Type

func (op *ConnectOp) Type() string

type ConnectRequest

type ConnectRequest struct {
	Domain    string
	IP        net.IP
	Protocol  packet.IPProtocol
	Port      uint16
	QueueSize uint16
}

func (*ConnectRequest) Address

func (r *ConnectRequest) Address() string

func (*ConnectRequest) String

func (r *ConnectRequest) String() string

type Tunnel

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

type TunnelContext

type TunnelContext struct {
	Path       []*TunnelContextHop
	PathCost   float32
	RoutingAlg string
}

TunnelContext holds additional information about the tunnel to be added to a connection.

type TunnelContextHop

type TunnelContextHop struct {
	ID   string
	Name string
	IPv4 *TunnelContextHopIPInfo `json:",omitempty"`
	IPv6 *TunnelContextHopIPInfo `json:",omitempty"`
}

type TunnelContextHopIPInfo

type TunnelContextHopIPInfo struct {
	IP      net.IP
	Country string
	ASN     uint
	ASOwner string
}