localproxy

type Backend interface {
	Name() BackendName
	InfoBackend() string
	IngressBaseURL() *url.URL
	IngressUnixSocket() string
	ControlPlaneBaseURL() *url.URL
	ControlPlaneUnixSocket() string
	WaitForTunnelClient(context.Context, time.Duration, types.TunnelID) error
	Wait(context.Context) error
	Stop(context.Context) error
}

type BackendFactory interface {
	Name() BackendName
	StartBackend(context.Context, BackendOptions) (Backend, error)
}

type BackendName string

type BackendOptions struct {
	ListenAddr             string
	ListenUnixSocket       string
	ControlPlaneUnixSocket string
	TunnelID               types.TunnelID
	APIKey                 string
	EngineQueueBackend     QueueBackendName
	EngineRedisURL         string
	ResponseTimeout        time.Duration
	ClientLastSeenTimeout  time.Duration
	ReadinessTimeout       time.Duration
	Stderr                 io.Writer
}

type Info struct {
	TunnelID               string `json:"tunnel_id"`
	MCPURL                 string `json:"mcp_url"`
	MCPTransport           string `json:"mcp_transport"`
	MCPUnixSocket          string `json:"mcp_unix_socket,omitempty"`
	MCPURLPath             string `json:"mcp_url_path,omitempty"`
	ControlPlaneBaseURL    string `json:"control_plane_base_url"`
	ControlPlaneTransport  string `json:"control_plane_transport"`
	ControlPlaneUnixSocket string `json:"control_plane_unix_socket,omitempty"`
	HealthURL              string `json:"health_url,omitempty"`
	Backend                string `json:"backend"`
}

type Options struct {
	ListenAddr       string
	ListenUnixSocket string
	TunnelID         types.TunnelID
	MCPServerURLs    []string
	MCPCommands      []string
	Profile          string
	ProfileFile      string
	ProfileDir       string
	// HealthListenAddr optionally starts the embedded tunnel-client health/admin
	// listener. Empty means no health/admin listener.
	HealthListenAddr string
	// HealthURLFile writes the embedded tunnel-client health/admin base URL. If
	// set without HealthListenAddr, Start uses an ephemeral loopback listener.
	HealthURLFile string
	URLFile       string
	// Backend selects the local proxy backend. Empty defaults to auto.
	Backend BackendName
	// EngineQueueBackend selects the queue implementation used by the backend.
	// Empty defaults to inmem. Redis is supported only by linked Rust backends.
	EngineQueueBackend QueueBackendName
	// EngineRedisURL configures the Rust Redis queue backend. The CLI fills this
	// from --engine-redis-url or TUNNEL_ENGINE_REDIS_URL.
	EngineRedisURL string
	// BackendFactories registers optional per-call backends linked into this
	// binary. Process-wide linked backends can also be registered with
	// RegisterBackendFactory.
	BackendFactories []BackendFactory
	// ResponseTimeout bounds how long local MCP ingress waits for a tunnel-client response.
	ResponseTimeout time.Duration
	// ClientLastSeenTimeout is used by readiness and local diagnostics.
	ClientLastSeenTimeout   time.Duration
	ReadinessTimeout        time.Duration
	ControlPlanePollTimeout time.Duration
	PollDeadlineGuardrail   time.Duration
	LookupEnv               func(string) (string, bool)
	Stdout                  io.Writer
	Stderr                  io.Writer
}

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

type QueueBackendName string