portfwd

Documentation

Index

• Variables
• func Control(_, _ string, c syscall.RawConn) (err error)
• func HandleTCPConnection(ctx context.Context, client *guestagentclient.GuestAgentClient, conn net.Conn, ...)
• func HandleUDPConnection(ctx context.Context, client *guestagentclient.GuestAgentClient, ...)
• func Listen(ctx context.Context, listenConfig net.ListenConfig, hostAddress string) (net.Listener, error)
• func ListenPacket(ctx context.Context, listenConfig net.ListenConfig, hostAddress string) (net.PacketConn, error)
• type ClosableListeners
  • func NewClosableListener() *ClosableListeners
  • func (p *ClosableListeners) Forward(ctx context.Context, client *guestagentclient.GuestAgentClient, ...)
  • func (p *ClosableListeners) Remove(_ context.Context, protocol, hostAddress, guestAddress string)
• type Forwarder
  • func NewPortForwarder(rules []limayaml.PortForward, ignoreTCP, ignoreUDP bool) *Forwarder
  • func (fw *Forwarder) OnEvent(ctx context.Context, client *guestagentclient.GuestAgentClient, ev *api.Event)
• type GrpcClientRW
  • func (g *GrpcClientRW) Close() error
  • func (g *GrpcClientRW) LocalAddr() net.Addr
  • func (g *GrpcClientRW) Read(p []byte) (n int, err error)
  • func (g *GrpcClientRW) RemoteAddr() net.Addr
  • func (g *GrpcClientRW) SetDeadline(_ time.Time) error
  • func (g *GrpcClientRW) SetReadDeadline(_ time.Time) error
  • func (g *GrpcClientRW) SetWriteDeadline(_ time.Time) error
  • func (g *GrpcClientRW) Write(p []byte) (n int, err error)

Variables

var IPv4loopback1 = limayaml.IPv4loopback1

Functions

func Control

func Control(_, _ string, c syscall.RawConn) (err error)

func HandleTCPConnection

func HandleTCPConnection(ctx context.Context, client *guestagentclient.GuestAgentClient, conn net.Conn, guestAddr string)

func HandleUDPConnection

func HandleUDPConnection(ctx context.Context, client *guestagentclient.GuestAgentClient, conn net.PacketConn, guestAddr string)

func Listen

func Listen(ctx context.Context, listenConfig net.ListenConfig, hostAddress string) (net.Listener, error)

func ListenPacket

func ListenPacket(ctx context.Context, listenConfig net.ListenConfig, hostAddress string) (net.PacketConn, error)

Types

type ClosableListeners

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

func NewClosableListener

func NewClosableListener() *ClosableListeners

func (*ClosableListeners) Forward

func (p *ClosableListeners) Forward(ctx context.Context, client *guestagentclient.GuestAgentClient,
	protocol string, hostAddress string, guestAddress string,
)

func (*ClosableListeners) Remove

func (p *ClosableListeners) Remove(_ context.Context, protocol, hostAddress, guestAddress string)

type Forwarder

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

func NewPortForwarder

func NewPortForwarder(rules []limayaml.PortForward, ignoreTCP, ignoreUDP bool) *Forwarder

func (*Forwarder) OnEvent

func (fw *Forwarder) OnEvent(ctx context.Context, client *guestagentclient.GuestAgentClient, ev *api.Event)

type GrpcClientRW

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

func (*GrpcClientRW) Close

func (g *GrpcClientRW) Close() error

func (*GrpcClientRW) LocalAddr

func (g *GrpcClientRW) LocalAddr() net.Addr

func (*GrpcClientRW) Read

func (g *GrpcClientRW) Read(p []byte) (n int, err error)

func (*GrpcClientRW) RemoteAddr

func (g *GrpcClientRW) RemoteAddr() net.Addr

func (*GrpcClientRW) SetDeadline

func (g *GrpcClientRW) SetDeadline(_ time.Time) error

func (*GrpcClientRW) SetReadDeadline

func (g *GrpcClientRW) SetReadDeadline(_ time.Time) error

func (*GrpcClientRW) SetWriteDeadline

func (g *GrpcClientRW) SetWriteDeadline(_ time.Time) error

func (*GrpcClientRW) Write

func (g *GrpcClientRW) Write(p []byte) (n int, err error)