TheArchive/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-06-27 18:48:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

client/local: add godoc links

Browse Source 
Signed-off-by: Olivier Mengué <dolmen@cpan.org>
This commit is contained in:
Olivier Mengué 2025-04-01 18:00:06 +02:00 committed by Brad Fitzpatrick
parent cb6fc37d66
commit b1c2860485
1 changed files with 20 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
client/local/local.go
View File

@ -294,7 +294,7 @@ func (lc *Client) get200(ctx context.Context, path string) ([]byte, error) {
// WhoIs returns the owner of the remoteAddr, which must be an IP or IP:port. // WhoIs returns the owner of the remoteAddr, which must be an IP or IP:port.
// //
// Deprecated: use Client.WhoIs. // Deprecated: use [Client.WhoIs].
func WhoIs(ctx context.Context, remoteAddr string) (*apitype.WhoIsResponse, error) { func WhoIs(ctx context.Context, remoteAddr string) (*apitype.WhoIsResponse, error) {
return defaultClient.WhoIs(ctx, remoteAddr) return defaultClient.WhoIs(ctx, remoteAddr)
} }
@ -309,7 +309,7 @@ func decodeJSON[T any](b []byte) (ret T, err error) {
// WhoIs returns the owner of the remoteAddr, which must be an IP or IP:port. // WhoIs returns the owner of the remoteAddr, which must be an IP or IP:port.
// //
// If not found, the error is ErrPeerNotFound. // If not found, the error is [ErrPeerNotFound].
// //
// For connections proxied by tailscaled, this looks up the owner of the given // For connections proxied by tailscaled, this looks up the owner of the given
// address as TCP first, falling back to UDP; if you want to only check a // address as TCP first, falling back to UDP; if you want to only check a
@ -325,7 +325,8 @@ func (lc *Client) WhoIs(ctx context.Context, remoteAddr string) (*apitype.WhoIsR
return decodeJSON[*apitype.WhoIsResponse](body) return decodeJSON[*apitype.WhoIsResponse](body)
} }
// ErrPeerNotFound is returned by WhoIs and WhoIsNodeKey when a peer is not found. // ErrPeerNotFound is returned by [Client.WhoIs], [Client.WhoIsNodeKey] and
// [Client.WhoIsProto] when a peer is not found.
var ErrPeerNotFound = errors.New("peer not found") var ErrPeerNotFound = errors.New("peer not found")
// WhoIsNodeKey returns the owner of the given wireguard public key. // WhoIsNodeKey returns the owner of the given wireguard public key.
@ -345,7 +346,7 @@ func (lc *Client) WhoIsNodeKey(ctx context.Context, key key.NodePublic) (*apityp
// WhoIsProto returns the owner of the remoteAddr, which must be an IP or // WhoIsProto returns the owner of the remoteAddr, which must be an IP or
// IP:port, for the given protocol (tcp or udp). // IP:port, for the given protocol (tcp or udp).
// //
// If not found, the error is ErrPeerNotFound. // If not found, the error is [ErrPeerNotFound].
func (lc *Client) WhoIsProto(ctx context.Context, proto, remoteAddr string) (*apitype.WhoIsResponse, error) { func (lc *Client) WhoIsProto(ctx context.Context, proto, remoteAddr string) (*apitype.WhoIsResponse, error) {
body, err := lc.get200(ctx, "/localapi/v0/whois?proto="+url.QueryEscape(proto)+"&addr="+url.QueryEscape(remoteAddr)) body, err := lc.get200(ctx, "/localapi/v0/whois?proto="+url.QueryEscape(proto)+"&addr="+url.QueryEscape(remoteAddr))
if err != nil { if err != nil {
@ -490,7 +491,7 @@ func (lc *Client) BugReportWithOpts(ctx context.Context, opts BugReportOpts) (st
// BugReport logs and returns a log marker that can be shared by the user with support. // BugReport logs and returns a log marker that can be shared by the user with support.
// //
// This is the same as calling BugReportWithOpts and only specifying the Note // This is the same as calling [Client.BugReportWithOpts] and only specifying the Note
// field. // field.
func (lc *Client) BugReport(ctx context.Context, note string) (string, error) { func (lc *Client) BugReport(ctx context.Context, note string) (string, error) {
return lc.BugReportWithOpts(ctx, BugReportOpts{Note: note}) return lc.BugReportWithOpts(ctx, BugReportOpts{Note: note})
@ -531,7 +532,7 @@ func (lc *Client) DebugResultJSON(ctx context.Context, action string) (any, erro
return x, nil return x, nil
} }
// DebugPortmapOpts contains options for the DebugPortmap command. // DebugPortmapOpts contains options for the [Client.DebugPortmap] command.
type DebugPortmapOpts struct { type DebugPortmapOpts struct {
// Duration is how long the mapping should be created for. It defaults // Duration is how long the mapping should be created for. It defaults
// to 5 seconds if not set. // to 5 seconds if not set.
@ -677,7 +678,7 @@ func (lc *Client) WaitingFiles(ctx context.Context) ([]apitype.WaitingFile, erro
return lc.AwaitWaitingFiles(ctx, 0) return lc.AwaitWaitingFiles(ctx, 0)
} }
// AwaitWaitingFiles is like WaitingFiles but takes a duration to await for an answer. // AwaitWaitingFiles is like [Client.WaitingFiles] but takes a duration to await for an answer.
// If the duration is 0, it will return immediately. The duration is respected at second // If the duration is 0, it will return immediately. The duration is respected at second
// granularity only. If no files are available, it returns (nil, nil). // granularity only. If no files are available, it returns (nil, nil).
func (lc *Client) AwaitWaitingFiles(ctx context.Context, d time.Duration) ([]apitype.WaitingFile, error) { func (lc *Client) AwaitWaitingFiles(ctx context.Context, d time.Duration) ([]apitype.WaitingFile, error) {
@ -946,7 +947,7 @@ func (lc *Client) SetDNS(ctx context.Context, name, value string) error {
// The host may be a base DNS name (resolved from the netmap inside // The host may be a base DNS name (resolved from the netmap inside
// tailscaled), a FQDN, or an IP address. // tailscaled), a FQDN, or an IP address.
// //
// The ctx is only used for the duration of the call, not the lifetime of the net.Conn. // The ctx is only used for the duration of the call, not the lifetime of the [net.Conn].
func (lc *Client) DialTCP(ctx context.Context, host string, port uint16) (net.Conn, error) { func (lc *Client) DialTCP(ctx context.Context, host string, port uint16) (net.Conn, error) {
return lc.UserDial(ctx, "tcp", host, port) return lc.UserDial(ctx, "tcp", host, port)
} }
@ -957,7 +958,7 @@ func (lc *Client) DialTCP(ctx context.Context, host string, port uint16) (net.Co
// a FQDN, or an IP address. // a FQDN, or an IP address.
// //
// The ctx is only used for the duration of the call, not the lifetime of the // The ctx is only used for the duration of the call, not the lifetime of the
// net.Conn. // [net.Conn].
func (lc *Client) UserDial(ctx context.Context, network, host string, port uint16) (net.Conn, error) { func (lc *Client) UserDial(ctx context.Context, network, host string, port uint16) (net.Conn, error) {
connCh := make(chan net.Conn, 1) connCh := make(chan net.Conn, 1)
trace := httptrace.ClientTrace{ trace := httptrace.ClientTrace{
@ -1025,7 +1026,7 @@ func (lc *Client) CurrentDERPMap(ctx context.Context) (*tailcfg.DERPMap, error)
// //
// It returns a cached certificate from disk if it's still valid. // It returns a cached certificate from disk if it's still valid.
// //
// Deprecated: use Client.CertPair. // Deprecated: use [Client.CertPair].
func CertPair(ctx context.Context, domain string) (certPEM, keyPEM []byte, err error) { func CertPair(ctx context.Context, domain string) (certPEM, keyPEM []byte, err error) {
return defaultClient.CertPair(ctx, domain) return defaultClient.CertPair(ctx, domain)
} }
@ -1072,9 +1073,9 @@ func (lc *Client) CertPairWithValidity(ctx context.Context, domain string, minVa
// It returns a cached certificate from disk if it's still valid. // It returns a cached certificate from disk if it's still valid.
// //
// It's the right signature to use as the value of // It's the right signature to use as the value of
// tls.Config.GetCertificate. // [tls.Config.GetCertificate].
// //
// Deprecated: use Client.GetCertificate. // Deprecated: use [Client.GetCertificate].
func GetCertificate(hi *tls.ClientHelloInfo) (*tls.Certificate, error) { func GetCertificate(hi *tls.ClientHelloInfo) (*tls.Certificate, error) {
return defaultClient.GetCertificate(hi) return defaultClient.GetCertificate(hi)
} }
@ -1084,7 +1085,7 @@ func GetCertificate(hi *tls.ClientHelloInfo) (*tls.Certificate, error) {
// It returns a cached certificate from disk if it's still valid. // It returns a cached certificate from disk if it's still valid.
// //
// It's the right signature to use as the value of // It's the right signature to use as the value of
// tls.Config.GetCertificate. // [tls.Config.GetCertificate].
// //
// API maturity: this is considered a stable API. // API maturity: this is considered a stable API.
func (lc *Client) GetCertificate(hi *tls.ClientHelloInfo) (*tls.Certificate, error) { func (lc *Client) GetCertificate(hi *tls.ClientHelloInfo) (*tls.Certificate, error) {
@ -1113,7 +1114,7 @@ func (lc *Client) GetCertificate(hi *tls.ClientHelloInfo) (*tls.Certificate, err
// ExpandSNIName expands bare label name into the most likely actual TLS cert name. // ExpandSNIName expands bare label name into the most likely actual TLS cert name.
// //
// Deprecated: use Client.ExpandSNIName. // Deprecated: use [Client.ExpandSNIName].
func ExpandSNIName(ctx context.Context, name string) (fqdn string, ok bool) { func ExpandSNIName(ctx context.Context, name string) (fqdn string, ok bool) {
return defaultClient.ExpandSNIName(ctx, name) return defaultClient.ExpandSNIName(ctx, name)
} }
@ -1502,7 +1503,7 @@ func (lc *Client) SwitchProfile(ctx context.Context, profile ipn.ProfileID) erro
// DeleteProfile removes the profile with the given ID. // DeleteProfile removes the profile with the given ID.
// If the profile is the current profile, an empty profile // If the profile is the current profile, an empty profile
// will be selected as if SwitchToEmptyProfile was called. // will be selected as if [Client.SwitchToEmptyProfile] was called.
func (lc *Client) DeleteProfile(ctx context.Context, profile ipn.ProfileID) error { func (lc *Client) DeleteProfile(ctx context.Context, profile ipn.ProfileID) error {
_, err := lc.send(ctx, "DELETE", "/localapi/v0/profiles/"+url.PathEscape(string(profile)), http.StatusNoContent, nil) _, err := lc.send(ctx, "DELETE", "/localapi/v0/profiles/"+url.PathEscape(string(profile)), http.StatusNoContent, nil)
return err return err
@ -1559,7 +1560,7 @@ func (lc *Client) DebugSetExpireIn(ctx context.Context, d time.Duration) error {
// StreamDebugCapture streams a pcap-formatted packet capture. // StreamDebugCapture streams a pcap-formatted packet capture.
// //
// The provided context does not determine the lifetime of the // The provided context does not determine the lifetime of the
// returned io.ReadCloser. // returned [io.ReadCloser].
func (lc *Client) StreamDebugCapture(ctx context.Context) (io.ReadCloser, error) { func (lc *Client) StreamDebugCapture(ctx context.Context) (io.ReadCloser, error) {
req, err := http.NewRequestWithContext(ctx, "POST", "http://"+apitype.LocalAPIHost+"/localapi/v0/debug-capture", nil) req, err := http.NewRequestWithContext(ctx, "POST", "http://"+apitype.LocalAPIHost+"/localapi/v0/debug-capture", nil)
if err != nil { if err != nil {
@ -1582,7 +1583,7 @@ func (lc *Client) StreamDebugCapture(ctx context.Context) (io.ReadCloser, error)
// The context is used for the life of the watch, not just the call to // The context is used for the life of the watch, not just the call to
// WatchIPNBus. // WatchIPNBus.
// //
// The returned IPNBusWatcher's Close method must be called when done to release // The returned [IPNBusWatcher]'s Close method must be called when done to release
// resources. // resources.
// //
// A default set of ipn.Notify messages are returned but the set can be modified by mask. // A default set of ipn.Notify messages are returned but the set can be modified by mask.
@ -1609,7 +1610,7 @@ func (lc *Client) WatchIPNBus(ctx context.Context, mask ipn.NotifyWatchOpt) (*IP
}, nil }, nil
} }
// CheckUpdate returns a tailcfg.ClientVersion indicating whether or not an update is available // CheckUpdate returns a [*tailcfg.ClientVersion] indicating whether or not an update is available
// to be installed via the LocalAPI. In case the LocalAPI can't install updates, it returns a // to be installed via the LocalAPI. In case the LocalAPI can't install updates, it returns a
// ClientVersion that says that we are up to date. // ClientVersion that says that we are up to date.
func (lc *Client) CheckUpdate(ctx context.Context) (*tailcfg.ClientVersion, error) { func (lc *Client) CheckUpdate(ctx context.Context) (*tailcfg.ClientVersion, error) {
@ -1685,7 +1686,7 @@ func (lc *Client) DriveShareList(ctx context.Context) ([]*drive.Share, error) {
} }
// IPNBusWatcher is an active subscription (watch) of the local tailscaled IPN bus. // IPNBusWatcher is an active subscription (watch) of the local tailscaled IPN bus.
// It's returned by Client.WatchIPNBus. // It's returned by [Client.WatchIPNBus].
// //
// It must be closed when done. // It must be closed when done.
type IPNBusWatcher struct { type IPNBusWatcher struct {