gateway

type Config ¶

type Config struct {
	Subnet string   // CIDR subnet for local IPs (default: "10.4.0.0/16")
	Ports  []uint16 // Ports to proxy (default: DefaultPorts)
}

Config configures the gateway.

type Dialer ¶

type Dialer interface {
	DialAddr(dst protocol.Addr, port uint16) (net.Conn, error)
	Close() error
}

Dialer is satisfied by *driver.Driver. The concrete implementation lives at the L12 composition root (cmd/gateway) so plugins/gateway stays free of pkg/driver.

type Gateway ¶

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

Gateway bridges standard IP/TCP traffic to the Pilot Protocol overlay. In proxy mode, it listens on mapped local IPs and forwards TCP connections through Pilot Protocol streams.

func New(cfg Config, d Dialer) (*Gateway, error)

func (gw *Gateway) Map(pilotAddr protocol.Addr, localIP string) (net.IP, error)

func (gw *Gateway) Mappings() *MappingTable

func (gw *Gateway) Stop()

func (gw *Gateway) Unmap(localIP string) error

type Mapping ¶

type Mapping struct {
	LocalIP   net.IP
	PilotAddr protocol.Addr
}

All returns all current mappings as (localIP, pilotAddr) pairs.

type MappingTable ¶

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

MappingTable maps local IPs to Pilot addresses and vice versa.

func NewMappingTable(cidr string) (*MappingTable, error)

func (mt *MappingTable) All() []Mapping

func (mt *MappingTable) Lookup(localIP net.IP) (protocol.Addr, bool)

func (mt *MappingTable) Map(pilotAddr protocol.Addr, localIP net.IP) (net.IP, error)

func (mt *MappingTable) ReverseLookup(addr protocol.Addr) (net.IP, bool)

func (mt *MappingTable) Unmap(localIP net.IP) error

type Service ¶

type Service struct{}

Service is the L11 plugin lifecycle adapter for the gateway. The daemon does not register this today — cmd/gateway is a standalone binary that uses gateway.New / *Gateway.Start directly. The adapter exists so the plugin package conforms to the L10 Service contract and so the no_gateway build tag has a meaningful counterpart (see service_disabled.go).

When this plugin is eventually wired into cmd/daemon's plugin runtime, this Service will own the *Gateway lifecycle. Today its Start/Stop are no-ops; it is registered nowhere.

func NewService() *Service

func (s *Service) Name() string

func (s *Service) Order() int

func (s *Service) Start(_ context.Context, _ coreapi.Deps) error

func (s *Service) Stop(_ context.Context) error