TheArchive/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-05-06 15:46:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

all: use new LocalAPI client package location

Browse Source 
It was moved in f57fa3cbc30e.

Updates tailscale/corp#22748

Change-Id: I19f965e6bded1d4c919310aa5b864f2de0cd6220
Signed-off-by: Brad Fitzpatrick <bradfitz@tailscale.com>
This commit is contained in:
Brad Fitzpatrick 2025-02-05 10:53:06 -08:00 committed by Brad Fitzpatrick
parent 8ecce0e98d
commit 05ac21ebe4
41 changed files with 114 additions and 108 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client/systray/systray.go
View File

@ -26,7 +26,7 @@ import (
"github.com/atotto/clipboard" "github.com/atotto/clipboard"
dbus "github.com/godbus/dbus/v5" dbus "github.com/godbus/dbus/v5"
"github.com/toqueteos/webbrowser" "github.com/toqueteos/webbrowser"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/ipn/ipnstate" "tailscale.com/ipn/ipnstate"
"tailscale.com/tailcfg" "tailscale.com/tailcfg"
@ -67,7 +67,7 @@ func (menu *Menu) Run() {
type Menu struct { type Menu struct {
mu sync.Mutex // protects the entire Menu mu sync.Mutex // protects the entire Menu
lc tailscale.LocalClient lc local.Client
status *ipnstate.Status status *ipnstate.Status
curProfile ipn.LoginProfile curProfile ipn.LoginProfile
allProfiles []ipn.LoginProfile allProfiles []ipn.LoginProfile

2
client/tailscale/apitype/apitype.go
View File

@ -24,7 +24,7 @@ const LocalAPIHost = "local-tailscaled.sock"
const RequestReasonHeader = "X-Tailscale-Reason" const RequestReasonHeader = "X-Tailscale-Reason"
// RequestReasonKey is the context key used to pass the request reason // RequestReasonKey is the context key used to pass the request reason
// when making a LocalAPI request via [tailscale.LocalClient]. // when making a LocalAPI request via [local.Client].
// It's value is a raw string. An empty string means no reason was provided. // It's value is a raw string. An empty string means no reason was provided.
// //
// See tailscale/corp#26146. // See tailscale/corp#26146.

5
client/tailscale/example/servetls/servetls.go
View File

@ -11,13 +11,14 @@ import (
"log" "log"
"net/http" "net/http"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
) )
func main() { func main() {
var lc local.Client
s := &http.Server{ s := &http.Server{
TLSConfig: &tls.Config{ TLSConfig: &tls.Config{
GetCertificate: tailscale.GetCertificate, GetCertificate: lc.GetCertificate,
}, },
Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
io.WriteString(w, "<h1>Hello from Tailscale!</h1> It works.") io.WriteString(w, "<h1>Hello from Tailscale!</h1> It works.")

10
client/web/web.go
View File

@ -22,7 +22,7 @@ import (
"time" "time"
"github.com/gorilla/csrf" "github.com/gorilla/csrf"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
"tailscale.com/clientupdate" "tailscale.com/clientupdate"
"tailscale.com/envknob" "tailscale.com/envknob"
@ -50,7 +50,7 @@ type Server struct {
mode ServerMode mode ServerMode
logf logger.Logf logf logger.Logf
lc *tailscale.LocalClient lc *local.Client
timeNow func() time.Time timeNow func() time.Time
// devMode indicates that the server run with frontend assets // devMode indicates that the server run with frontend assets
@ -125,9 +125,9 @@ type ServerOpts struct {
// PathPrefix is the URL prefix added to requests by CGI or reverse proxy. // PathPrefix is the URL prefix added to requests by CGI or reverse proxy.
PathPrefix string PathPrefix string
// LocalClient is the tailscale.LocalClient to use for this web server. // LocalClient is the local.Client to use for this web server.
// If nil, a new one will be created. // If nil, a new one will be created.
LocalClient *tailscale.LocalClient LocalClient *local.Client
// TimeNow optionally provides a time function. // TimeNow optionally provides a time function.
// time.Now is used as default. // time.Now is used as default.
@ -166,7 +166,7 @@ func NewServer(opts ServerOpts) (s *Server, err error) {
return nil, fmt.Errorf("invalid Mode provided") return nil, fmt.Errorf("invalid Mode provided")
} }
if opts.LocalClient == nil { if opts.LocalClient == nil {
opts.LocalClient = &tailscale.LocalClient{} opts.LocalClient = &local.Client{}
} }
s = &Server{ s = &Server{
mode: opts.Mode, mode: opts.Mode,

14
client/web/web_test.go
View File

@ -20,7 +20,7 @@ import (
"time" "time"
"github.com/google/go-cmp/cmp" "github.com/google/go-cmp/cmp"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/ipn/ipnstate" "tailscale.com/ipn/ipnstate"
@ -120,7 +120,7 @@ func TestServeAPI(t *testing.T) {
s := &Server{ s := &Server{
mode: ManageServerMode, mode: ManageServerMode,
lc: &tailscale.LocalClient{Dial: lal.Dial}, lc: &local.Client{Dial: lal.Dial},
timeNow: time.Now, timeNow: time.Now,
} }
@ -288,7 +288,7 @@ func TestGetTailscaleBrowserSession(t *testing.T) {
s := &Server{ s := &Server{
timeNow: time.Now, timeNow: time.Now,
lc: &tailscale.LocalClient{Dial: lal.Dial}, lc: &local.Client{Dial: lal.Dial},
} }
// Add some browser sessions to cache state. // Add some browser sessions to cache state.
@ -457,7 +457,7 @@ func TestAuthorizeRequest(t *testing.T) {
s := &Server{ s := &Server{
mode: ManageServerMode, mode: ManageServerMode,
lc: &tailscale.LocalClient{Dial: lal.Dial}, lc: &local.Client{Dial: lal.Dial},
timeNow: time.Now, timeNow: time.Now,
} }
validCookie := "ts-cookie" validCookie := "ts-cookie"
@ -572,7 +572,7 @@ func TestServeAuth(t *testing.T) {
s := &Server{ s := &Server{
mode: ManageServerMode, mode: ManageServerMode,
lc: &tailscale.LocalClient{Dial: lal.Dial}, lc: &local.Client{Dial: lal.Dial},
timeNow: func() time.Time { return timeNow }, timeNow: func() time.Time { return timeNow },
newAuthURL: mockNewAuthURL, newAuthURL: mockNewAuthURL,
waitAuthURL: mockWaitAuthURL, waitAuthURL: mockWaitAuthURL,
@ -914,7 +914,7 @@ func TestServeAPIAuthMetricLogging(t *testing.T) {
s := &Server{ s := &Server{
mode: ManageServerMode, mode: ManageServerMode,
lc: &tailscale.LocalClient{Dial: lal.Dial}, lc: &local.Client{Dial: lal.Dial},
timeNow: func() time.Time { return timeNow }, timeNow: func() time.Time { return timeNow },
newAuthURL: mockNewAuthURL, newAuthURL: mockNewAuthURL,
waitAuthURL: mockWaitAuthURL, waitAuthURL: mockWaitAuthURL,
@ -1126,7 +1126,7 @@ func TestRequireTailscaleIP(t *testing.T) {
s := &Server{ s := &Server{
mode: ManageServerMode, mode: ManageServerMode,
lc: &tailscale.LocalClient{Dial: lal.Dial}, lc: &local.Client{Dial: lal.Dial},
timeNow: time.Now, timeNow: time.Now,
logf: t.Logf, logf: t.Logf,
} }

6
cmd/containerboot/metrics.go
View File

@ -10,7 +10,7 @@ import (
"io" "io"
"net/http" "net/http"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
) )
@ -18,7 +18,7 @@ import (
// the tailscaled's LocalAPI usermetrics endpoint at /localapi/v0/usermetrics. // the tailscaled's LocalAPI usermetrics endpoint at /localapi/v0/usermetrics.
type metrics struct { type metrics struct {
debugEndpoint string debugEndpoint string
lc *tailscale.LocalClient lc *local.Client
} }
func proxy(w http.ResponseWriter, r *http.Request, url string, do func(*http.Request) (*http.Response, error)) { func proxy(w http.ResponseWriter, r *http.Request, url string, do func(*http.Request) (*http.Response, error)) {
@ -68,7 +68,7 @@ func (m *metrics) handleDebug(w http.ResponseWriter, r *http.Request) {
// In 1.78.x and 1.80.x, it also proxies debug paths to tailscaled's debug // In 1.78.x and 1.80.x, it also proxies debug paths to tailscaled's debug
// endpoint if configured to ease migration for a breaking change serving user // endpoint if configured to ease migration for a breaking change serving user
// metrics instead of debug metrics on the "metrics" port. // metrics instead of debug metrics on the "metrics" port.
func metricsHandlers(mux *http.ServeMux, lc *tailscale.LocalClient, debugAddrPort string) { func metricsHandlers(mux *http.ServeMux, lc *local.Client, debugAddrPort string) {
m := &metrics{ m := &metrics{
lc: lc, lc: lc,
debugEndpoint: debugAddrPort, debugEndpoint: debugAddrPort,

6
cmd/containerboot/serve.go
View File

@ -17,7 +17,7 @@ import (
"time" "time"
"github.com/fsnotify/fsnotify" "github.com/fsnotify/fsnotify"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/kube/kubetypes" "tailscale.com/kube/kubetypes"
"tailscale.com/types/netmap" "tailscale.com/types/netmap"
@ -28,7 +28,7 @@ import (
// applies it to lc. It exits when ctx is canceled. cdChanged is a channel that // applies it to lc. It exits when ctx is canceled. cdChanged is a channel that
// is written to when the certDomain changes, causing the serve config to be // is written to when the certDomain changes, causing the serve config to be
// re-read and applied. // re-read and applied.
func watchServeConfigChanges(ctx context.Context, path string, cdChanged <-chan bool, certDomainAtomic *atomic.Pointer[string], lc *tailscale.LocalClient, kc *kubeClient) { func watchServeConfigChanges(ctx context.Context, path string, cdChanged <-chan bool, certDomainAtomic *atomic.Pointer[string], lc *local.Client, kc *kubeClient) {
if certDomainAtomic == nil { if certDomainAtomic == nil {
panic("certDomainAtomic must not be nil") panic("certDomainAtomic must not be nil")
} }
@ -91,7 +91,7 @@ func certDomainFromNetmap(nm *netmap.NetworkMap) string {
return nm.DNS.CertDomains[0] return nm.DNS.CertDomains[0]
} }
// localClient is a subset of tailscale.LocalClient that can be mocked for testing. // localClient is a subset of [local.Client] that can be mocked for testing.
type localClient interface { type localClient interface {
SetServeConfig(context.Context, *ipn.ServeConfig) error SetServeConfig(context.Context, *ipn.ServeConfig) error
} }

4
cmd/containerboot/serve_test.go
View File

@ -12,7 +12,7 @@ import (
"testing" "testing"
"github.com/google/go-cmp/cmp" "github.com/google/go-cmp/cmp"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/kube/kubetypes" "tailscale.com/kube/kubetypes"
) )
@ -197,7 +197,7 @@ func TestReadServeConfig(t *testing.T) {
} }
type fakeLocalClient struct { type fakeLocalClient struct {
*tailscale.LocalClient *local.Client
setServeCalled bool setServeCalled bool
} }

6
cmd/containerboot/services.go
View File

@ -21,7 +21,7 @@ import (
"time" "time"
"github.com/fsnotify/fsnotify" "github.com/fsnotify/fsnotify"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/kube/egressservices" "tailscale.com/kube/egressservices"
"tailscale.com/kube/kubeclient" "tailscale.com/kube/kubeclient"
@ -50,7 +50,7 @@ type egressProxy struct {
kc kubeclient.Client // never nil kc kubeclient.Client // never nil
stateSecret string // name of the kube state Secret stateSecret string // name of the kube state Secret
tsClient *tailscale.LocalClient // never nil tsClient *local.Client // never nil
netmapChan chan ipn.Notify // chan to receive netmap updates on netmapChan chan ipn.Notify // chan to receive netmap updates on
@ -131,7 +131,7 @@ type egressProxyRunOpts struct {
cfgPath string cfgPath string
nfr linuxfw.NetfilterRunner nfr linuxfw.NetfilterRunner
kc kubeclient.Client kc kubeclient.Client
tsClient *tailscale.LocalClient tsClient *local.Client
stateSecret string stateSecret string
netmapChan chan ipn.Notify netmapChan chan ipn.Notify
podIPv4 string podIPv4 string

8
cmd/containerboot/tailscaled.go
View File

@ -20,10 +20,10 @@ import (
"time" "time"
"github.com/fsnotify/fsnotify" "github.com/fsnotify/fsnotify"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
) )
func startTailscaled(ctx context.Context, cfg *settings) (*tailscale.LocalClient, *os.Process, error) { func startTailscaled(ctx context.Context, cfg *settings) (*local.Client, *os.Process, error) {
args := tailscaledArgs(cfg) args := tailscaledArgs(cfg)
// tailscaled runs without context, since it needs to persist // tailscaled runs without context, since it needs to persist
// beyond the startup timeout in ctx. // beyond the startup timeout in ctx.
@ -54,7 +54,7 @@ func startTailscaled(ctx context.Context, cfg *settings) (*tailscale.LocalClient
break break
} }
tsClient := &tailscale.LocalClient{ tsClient := &local.Client{
Socket: cfg.Socket, Socket: cfg.Socket,
UseSocketOnly: true, UseSocketOnly: true,
} }
@ -170,7 +170,7 @@ func tailscaleSet(ctx context.Context, cfg *settings) error {
return nil return nil
} }
func watchTailscaledConfigChanges(ctx context.Context, path string, lc *tailscale.LocalClient, errCh chan<- error) { func watchTailscaledConfigChanges(ctx context.Context, path string, lc *local.Client, errCh chan<- error) {
var ( var (
tickChan <-chan time.Time tickChan <-chan time.Time
tailscaledCfgDir = filepath.Dir(path) tailscaledCfgDir = filepath.Dir(path)

2
cmd/derper/depaware.txt
View File

@ -88,7 +88,7 @@ tailscale.com/cmd/derper dependencies: (generated by github.com/tailscale/depawa
google.golang.org/protobuf/types/known/timestamppb from github.com/prometheus/client_golang/prometheus+ google.golang.org/protobuf/types/known/timestamppb from github.com/prometheus/client_golang/prometheus+
tailscale.com from tailscale.com/version tailscale.com from tailscale.com/version
💣 tailscale.com/atomicfile from tailscale.com/cmd/derper+ 💣 tailscale.com/atomicfile from tailscale.com/cmd/derper+
tailscale.com/client/local from tailscale.com/client/tailscale tailscale.com/client/local from tailscale.com/client/tailscale+
tailscale.com/client/tailscale from tailscale.com/derp tailscale.com/client/tailscale from tailscale.com/derp
tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+ tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+
tailscale.com/derp from tailscale.com/cmd/derper+ tailscale.com/derp from tailscale.com/cmd/derper+

4
cmd/hello/hello.go
View File

@ -18,7 +18,7 @@ import (
"strings" "strings"
"time" "time"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
) )
@ -31,7 +31,7 @@ var (
//go:embed hello.tmpl.html //go:embed hello.tmpl.html
var embeddedTemplate string var embeddedTemplate string
var localClient tailscale.LocalClient var localClient local.Client
func main() { func main() {
flag.Parse() flag.Parse()

4
cmd/k8s-operator/depaware.txt
View File

@ -780,8 +780,8 @@ tailscale.com/cmd/k8s-operator dependencies: (generated by github.com/tailscale/
tailscale.com from tailscale.com/version tailscale.com from tailscale.com/version
tailscale.com/appc from tailscale.com/ipn/ipnlocal tailscale.com/appc from tailscale.com/ipn/ipnlocal
💣 tailscale.com/atomicfile from tailscale.com/ipn+ 💣 tailscale.com/atomicfile from tailscale.com/ipn+
tailscale.com/client/local from tailscale.com/client/tailscale tailscale.com/client/local from tailscale.com/client/tailscale+
tailscale.com/client/tailscale from tailscale.com/client/web+ tailscale.com/client/tailscale from tailscale.com/cmd/k8s-operator+
tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+ tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+
tailscale.com/client/web from tailscale.com/ipn/ipnlocal tailscale.com/client/web from tailscale.com/ipn/ipnlocal
tailscale.com/clientupdate from tailscale.com/client/web+ tailscale.com/clientupdate from tailscale.com/client/web+

4
cmd/k8s-operator/proxy.go
View File

@ -20,7 +20,7 @@ import (
"go.uber.org/zap" "go.uber.org/zap"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
"k8s.io/client-go/transport" "k8s.io/client-go/transport"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
ksr "tailscale.com/k8s-operator/sessionrecording" ksr "tailscale.com/k8s-operator/sessionrecording"
"tailscale.com/kube/kubetypes" "tailscale.com/kube/kubetypes"
@ -189,7 +189,7 @@ func runAPIServerProxy(ts *tsnet.Server, rt http.RoundTripper, log *zap.SugaredL
// LocalAPI and then proxies them to the Kubernetes API. // LocalAPI and then proxies them to the Kubernetes API.
type apiserverProxy struct { type apiserverProxy struct {
log *zap.SugaredLogger log *zap.SugaredLogger
lc *tailscale.LocalClient lc *local.Client
rp *httputil.ReverseProxy rp *httputil.ReverseProxy
mode apiServerProxyMode mode apiServerProxyMode

6
cmd/natc/natc.go
View File

@ -29,7 +29,7 @@ import (
"golang.org/x/net/dns/dnsmessage" "golang.org/x/net/dns/dnsmessage"
"gvisor.dev/gvisor/pkg/tcpip" "gvisor.dev/gvisor/pkg/tcpip"
"gvisor.dev/gvisor/pkg/tcpip/transport/tcp" "gvisor.dev/gvisor/pkg/tcpip/transport/tcp"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/envknob" "tailscale.com/envknob"
"tailscale.com/hostinfo" "tailscale.com/hostinfo"
"tailscale.com/ipn" "tailscale.com/ipn"
@ -186,9 +186,9 @@ func main() {
type connector struct { type connector struct {
// ts is the tsnet.Server used to host the connector. // ts is the tsnet.Server used to host the connector.
ts *tsnet.Server ts *tsnet.Server
// lc is the LocalClient used to interact with the tsnet.Server hosting this // lc is the local.Client used to interact with the tsnet.Server hosting this
// connector. // connector.
lc *tailscale.LocalClient lc *local.Client
// dnsAddr is the IPv4 address to listen on for DNS requests. It is used to // dnsAddr is the IPv4 address to listen on for DNS requests. It is used to
// prevent the app connector from assigning it to a domain. // prevent the app connector from assigning it to a domain.

6
cmd/pgproxy/pgproxy.go
View File

@ -24,7 +24,7 @@ import (
"strings" "strings"
"time" "time"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/metrics" "tailscale.com/metrics"
"tailscale.com/tsnet" "tailscale.com/tsnet"
"tailscale.com/tsweb" "tailscale.com/tsweb"
@ -105,7 +105,7 @@ type proxy struct {
upstreamHost string // "my.database.com" upstreamHost string // "my.database.com"
upstreamCertPool *x509.CertPool upstreamCertPool *x509.CertPool
downstreamCert []tls.Certificate downstreamCert []tls.Certificate
client *tailscale.LocalClient client *local.Client
activeSessions expvar.Int activeSessions expvar.Int
startedSessions expvar.Int startedSessions expvar.Int
@ -115,7 +115,7 @@ type proxy struct {
// newProxy returns a proxy that forwards connections to // newProxy returns a proxy that forwards connections to
// upstreamAddr. The upstream's TLS session is verified using the CA // upstreamAddr. The upstream's TLS session is verified using the CA
// cert(s) in upstreamCAPath. // cert(s) in upstreamCAPath.
func newProxy(upstreamAddr, upstreamCAPath string, client *tailscale.LocalClient) (*proxy, error) { func newProxy(upstreamAddr, upstreamCAPath string, client *local.Client) (*proxy, error) {
bs, err := os.ReadFile(upstreamCAPath) bs, err := os.ReadFile(upstreamCAPath)
if err != nil { if err != nil {
return nil, err return nil, err

6
cmd/proxy-to-grafana/proxy-to-grafana.go
View File

@ -36,7 +36,7 @@ import (
"strings" "strings"
"time" "time"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/tailcfg" "tailscale.com/tailcfg"
"tailscale.com/tsnet" "tailscale.com/tsnet"
) )
@ -127,7 +127,7 @@ func main() {
log.Fatal(http.Serve(ln, proxy)) log.Fatal(http.Serve(ln, proxy))
} }
func modifyRequest(req *http.Request, localClient *tailscale.LocalClient) { func modifyRequest(req *http.Request, localClient *local.Client) {
// with enable_login_token set to true, we get a cookie that handles // with enable_login_token set to true, we get a cookie that handles
// auth for paths that are not /login // auth for paths that are not /login
if req.URL.Path != "/login" { if req.URL.Path != "/login" {
@ -144,7 +144,7 @@ func modifyRequest(req *http.Request, localClient *tailscale.LocalClient) {
req.Header.Set("X-Webauth-Name", user.DisplayName) req.Header.Set("X-Webauth-Name", user.DisplayName)
} }
func getTailscaleUser(ctx context.Context, localClient *tailscale.LocalClient, ipPort string) (*tailcfg.UserProfile, error) { func getTailscaleUser(ctx context.Context, localClient *local.Client, ipPort string) (*tailcfg.UserProfile, error) {
whois, err := localClient.WhoIs(ctx, ipPort) whois, err := localClient.WhoIs(ctx, ipPort)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to identify remote host: %w", err) return nil, fmt.Errorf("failed to identify remote host: %w", err)

4
cmd/sniproxy/sniproxy.go
View File

@ -22,7 +22,7 @@ import (
"strings" "strings"
"github.com/peterbourgon/ff/v3" "github.com/peterbourgon/ff/v3"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/hostinfo" "tailscale.com/hostinfo"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/tailcfg" "tailscale.com/tailcfg"
@ -183,7 +183,7 @@ func run(ctx context.Context, ts *tsnet.Server, wgPort int, hostname string, pro
type sniproxy struct { type sniproxy struct {
srv Server srv Server
ts *tsnet.Server ts *tsnet.Server
lc *tailscale.LocalClient lc *local.Client
} }
func (s *sniproxy) advertiseRoutesFromConfig(ctx context.Context, c *appctype.AppConnectorConfig) error { func (s *sniproxy) advertiseRoutesFromConfig(ctx context.Context, c *appctype.AppConnectorConfig) error {

3
cmd/tailscale/cli/cli.go
View File

@ -21,6 +21,7 @@ import (
"github.com/mattn/go-colorable" "github.com/mattn/go-colorable"
"github.com/mattn/go-isatty" "github.com/mattn/go-isatty"
"github.com/peterbourgon/ff/v3/ffcli" "github.com/peterbourgon/ff/v3/ffcli"
"tailscale.com/client/local"
"tailscale.com/client/tailscale" "tailscale.com/client/tailscale"
"tailscale.com/cmd/tailscale/cli/ffcomplete" "tailscale.com/cmd/tailscale/cli/ffcomplete"
"tailscale.com/envknob" "tailscale.com/envknob"
@ -79,7 +80,7 @@ func CleanUpArgs(args []string) []string {
return out return out
} }
var localClient = tailscale.LocalClient{ var localClient = local.Client{
Socket: paths.DefaultTailscaledSocket(), Socket: paths.DefaultTailscaledSocket(),
} }

2
cmd/tailscale/cli/serve_legacy.go
View File

@ -130,7 +130,7 @@ func (e *serveEnv) newFlags(name string, setup func(fs *flag.FlagSet)) *flag.Fla
} }
// localServeClient is an interface conforming to the subset of // localServeClient is an interface conforming to the subset of
// tailscale.LocalClient. It includes only the methods used by the // local.Client. It includes only the methods used by the
// serve command. // serve command.
// //
// The purpose of this interface is to allow tests to provide a mock. // The purpose of this interface is to allow tests to provide a mock.

2
cmd/tailscale/cli/serve_legacy_test.go
View File

@ -850,7 +850,7 @@ func TestVerifyFunnelEnabled(t *testing.T) {
} }
} }
// fakeLocalServeClient is a fake tailscale.LocalClient for tests. // fakeLocalServeClient is a fake local.Client for tests.
// It's not a full implementation, just enough to test the serve command. // It's not a full implementation, just enough to test the serve command.
// //
// The fake client is stateful, and is used to test manipulating // The fake client is stateful, and is used to test manipulating

4
cmd/tailscale/depaware.txt
View File

@ -70,8 +70,8 @@ tailscale.com/cmd/tailscale dependencies: (generated by github.com/tailscale/dep
software.sslmate.com/src/go-pkcs12/internal/rc2 from software.sslmate.com/src/go-pkcs12 software.sslmate.com/src/go-pkcs12/internal/rc2 from software.sslmate.com/src/go-pkcs12
tailscale.com from tailscale.com/version tailscale.com from tailscale.com/version
💣 tailscale.com/atomicfile from tailscale.com/cmd/tailscale/cli+ 💣 tailscale.com/atomicfile from tailscale.com/cmd/tailscale/cli+
tailscale.com/client/local from tailscale.com/client/tailscale tailscale.com/client/local from tailscale.com/client/tailscale+
tailscale.com/client/tailscale from tailscale.com/client/web+ tailscale.com/client/tailscale from tailscale.com/cmd/tailscale/cli+
tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+ tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+
tailscale.com/client/web from tailscale.com/cmd/tailscale/cli tailscale.com/client/web from tailscale.com/cmd/tailscale/cli
tailscale.com/clientupdate from tailscale.com/client/web+ tailscale.com/clientupdate from tailscale.com/client/web+

4
cmd/tailscaled/depaware.txt
View File

@ -233,8 +233,8 @@ tailscale.com/cmd/tailscaled dependencies: (generated by github.com/tailscale/de
tailscale.com/appc from tailscale.com/ipn/ipnlocal tailscale.com/appc from tailscale.com/ipn/ipnlocal
💣 tailscale.com/atomicfile from tailscale.com/ipn+ 💣 tailscale.com/atomicfile from tailscale.com/ipn+
LD tailscale.com/chirp from tailscale.com/cmd/tailscaled LD tailscale.com/chirp from tailscale.com/cmd/tailscaled
tailscale.com/client/local from tailscale.com/client/tailscale tailscale.com/client/local from tailscale.com/client/tailscale+
tailscale.com/client/tailscale from tailscale.com/client/web+ tailscale.com/client/tailscale from tailscale.com/derp
tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+ tailscale.com/client/tailscale/apitype from tailscale.com/client/tailscale+
tailscale.com/client/web from tailscale.com/ipn/ipnlocal tailscale.com/client/web from tailscale.com/ipn/ipnlocal
tailscale.com/clientupdate from tailscale.com/client/web+ tailscale.com/clientupdate from tailscale.com/client/web+

4
cmd/tailscaled/tailscaled.go
View File

@ -30,7 +30,7 @@ import (
"syscall" "syscall"
"time" "time"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/cmd/tailscaled/childproc" "tailscale.com/cmd/tailscaled/childproc"
"tailscale.com/control/controlclient" "tailscale.com/control/controlclient"
"tailscale.com/drive/driveimpl" "tailscale.com/drive/driveimpl"
@ -621,7 +621,7 @@ func getLocalBackend(ctx context.Context, logf logger.Logf, logID logid.PublicID
if root := lb.TailscaleVarRoot(); root != "" { if root := lb.TailscaleVarRoot(); root != "" {
dnsfallback.SetCachePath(filepath.Join(root, "derpmap.cached.json"), logf) dnsfallback.SetCachePath(filepath.Join(root, "derpmap.cached.json"), logf)
} }
lb.ConfigureWebClient(&tailscale.LocalClient{ lb.ConfigureWebClient(&local.Client{
Socket: args.socketpath, Socket: args.socketpath,
UseSocketOnly: args.socketpath != paths.DefaultTailscaledSocket(), UseSocketOnly: args.socketpath != paths.DefaultTailscaledSocket(),
}) })

4
cmd/tl-longchain/tl-longchain.go
View File

@ -22,7 +22,7 @@ import (
"log" "log"
"time" "time"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/ipn/ipnstate" "tailscale.com/ipn/ipnstate"
"tailscale.com/tka" "tailscale.com/tka"
"tailscale.com/types/key" "tailscale.com/types/key"
@ -37,7 +37,7 @@ var (
func main() { func main() {
flag.Parse() flag.Parse()
lc := tailscale.LocalClient{Socket: *flagSocket} lc := local.Client{Socket: *flagSocket}
if lc.Socket != "" { if lc.Socket != "" {
lc.UseSocketOnly = true lc.UseSocketOnly = true
} }

12
cmd/tsidp/tsidp.go
View File

@ -35,7 +35,7 @@ import (
"gopkg.in/square/go-jose.v2" "gopkg.in/square/go-jose.v2"
"gopkg.in/square/go-jose.v2/jwt" "gopkg.in/square/go-jose.v2/jwt"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
"tailscale.com/envknob" "tailscale.com/envknob"
"tailscale.com/ipn" "tailscale.com/ipn"
@ -75,7 +75,7 @@ func main() {
} }
var ( var (
lc *tailscale.LocalClient lc *local.Client
st *ipnstate.Status st *ipnstate.Status
err error err error
watcherChan chan error watcherChan chan error
@ -84,7 +84,7 @@ func main() {
lns []net.Listener lns []net.Listener
) )
if *flagUseLocalTailscaled { if *flagUseLocalTailscaled {
lc = &tailscale.LocalClient{} lc = &local.Client{}
st, err = lc.StatusWithoutPeers(ctx) st, err = lc.StatusWithoutPeers(ctx)
if err != nil { if err != nil {
log.Fatalf("getting status: %v", err) log.Fatalf("getting status: %v", err)
@ -212,7 +212,7 @@ func main() {
// serveOnLocalTailscaled starts a serve session using an already-running // serveOnLocalTailscaled starts a serve session using an already-running
// tailscaled instead of starting a fresh tsnet server, making something // tailscaled instead of starting a fresh tsnet server, making something
// listening on clientDNSName:dstPort accessible over serve/funnel. // listening on clientDNSName:dstPort accessible over serve/funnel.
func serveOnLocalTailscaled(ctx context.Context, lc *tailscale.LocalClient, st *ipnstate.Status, dstPort uint16, shouldFunnel bool) (cleanup func(), watcherChan chan error, err error) { func serveOnLocalTailscaled(ctx context.Context, lc *local.Client, st *ipnstate.Status, dstPort uint16, shouldFunnel bool) (cleanup func(), watcherChan chan error, err error) {
// In order to support funneling out in local tailscaled mode, we need // In order to support funneling out in local tailscaled mode, we need
// to add a serve config to forward the listeners we bound above and // to add a serve config to forward the listeners we bound above and
// allow those forwarders to be funneled out. // allow those forwarders to be funneled out.
@ -275,7 +275,7 @@ func serveOnLocalTailscaled(ctx context.Context, lc *tailscale.LocalClient, st *
} }
type idpServer struct { type idpServer struct {
lc *tailscale.LocalClient lc *local.Client
loopbackURL string loopbackURL string
serverURL string // "https://foo.bar.ts.net" serverURL string // "https://foo.bar.ts.net"
funnel bool funnel bool
@ -328,7 +328,7 @@ type authRequest struct {
// allowRelyingParty validates that a relying party identified either by a // allowRelyingParty validates that a relying party identified either by a
// known remoteAddr or a valid client ID/secret pair is allowed to proceed // known remoteAddr or a valid client ID/secret pair is allowed to proceed
// with the authorization flow associated with this authRequest. // with the authorization flow associated with this authRequest.
func (ar *authRequest) allowRelyingParty(r *http.Request, lc *tailscale.LocalClient) error { func (ar *authRequest) allowRelyingParty(r *http.Request, lc *local.Client) error {
if ar.localRP { if ar.localRP {
ra, err := netip.ParseAddrPort(r.RemoteAddr) ra, err := netip.ParseAddrPort(r.RemoteAddr)
if err != nil { if err != nil {

4
cmd/tta/tta.go
View File

@ -30,7 +30,7 @@ import (
"time" "time"
"tailscale.com/atomicfile" "tailscale.com/atomicfile"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/hostinfo" "tailscale.com/hostinfo"
"tailscale.com/util/mak" "tailscale.com/util/mak"
"tailscale.com/util/must" "tailscale.com/util/must"
@ -64,7 +64,7 @@ func serveCmd(w http.ResponseWriter, cmd string, args ...string) {
} }
type localClientRoundTripper struct { type localClientRoundTripper struct {
lc tailscale.LocalClient lc local.Client
} }
func (rt *localClientRoundTripper) RoundTrip(req *http.Request) (*http.Response, error) { func (rt *localClientRoundTripper) RoundTrip(req *http.Request) (*http.Response, error) {

3
derp/derp_server.go
View File

@ -36,6 +36,7 @@ import (
"go4.org/mem" "go4.org/mem"
"golang.org/x/sync/errgroup" "golang.org/x/sync/errgroup"
"tailscale.com/client/local"
"tailscale.com/client/tailscale" "tailscale.com/client/tailscale"
"tailscale.com/disco" "tailscale.com/disco"
"tailscale.com/envknob" "tailscale.com/envknob"
@ -1319,7 +1320,7 @@ func (c *sclient) requestMeshUpdate() {
} }
} }
var localClient tailscale.LocalClient var localClient local.Client
// isMeshPeer reports whether the client is a trusted mesh peer // isMeshPeer reports whether the client is a trusted mesh peer
// node in the DERP region. // node in the DERP region.

10
ipn/ipnlocal/web_client.go
View File

@ -17,7 +17,7 @@ import (
"sync" "sync"
"time" "time"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/client/web" "tailscale.com/client/web"
"tailscale.com/logtail/backoff" "tailscale.com/logtail/backoff"
"tailscale.com/net/netutil" "tailscale.com/net/netutil"
@ -36,16 +36,16 @@ type webClient struct {
server *web.Server // or nil, initialized lazily server *web.Server // or nil, initialized lazily
// lc optionally specifies a LocalClient to use to connect // lc optionally specifies a local.Client to use to connect
// to the localapi for this tailscaled instance. // to the localapi for this tailscaled instance.
// If nil, a default is used. // If nil, a default is used.
lc *tailscale.LocalClient lc *local.Client
} }
// ConfigureWebClient configures b.web prior to use. // ConfigureWebClient configures b.web prior to use.
// Specifially, it sets b.web.lc to the provided LocalClient. // Specifially, it sets b.web.lc to the provided local.Client.
// If provided as nil, b.web.lc is cleared out. // If provided as nil, b.web.lc is cleared out.
func (b *LocalBackend) ConfigureWebClient(lc *tailscale.LocalClient) { func (b *LocalBackend) ConfigureWebClient(lc *local.Client) {
b.webClient.mu.Lock() b.webClient.mu.Lock()
defer b.webClient.mu.Unlock() defer b.webClient.mu.Unlock()
b.webClient.lc = lc b.webClient.lc = lc

4
ipn/ipnlocal/web_client_stub.go
View File

@ -9,14 +9,14 @@ import (
"errors" "errors"
"net" "net"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
) )
const webClientPort = 5252 const webClientPort = 5252
type webClient struct{} type webClient struct{}
func (b *LocalBackend) ConfigureWebClient(lc *tailscale.LocalClient) {} func (b *LocalBackend) ConfigureWebClient(lc *local.Client) {}
func (b *LocalBackend) webClientGetOrInit() error { func (b *LocalBackend) webClientGetOrInit() error {
return errors.New("not implemented") return errors.New("not implemented")

19
ipn/ipnserver/server_test.go
View File

@ -17,6 +17,7 @@ import (
"sync/atomic" "sync/atomic"
"testing" "testing"
"tailscale.com/client/local"
"tailscale.com/client/tailscale" "tailscale.com/client/tailscale"
"tailscale.com/client/tailscale/apitype" "tailscale.com/client/tailscale/apitype"
"tailscale.com/control/controlclient" "tailscale.com/control/controlclient"
@ -330,7 +331,7 @@ func newTestIPNServer(tb testing.TB, lb *ipnlocal.LocalBackend, enableLogging bo
type testIPNClient struct { type testIPNClient struct {
tb testing.TB tb testing.TB
*tailscale.LocalClient *local.Client
User *ipnauth.TestActor User *ipnauth.TestActor
} }
@ -338,7 +339,7 @@ func (c *testIPNClient) WatchIPNBus(ctx context.Context, mask ipn.NotifyWatchOpt
c.tb.Helper() c.tb.Helper()
ctx, cancelWatcher := context.WithCancel(ctx) ctx, cancelWatcher := context.WithCancel(ctx)
c.tb.Cleanup(cancelWatcher) c.tb.Cleanup(cancelWatcher)
watcher, err := c.LocalClient.WatchIPNBus(ctx, mask) watcher, err := c.Client.WatchIPNBus(ctx, mask)
if err != nil { if err != nil {
c.tb.Fatalf("WatchIPNBus(%q): %v", c.User.Name, err) c.tb.Fatalf("WatchIPNBus(%q): %v", c.User.Name, err)
} }
@ -359,7 +360,7 @@ type testIPNServer struct {
tb testing.TB tb testing.TB
*Server *Server
clientID atomic.Int64 clientID atomic.Int64
getClient func(*ipnauth.TestActor) *tailscale.LocalClient getClient func(*ipnauth.TestActor) *local.Client
actorsMu sync.Mutex actorsMu sync.Mutex
actors map[string]*ipnauth.TestActor actors map[string]*ipnauth.TestActor
@ -369,9 +370,9 @@ func (s *testIPNServer) getClientAs(name string) *testIPNClient {
clientID := fmt.Sprintf("Client-%d", 1+s.clientID.Add(1)) clientID := fmt.Sprintf("Client-%d", 1+s.clientID.Add(1))
user := s.makeTestUser(name, clientID) user := s.makeTestUser(name, clientID)
return &testIPNClient{ return &testIPNClient{
tb: s.tb, tb: s.tb,
LocalClient: s.getClient(user), Client: s.getClient(user),
User: user, User: user,
} }
} }
@ -427,7 +428,7 @@ func (s *testIPNServer) checkCurrentUser(want *ipnauth.TestActor) {
// startTestIPNServer starts a [httptest.Server] that hosts the specified IPN server for the // startTestIPNServer starts a [httptest.Server] that hosts the specified IPN server for the
// duration of the test, using the specified base context for incoming requests. // duration of the test, using the specified base context for incoming requests.
// It returns a function that creates a [tailscale.LocalClient] as a given [ipnauth.TestActor]. // It returns a function that creates a [local.Client] as a given [ipnauth.TestActor].
func startTestIPNServer(tb testing.TB, baseContext context.Context, server *Server) *testIPNServer { func startTestIPNServer(tb testing.TB, baseContext context.Context, server *Server) *testIPNServer {
tb.Helper() tb.Helper()
ts := httptest.NewUnstartedServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { ts := httptest.NewUnstartedServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
@ -448,8 +449,8 @@ func startTestIPNServer(tb testing.TB, baseContext context.Context, server *Serv
return &testIPNServer{ return &testIPNServer{
tb: tb, tb: tb,
Server: server, Server: server,
getClient: func(actor *ipnauth.TestActor) *tailscale.LocalClient { getClient: func(actor *ipnauth.TestActor) *local.Client {
return &tailscale.LocalClient{Transport: newTestRoundTripper(ts, actor)} return &local.Client{Transport: newTestRoundTripper(ts, actor)}
}, },
} }
} }

4
prober/derp.go
View File

@ -30,7 +30,7 @@ import (
"github.com/tailscale/wireguard-go/device" "github.com/tailscale/wireguard-go/device"
"github.com/tailscale/wireguard-go/tun" "github.com/tailscale/wireguard-go/tun"
"go4.org/netipx" "go4.org/netipx"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/derp" "tailscale.com/derp"
"tailscale.com/derp/derphttp" "tailscale.com/derp/derphttp"
"tailscale.com/net/netmon" "tailscale.com/net/netmon"
@ -534,7 +534,7 @@ func (d *derpProber) getNodePair(n1, n2 string) (ret1, ret2 *tailcfg.DERPNode, _
return ret1, ret2, nil return ret1, ret2, nil
} }
var tsLocalClient tailscale.LocalClient var tsLocalClient local.Client
// updateMap refreshes the locally-cached DERP map. // updateMap refreshes the locally-cached DERP map.
func (d *derpProber) updateMap(ctx context.Context) error { func (d *derpProber) updateMap(ctx context.Context) error {

15
tsnet/tsnet.go
View File

@ -26,6 +26,7 @@ import (
"sync" "sync"
"time" "time"
"tailscale.com/client/local"
"tailscale.com/client/tailscale" "tailscale.com/client/tailscale"
"tailscale.com/control/controlclient" "tailscale.com/control/controlclient"
"tailscale.com/envknob" "tailscale.com/envknob"
@ -135,11 +136,11 @@ type Server struct {
hostname string hostname string
shutdownCtx context.Context shutdownCtx context.Context
shutdownCancel context.CancelFunc shutdownCancel context.CancelFunc
proxyCred string // SOCKS5 proxy auth for loopbackListener proxyCred string // SOCKS5 proxy auth for loopbackListener
localAPICred string // basic auth password for loopbackListener localAPICred string // basic auth password for loopbackListener
loopbackListener net.Listener // optional loopback for localapi and proxies loopbackListener net.Listener // optional loopback for localapi and proxies
localAPIListener net.Listener // in-memory, used by localClient localAPIListener net.Listener // in-memory, used by localClient
localClient *tailscale.LocalClient // in-memory localClient *local.Client // in-memory
localAPIServer *http.Server localAPIServer *http.Server
logbuffer *filch.Filch logbuffer *filch.Filch
logtail *logtail.Logger logtail *logtail.Logger
@ -222,7 +223,7 @@ func (s *Server) HTTPClient() *http.Client {
// //
// It will start the server if it has not been started yet. If the server's // It will start the server if it has not been started yet. If the server's
// already been started successfully, it doesn't return an error. // already been started successfully, it doesn't return an error.
func (s *Server) LocalClient() (*tailscale.LocalClient, error) { func (s *Server) LocalClient() (*local.Client, error) {
if err := s.Start(); err != nil { if err := s.Start(); err != nil {
return nil, err return nil, err
} }
@ -676,7 +677,7 @@ func (s *Server) start() (reterr error) {
// nettest.Listen provides a in-memory pipe based implementation for net.Conn. // nettest.Listen provides a in-memory pipe based implementation for net.Conn.
lal := memnet.Listen("local-tailscaled.sock:80") lal := memnet.Listen("local-tailscaled.sock:80")
s.localAPIListener = lal s.localAPIListener = lal
s.localClient = &tailscale.LocalClient{Dial: lal.Dial} s.localClient = &local.Client{Dial: lal.Dial}
s.localAPIServer = &http.Server{Handler: lah} s.localAPIServer = &http.Server{Handler: lah}
s.lb.ConfigureWebClient(s.localClient) s.lb.ConfigureWebClient(s.localClient)
go func() { go func() {

4
tsnet/tsnet_test.go
View File

@ -36,7 +36,7 @@ import (
dto "github.com/prometheus/client_model/go" dto "github.com/prometheus/client_model/go"
"github.com/prometheus/common/expfmt" "github.com/prometheus/common/expfmt"
"golang.org/x/net/proxy" "golang.org/x/net/proxy"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/cmd/testwrapper/flakytest" "tailscale.com/cmd/testwrapper/flakytest"
"tailscale.com/ipn" "tailscale.com/ipn"
"tailscale.com/ipn/store/mem" "tailscale.com/ipn/store/mem"
@ -1273,7 +1273,7 @@ func waitForCondition(t *testing.T, msg string, waitTime time.Duration, f func()
} }
// mustDirect ensures there is a direct connection between LocalClient 1 and 2 // mustDirect ensures there is a direct connection between LocalClient 1 and 2
func mustDirect(t *testing.T, logf logger.Logf, lc1, lc2 *tailscale.LocalClient) { func mustDirect(t *testing.T, logf logger.Logf, lc1, lc2 *local.Client) {
t.Helper() t.Helper()
lastLog := time.Now().Add(-time.Minute) lastLog := time.Now().Add(-time.Minute)
// See https://github.com/tailscale/tailscale/issues/654 // See https://github.com/tailscale/tailscale/issues/654

7
tstest/integration/integration_test.go
View File

@ -32,6 +32,7 @@ import (
"github.com/miekg/dns" "github.com/miekg/dns"
"go4.org/mem" "go4.org/mem"
"tailscale.com/client/local"
"tailscale.com/client/tailscale" "tailscale.com/client/tailscale"
"tailscale.com/clientupdate" "tailscale.com/clientupdate"
"tailscale.com/cmd/testwrapper/flakytest" "tailscale.com/cmd/testwrapper/flakytest"
@ -755,11 +756,11 @@ func TestClientSideJailing(t *testing.T) {
defer ln.Close() defer ln.Close()
port := uint16(ln.Addr().(*net.TCPAddr).Port) port := uint16(ln.Addr().(*net.TCPAddr).Port)
lc1 := &tailscale.LocalClient{ lc1 := &local.Client{
Socket: n1.sockFile, Socket: n1.sockFile,
UseSocketOnly: true, UseSocketOnly: true,
} }
lc2 := &tailscale.LocalClient{ lc2 := &local.Client{
Socket: n2.sockFile, Socket: n2.sockFile,
UseSocketOnly: true, UseSocketOnly: true,
} }
@ -789,7 +790,7 @@ func TestClientSideJailing(t *testing.T) {
}, },
} }
testDial := func(t *testing.T, lc *tailscale.LocalClient, ip netip.Addr, port uint16, shouldFail bool) { testDial := func(t *testing.T, lc *local.Client, ip netip.Addr, port uint16, shouldFail bool) {
t.Helper() t.Helper()
ctx, cancel := context.WithTimeout(context.Background(), time.Second) ctx, cancel := context.WithTimeout(context.Background(), time.Second)
defer cancel() defer cancel()

2
tstest/integration/tailscaled_deps_test_darwin.go
View File

@ -11,7 +11,7 @@ import (
// transitive deps when we run "go install tailscaled" in a child // transitive deps when we run "go install tailscaled" in a child
// process and can cache a prior success when a dependency changes. // process and can cache a prior success when a dependency changes.
_ "tailscale.com/chirp" _ "tailscale.com/chirp"
_ "tailscale.com/client/tailscale" _ "tailscale.com/client/local"
_ "tailscale.com/cmd/tailscaled/childproc" _ "tailscale.com/cmd/tailscaled/childproc"
_ "tailscale.com/control/controlclient" _ "tailscale.com/control/controlclient"
_ "tailscale.com/derp/derphttp" _ "tailscale.com/derp/derphttp"

2
tstest/integration/tailscaled_deps_test_freebsd.go
View File

@ -11,7 +11,7 @@ import (
// transitive deps when we run "go install tailscaled" in a child // transitive deps when we run "go install tailscaled" in a child
// process and can cache a prior success when a dependency changes. // process and can cache a prior success when a dependency changes.
_ "tailscale.com/chirp" _ "tailscale.com/chirp"
_ "tailscale.com/client/tailscale" _ "tailscale.com/client/local"
_ "tailscale.com/cmd/tailscaled/childproc" _ "tailscale.com/cmd/tailscaled/childproc"
_ "tailscale.com/control/controlclient" _ "tailscale.com/control/controlclient"
_ "tailscale.com/derp/derphttp" _ "tailscale.com/derp/derphttp"

2
tstest/integration/tailscaled_deps_test_linux.go
View File

@ -11,7 +11,7 @@ import (
// transitive deps when we run "go install tailscaled" in a child // transitive deps when we run "go install tailscaled" in a child
// process and can cache a prior success when a dependency changes. // process and can cache a prior success when a dependency changes.
_ "tailscale.com/chirp" _ "tailscale.com/chirp"
_ "tailscale.com/client/tailscale" _ "tailscale.com/client/local"
_ "tailscale.com/cmd/tailscaled/childproc" _ "tailscale.com/cmd/tailscaled/childproc"
_ "tailscale.com/control/controlclient" _ "tailscale.com/control/controlclient"
_ "tailscale.com/derp/derphttp" _ "tailscale.com/derp/derphttp"

2
tstest/integration/tailscaled_deps_test_openbsd.go
View File

@ -11,7 +11,7 @@ import (
// transitive deps when we run "go install tailscaled" in a child // transitive deps when we run "go install tailscaled" in a child
// process and can cache a prior success when a dependency changes. // process and can cache a prior success when a dependency changes.
_ "tailscale.com/chirp" _ "tailscale.com/chirp"
_ "tailscale.com/client/tailscale" _ "tailscale.com/client/local"
_ "tailscale.com/cmd/tailscaled/childproc" _ "tailscale.com/cmd/tailscaled/childproc"
_ "tailscale.com/control/controlclient" _ "tailscale.com/control/controlclient"
_ "tailscale.com/derp/derphttp" _ "tailscale.com/derp/derphttp"

2
tstest/integration/tailscaled_deps_test_windows.go
View File

@ -18,7 +18,7 @@ import (
_ "golang.org/x/sys/windows/svc/mgr" _ "golang.org/x/sys/windows/svc/mgr"
_ "golang.zx2c4.com/wintun" _ "golang.zx2c4.com/wintun"
_ "golang.zx2c4.com/wireguard/windows/tunnel/winipcfg" _ "golang.zx2c4.com/wireguard/windows/tunnel/winipcfg"
_ "tailscale.com/client/tailscale" _ "tailscale.com/client/local"
_ "tailscale.com/cmd/tailscaled/childproc" _ "tailscale.com/cmd/tailscaled/childproc"
_ "tailscale.com/control/controlclient" _ "tailscale.com/control/controlclient"
_ "tailscale.com/derp/derphttp" _ "tailscale.com/derp/derphttp"

6
tstest/natlab/vnet/vnet.go
View File

@ -50,7 +50,7 @@ import (
"gvisor.dev/gvisor/pkg/tcpip/transport/icmp" "gvisor.dev/gvisor/pkg/tcpip/transport/icmp"
"gvisor.dev/gvisor/pkg/tcpip/transport/tcp" "gvisor.dev/gvisor/pkg/tcpip/transport/tcp"
"gvisor.dev/gvisor/pkg/waiter" "gvisor.dev/gvisor/pkg/waiter"
"tailscale.com/client/tailscale" "tailscale.com/client/local"
"tailscale.com/derp" "tailscale.com/derp"
"tailscale.com/derp/derphttp" "tailscale.com/derp/derphttp"
"tailscale.com/net/netutil" "tailscale.com/net/netutil"
@ -2123,7 +2123,7 @@ func (s *Server) takeAgentConnOne(n *node) (_ *agentConn, ok bool) {
} }
type NodeAgentClient struct { type NodeAgentClient struct {
*tailscale.LocalClient *local.Client
HTTPClient *http.Client HTTPClient *http.Client
} }
@ -2148,7 +2148,7 @@ func (s *Server) NodeAgentDialer(n *Node) DialFunc {
func (s *Server) NodeAgentClient(n *Node) *NodeAgentClient { func (s *Server) NodeAgentClient(n *Node) *NodeAgentClient {
d := s.NodeAgentDialer(n) d := s.NodeAgentDialer(n)
return &NodeAgentClient{ return &NodeAgentClient{
LocalClient: &tailscale.LocalClient{ Client: &local.Client{
UseSocketOnly: true, UseSocketOnly: true,
OmitAuth: true, OmitAuth: true,
Dial: d, Dial: d,