Versions in this module Expand all Collapse all v1 v1.0.0 Oct 10, 2023 Changes in this version + func ConfigurationManager_ServerToClient(c ConfigurationManager) tunnelrpc.ConfigurationManager + func MarshalAuthenticateResponse(s tunnelrpc.AuthenticateResponse, p *AuthenticateResponse) error + func MarshalAuthentication(s tunnelrpc.Authentication, p *Authentication) error + func MarshalError(s tunnelrpc.ConnectionError, err error) error + func MarshalRegistrationOptions(s tunnelrpc.RegistrationOptions, p *RegistrationOptions) error + func MarshalServerInfo(s tunnelrpc.ServerInfo, p *ServerInfo) error + func MarshalTunnelRegistration(s tunnelrpc.TunnelRegistration, p *TunnelRegistration) error + func NetscaleServer_ServerToClient(s SessionManager, c ConfigurationManager) tunnelrpc.NetscaleServer + func RegistrationServer_ServerToClient(s RegistrationServer) tunnelrpc.RegistrationServer + func SessionManager_ServerToClient(s SessionManager) tunnelrpc.SessionManager + func TunnelServer_ServerToClient(s TunnelServer) tunnelrpc.TunnelServer + type AuthFail struct + func NewAuthFail(err error) AuthFail + func (ao AuthFail) Error() string + func (ao AuthFail) Serialize() AuthenticateResponse + type AuthOutcome interface + Serialize func() AuthenticateResponse + type AuthSuccess struct + func NewAuthSuccess(jwt []byte, hoursUntilRefresh uint8) AuthSuccess + func (ao AuthSuccess) JWT() []byte + func (ao AuthSuccess) RefreshAfter() time.Duration + func (ao AuthSuccess) Serialize() AuthenticateResponse + type AuthUnknown struct + func NewAuthUnknown(err error, hoursUntilRefresh uint8) AuthUnknown + func (ao AuthUnknown) Error() string + func (ao AuthUnknown) RefreshAfter() time.Duration + func (ao AuthUnknown) Serialize() AuthenticateResponse + type AuthenticateResponse struct + HoursUntilRefresh uint8 + Jwt []byte + PermanentErr string + RetryableErr string + func UnmarshalAuthenticateResponse(s tunnelrpc.AuthenticateResponse) (*AuthenticateResponse, error) + func (ar AuthenticateResponse) Outcome() AuthOutcome + type Authentication struct + Email string + Key string + OriginCAKey string + func UnmarshalAuthentication(s tunnelrpc.Authentication) (*Authentication, error) + type ClientInfo struct + Arch string + ClientID []byte + Features []string + Version string + type ConfigurationManager interface + UpdateConfiguration func(ctx context.Context, version int32, config []byte) *UpdateConfigurationResponse + type ConfigurationManager_PogsClient struct + Client capnp.Client + Conn *rpc.Conn + func (c ConfigurationManager_PogsClient) Close() error + func (c ConfigurationManager_PogsClient) UpdateConfiguration(ctx context.Context, version int32, config []byte) (*UpdateConfigurationResponse, error) + type ConfigurationManager_PogsImpl struct + func (i ConfigurationManager_PogsImpl) UpdateConfiguration(p tunnelrpc.ConfigurationManager_updateConfiguration) error + type ConnectionDetails struct + Location string + TunnelIsRemotelyManaged bool + UUID uuid.UUID + func (details *ConnectionDetails) MarshalCapnproto(s tunnelrpc.ConnectionDetails) error + func (details *ConnectionDetails) UnmarshalCapnproto(s tunnelrpc.ConnectionDetails) error + type ConnectionOptions struct + Client ClientInfo + CompressionQuality uint8 + NumPreviousAttempts uint8 + OriginLocalIP net.IP + ReplaceExisting bool + func (p *ConnectionOptions) MarshalCapnproto(s tunnelrpc.ConnectionOptions) error + func (p *ConnectionOptions) UnmarshalCapnproto(s tunnelrpc.ConnectionOptions) error + type NetscaleServer interface + type NetscaleServer_PogsClient struct + Client capnp.Client + Conn *rpc.Conn + func NewNetscaleServer_PogsClient(client capnp.Client, conn *rpc.Conn) NetscaleServer_PogsClient + func (c NetscaleServer_PogsClient) Close() error + type NetscaleServer_PogsImpl struct + type PermanentRegistrationError struct + func (*PermanentRegistrationError) IsPermanent() bool + func (pre *PermanentRegistrationError) Error() string + func (pre *PermanentRegistrationError) Serialize() *TunnelRegistration + type RPCError struct + func (re *RPCError) Error() string + func (re *RPCError) Unwrap() error + type RegisterUdpSessionResponse struct + Err error + Spans []byte + func (p *RegisterUdpSessionResponse) Marshal(s tunnelrpc.RegisterUdpSessionResponse) error + func (p *RegisterUdpSessionResponse) Unmarshal(s tunnelrpc.RegisterUdpSessionResponse) error + type RegistrationOptions struct + ClientID string + CompressionQuality uint64 + ConnectionID uint8 + ExistingTunnelPolicy tunnelrpc.ExistingTunnelPolicy + Features []string + IsAutoupdated bool + NumPreviousAttempts uint8 + OS string + OriginLocalIP string + PoolName string + RunFromTerminal bool + Tags []Tag + UUID string + Version string + func UnmarshalRegistrationOptions(s tunnelrpc.RegistrationOptions) (*RegistrationOptions, error) + type RegistrationServer interface + RegisterConnection func(ctx context.Context, auth TunnelAuth, tunnelID uuid.UUID, connIndex byte, ...) (*ConnectionDetails, error) + UnregisterConnection func(ctx context.Context) + UpdateLocalConfiguration func(ctx context.Context, config []byte) error + type RegistrationServer_PogsClient struct + Client capnp.Client + Conn *rpc.Conn + func (c RegistrationServer_PogsClient) Close() error + func (c RegistrationServer_PogsClient) RegisterConnection(ctx context.Context, auth TunnelAuth, tunnelID uuid.UUID, connIndex byte, ...) (*ConnectionDetails, error) + func (c RegistrationServer_PogsClient) SendLocalConfiguration(ctx context.Context, config []byte) error + func (c RegistrationServer_PogsClient) UnregisterConnection(ctx context.Context) error + type RegistrationServer_PogsImpl struct + func (i RegistrationServer_PogsImpl) RegisterConnection(p tunnelrpc.RegistrationServer_registerConnection) error + func (i RegistrationServer_PogsImpl) UnregisterConnection(p tunnelrpc.RegistrationServer_unregisterConnection) error + func (i RegistrationServer_PogsImpl) UpdateLocalConfiguration(c tunnelrpc.RegistrationServer_updateLocalConfiguration) error + type RetryableError struct + Delay time.Duration + func RetryErrorAfter(err error, delay time.Duration) *RetryableError + func (re *RetryableError) Error() string + func (re *RetryableError) Unwrap() error + type RetryableRegistrationError struct + func (*RetryableRegistrationError) IsPermanent() bool + func (rre *RetryableRegistrationError) Error() string + func (rre *RetryableRegistrationError) Serialize() *TunnelRegistration + type ServerInfo struct + LocationName string + func UnmarshalServerInfo(s tunnelrpc.ServerInfo) (*ServerInfo, error) + type SessionManager interface + RegisterUdpSession func(ctx context.Context, sessionID uuid.UUID, dstIP net.IP, dstPort uint16, ...) (*RegisterUdpSessionResponse, error) + UnregisterUdpSession func(ctx context.Context, sessionID uuid.UUID, message string) error + type SessionManager_PogsClient struct + Client capnp.Client + Conn *rpc.Conn + func (c SessionManager_PogsClient) Close() error + func (c SessionManager_PogsClient) RegisterUdpSession(ctx context.Context, sessionID uuid.UUID, dstIP net.IP, dstPort uint16, ...) (*RegisterUdpSessionResponse, error) + func (c SessionManager_PogsClient) UnregisterUdpSession(ctx context.Context, sessionID uuid.UUID, message string) error + type SessionManager_PogsImpl struct + func (i SessionManager_PogsImpl) RegisterUdpSession(p tunnelrpc.SessionManager_registerUdpSession) error + func (i SessionManager_PogsImpl) UnregisterUdpSession(p tunnelrpc.SessionManager_unregisterUdpSession) error + type SuccessfulTunnelRegistration struct + ConnDigest []byte + EventDigest []byte + LogLines []string + TunnelID string + Url string + type Tag struct + Name string + Value string + type TunnelAuth struct + AccountTag string + TunnelSecret []byte + func (a *TunnelAuth) MarshalCapnproto(s tunnelrpc.TunnelAuth) error + func (a *TunnelAuth) UnmarshalCapnproto(s tunnelrpc.TunnelAuth) error + type TunnelRegistration struct + Err string + PermanentFailure bool + RetryAfterSeconds uint16 + func NewSuccessfulTunnelRegistration(url string, logLines []string, tunnelID string, eventDigest []byte, ...) *TunnelRegistration + func UnmarshalTunnelRegistration(s tunnelrpc.TunnelRegistration) (*TunnelRegistration, error) + func (tr TunnelRegistration) DeserializeError() TunnelRegistrationError + type TunnelRegistrationError interface + IsPermanent func() bool + Serialize func() *TunnelRegistration + func NewPermanentRegistrationError(err error) TunnelRegistrationError + func NewRetryableRegistrationError(err error, retryAfterSeconds uint16) TunnelRegistrationError + type TunnelServer interface + Authenticate func(ctx context.Context, originCert []byte, hostname string, ...) (*AuthenticateResponse, error) + GetServerInfo func(ctx context.Context) (*ServerInfo, error) + ReconnectTunnel func(ctx context.Context, jwt, eventDigest, connDigest []byte, hostname string, ...) (*TunnelRegistration, error) + RegisterTunnel func(ctx context.Context, originCert []byte, hostname string, ...) *TunnelRegistration + UnregisterTunnel func(ctx context.Context, gracePeriodNanoSec int64) error + type TunnelServer_PogsClient struct + Client capnp.Client + Conn *rpc.Conn + func (c TunnelServer_PogsClient) Authenticate(ctx context.Context, originCert []byte, hostname string, ...) (*AuthenticateResponse, error) + func (c TunnelServer_PogsClient) Close() error + func (c TunnelServer_PogsClient) GetServerInfo(ctx context.Context) (*ServerInfo, error) + func (c TunnelServer_PogsClient) ReconnectTunnel(ctx context.Context, jwt, eventDigest []byte, connDigest []byte, ...) *TunnelRegistration + func (c TunnelServer_PogsClient) RegisterTunnel(ctx context.Context, originCert []byte, hostname string, ...) *TunnelRegistration + func (c TunnelServer_PogsClient) UnregisterTunnel(ctx context.Context, gracePeriodNanoSec int64) error + type TunnelServer_PogsImpl struct + func (i TunnelServer_PogsImpl) Authenticate(p tunnelrpc.TunnelServer_authenticate) error + func (i TunnelServer_PogsImpl) GetServerInfo(p tunnelrpc.TunnelServer_getServerInfo) error + func (i TunnelServer_PogsImpl) ObsoleteDeclarativeTunnelConnect(p tunnelrpc.TunnelServer_obsoleteDeclarativeTunnelConnect) error + func (i TunnelServer_PogsImpl) ReconnectTunnel(p tunnelrpc.TunnelServer_reconnectTunnel) error + func (i TunnelServer_PogsImpl) RegisterTunnel(p tunnelrpc.TunnelServer_registerTunnel) error + func (i TunnelServer_PogsImpl) UnregisterTunnel(p tunnelrpc.TunnelServer_unregisterTunnel) error + type UpdateConfigurationResponse struct + Err error + LastAppliedVersion int32 + func (p *UpdateConfigurationResponse) Marshal(s tunnelrpc.UpdateConfigurationResponse) error + func (p *UpdateConfigurationResponse) Unmarshal(s tunnelrpc.UpdateConfigurationResponse) error