supervisor

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

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

type EdgeAddrHandler interface {
	// ShouldGetNewAddress will check the edge connection error and determine if
	// the edge address should be replaced with a new one. Also, will return if the
	// error should be recognized as a connectivity error, or otherwise, a general
	// application error.
	ShouldGetNewAddress(connIndex uint8, err error) (needsNewAddress bool, connectivityError error)
}

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

type Incident struct {
	Name    string
	ID      string           `json:"id"`
	Updates []IncidentUpdate `json:"incident_updates"`
}

type IncidentLookup interface {
	ActiveIncidents() []Incident
}

type IncidentUpdate struct {
	Body string
}

type ReconnectSignal struct {
	// wait this many seconds before re-establish the connection
	Delay time.Duration
}

type StatusPage struct {
	Incidents []Incident
}

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

type TunnelConfig struct {
	GracePeriod        time.Duration
	ReplaceExisting    bool
	OSArch             string
	ClientID           string
	CloseConnOnce      *sync.Once // Used to close connectedSignal no more than once
	EdgeAddrs          []string
	Region             string
	EdgeIPVersion      allregions.ConfigIPVersion
	EdgeBindAddr       net.IP
	HAConnections      int
	IncidentLookup     IncidentLookup
	IsAutoupdated      bool
	LBPool             string
	Tags               []tunnelpogs.Tag
	Log                *zerolog.Logger
	LogTransport       *zerolog.Logger
	Observer           *connection.Observer
	ReportedVersion    string
	Retries            uint
	MaxEdgeAddrRetries uint8
	RunFromTerminal    bool

	NeedPQ bool

	NamedTunnel      *connection.NamedTunnelProperties
	ProtocolSelector connection.ProtocolSelector
	EdgeTLSConfigs   map[connection.Protocol]*tls.Config
	PacketConfig     *ingress.GlobalRouterConfig

	UDPUnregisterSessionTimeout time.Duration

	DisableQUICPathMTUDiscovery bool

	FeatureSelector *features.FeatureSelector
}

type TunnelServer interface {
	Serve(ctx context.Context, connIndex uint8, protocolFallback *protocolFallback, connectedSignal *signal.Signal) error
}