psiphon

package

Go to main page

Versions in this module

v1

v1.0.10

Dec 21, 2018

Changes in this version

+ func CountServerEntriesWithConstraints(useUpstreamProxy bool, region string, ...) (int, int)

+ func DeleteDialParameters(serverIPAddress, networkID string) error

+ func IsTLSConnUsingHTTP2(conn net.Conn) bool

+ func NoticeEstablishTunnelTimeout(timeout time.Duration)

+ func NoticeLivenessTest(ipAddress string, metrics *livenessTestMetrics, success bool)

+ func PickUserAgentIfUnset(p *parameters.ClientParametersSnapshot, headers http.Header) (bool, string)

+ func SetDialParameters(serverIPAddress, networkID string, dialParams *DialParameters) error

type Config

+ EstablishTunnelServerAffinityGracePeriodMilliseconds *int

+ LimitQUICVersions []string

+ LimitTLSProfiles []string

+ LivenessTestMaxDownstreamBytes *int

+ LivenessTestMaxUpstreamBytes *int

+ LivenessTestMinDownstreamBytes *int

+ LivenessTestMinUpstreamBytes *int

+ ReplayCandidateCount *int

+ ReplayDialParametersTTLSeconds *int

+ func (config *Config) GetNetworkID() string

type CustomTLSConfig

+ RandomizedTLSProfileSeed *prng.Seed

+ func (config *CustomTLSConfig) EnableClientSessionCache(clientParameters *parameters.ClientParameters)

type DialConfig

+ FragmentorConfig *fragmentor.Config

+ type DialParameters struct

+ APIRequestPaddingSeed *prng.Seed

+ DialConnMetrics common.MetricsSource

+ DialPortNumber string

+ DirectDialAddress string

+ FragmentorSeed *prng.Seed

+ IsReplay bool

+ LastUsedConfigStateHash []byte

+ LastUsedTimestamp time.Time

+ LivenessTestSeed *prng.Seed

+ MeekDialAddress string

+ MeekFrontingDialAddress string

+ MeekFrontingHost string

+ MeekHostHeader string

+ MeekObfuscatorPaddingSeed *prng.Seed

+ MeekResolvedIPAddress atomic.Value

+ MeekSNIServerName string

+ MeekTransformedHostName bool

+ NetworkID string

+ ObfuscatedQUICPaddingSeed *prng.Seed

+ ObfuscatedSSHConnMetrics common.MetricsSource

+ ObfuscatorPaddingSeed *prng.Seed

+ QUICDialSNIAddress string

+ QUICVersion string

+ RandomizedTLSProfileSeed *prng.Seed

+ SSHClientVersion string

+ SSHKEXSeed *prng.Seed

+ SelectedSSHClientVersion bool

+ SelectedTLSProfile bool

+ SelectedUserAgent bool

+ ServerEntry *protocol.ServerEntry

+ TLSProfile string

+ TunnelProtocol string

+ UpstreamProxyCustomHeaderNames []string

+ UpstreamProxyType string

+ UserAgent string

+ func GetDialParameters(serverIPAddress, networkID string) (*DialParameters, error)

+ func MakeDialParameters(config *Config, ...) (*DialParameters, error)

+ func (dialParams *DialParameters) Failed()

+ func (dialParams *DialParameters) GetDialConfig() *DialConfig

+ func (dialParams *DialParameters) GetMeekConfig() *MeekConfig

+ func (dialParams *DialParameters) Succeeded()

type MeekConfig

+ MeekObfuscatorPaddingSeed *prng.Seed

+ RandomizedTLSProfileSeed *prng.Seed

+ type NetDialer struct

+ func NewNetDialer(config *DialConfig) *NetDialer

+ func (d *NetDialer) Dial(network, address string) (net.Conn, error)

+ func (d *NetDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error)

v1.0.8

Aug 14, 2018

Changes in this version

+ func CloseDataStore()

+ func CountServerEntriesWithLimits(useUpstreamProxy bool, region string, limitState *limitTunnelProtocolsState) (int, int)

+ func NewUDPConn(ctx context.Context, addr string, config *DialConfig) (net.PacketConn, *net.UDPAddr, error)

+ func OpenDataStore(config *Config) error

type Config

+ InitialLimitTunnelProtocols []string

+ InitialLimitTunnelProtocolsCandidateCount int

+ LimitIntensiveConnectionWorkers int

+ LimitTunnelProtocols []string

+ func (config *Config) UseUpstreamProxy() bool

type CustomTLSConfig

+ ClientSessionCache utls.ClientSessionCache

v1.0.6

Jun 26, 2018

v1.0.5

Jun 5, 2018

Changes in this version

+ const DATA_STORE_LAST_SERVER_ENTRY_FILTER_KEY

+ const MAX_FRAGMENTOR_ITERATIONS_PER_NOTICE

+ const MAX_FRAGMENTOR_NOTICES

+ const MEEK_MAX_REQUEST_PAYLOAD_LENGTH

+ const URL_PROXY_TUNNELED_ICY_REQUEST_PATH

+ const URL_PROXY_TUNNELED_REWRITE_REQUEST_PATH

+ func DialTCPFragmentor(ctx context.Context, addr string, config *DialConfig, tunnelProtocol string, ...) (net.Conn, error)

+ func DoGarbageCollection()

+ func MakeDownloadHTTPClient(ctx context.Context, config *Config, tunnel *Tunnel, ...) (*http.Client, error)

+ func MakeTunneledHTTPClient(config *Config, tunnel *Tunnel, skipVerify bool) (*http.Client, error)

+ func MakeUntunneledHTTPClient(ctx context.Context, config *Config, untunneledDialConfig *DialConfig, ...) (*http.Client, error)

+ func NewReadCloseSignaller(context context.Context, reader io.Reader) *readCloseSignaller

+ func NoticeActiveAuthorizationIDs(activeAuthorizationIDs []string)

+ func NoticeBindToDevice(deviceInfo string)

+ func NoticeCommonLogger() common.Logger

+ func NoticeHomepages(urls []string)

+ func NoticeNetworkID(networkID string)

+ func NoticeRequestedTactics(ipAddress, region, protocol string, dialStats *DialStats)

+ func NoticeRequestingTactics(ipAddress, region, protocol string, dialStats *DialStats)

+ func NoticeServerTimestamp(timestamp string)

+ func NoticeUserLog(message string)

+ func ResetRepetitiveNotices()

+ func SetNoticeFiles(homepageFilename string, rotatingFilename string, rotatingFileSize int, ...) error

+ func SetNoticeWriter(writer io.Writer)

+ func StreamingStoreServerEntries(config *Config, serverEntries *protocol.StreamingServerEntryDecoder, ...) error

type Config

+ Authorizations []string

+ DisableLocalHTTPProxy bool

+ DisableLocalSocksProxy bool

+ DisableTactics bool

+ FetchRemoteServerListRetryPeriodMilliseconds *int

+ FetchUpgradeRetryPeriodMilliseconds *int

+ FragmentorMaxDelayMicroseconds *int

+ FragmentorMaxTotalBytes *int

+ FragmentorMaxWriteBytes *int

+ FragmentorMinDelayMicroseconds *int

+ FragmentorMinTotalBytes *int

+ FragmentorMinWriteBytes *int

+ IgnoreHandshakeStatsRegexps bool

+ LimitMeekBufferSizes bool

+ LimitMeekConnectionWorkers int

+ NetworkID string

+ NetworkIDGetter NetworkIDGetter

+ NetworkLatencyMultiplier float64

+ ObfuscatedSSHAlgorithms []string

+ ObfuscatedSSHMaxPadding *int

+ ObfuscatedSSHMinPadding *int

+ PacketTunnelTunFileDescriptor int

+ SessionID string

+ SplitTunnelDNSServer string

+ SplitTunnelRoutesURLFormat string

+ StaggerConnectionWorkersMilliseconds int

+ TunnelProtocols []string

+ UpstreamProxyURL string

+ UseFragmentor string

+ func (config *Config) Commit() error

+ func (config *Config) GetAuthorizations() []string

+ func (config *Config) GetClientParameters() *parameters.ClientParametersSnapshot

+ func (config *Config) GetSponsorID() string

+ func (config *Config) IsCommitted() bool

+ func (config *Config) SetClientParameters(tag string, skipOnError bool, applyParameters map[string]interface{}) error

+ func (config *Config) SetDynamicConfig(sponsorID string, authorizations []string)

type Controller

+ func (controller *Controller) DirectDial(remoteAddr string) (conn net.Conn, err error)

+ func (controller *Controller) SetDynamicConfig(sponsorID string, authorizations []string)

+ func (controller *Controller) TerminateNextActiveTunnel()

type CustomTLSConfig

+ ClientParameters *parameters.ClientParameters

+ UseDialAddrSNI bool

type DialConfig

+ UpstreamProxyURL string

+ type DialStats struct

+ MeekDialAddress string

+ MeekHostHeader string

+ MeekResolvedIPAddress atomic.Value

+ MeekSNIServerName string

+ MeekTransformedHostName bool

+ SSHClientVersion string

+ SelectedSSHClientVersion bool

+ SelectedTLSProfile bool

+ SelectedUserAgent bool

+ TLSProfile string

+ UpstreamProxyCustomHeaderNames []string

+ UpstreamProxyType string

+ UserAgent string

type Dialer

+ func NewTCPFragmentorDialer(config *DialConfig, tunnelProtocol string, ...) Dialer

+ type FragmentorConn struct

+ func (fragmentor *FragmentorConn) Close() (err error)

+ func (fragmentor *FragmentorConn) IsClosed() bool

+ func (fragmentor *FragmentorConn) Write(buffer []byte) (int, error)

type MeekConfig

+ ClientParameters *parameters.ClientParameters

+ RoundTripperOnly bool

type MeekConn

+ func (meek *MeekConn) RoundTrip(ctx context.Context, endPoint string, requestBody []byte) ([]byte, error)

+ type NetworkIDGetter interface

+ GetNetworkID func() string

+ type PacketTunnelTransport struct

+ func NewPacketTunnelTransport() *PacketTunnelTransport

+ func (p *PacketTunnelTransport) Close() error

+ func (p *PacketTunnelTransport) Read(data []byte) (int, error)

+ func (p *PacketTunnelTransport) UseTunnel(tunnel *Tunnel)

+ func (p *PacketTunnelTransport) Write(data []byte) (int, error)

type ServerEntryIterator

+ func NewTacticsServerEntryIterator(config *Config) (*ServerEntryIterator, error)

+ type TacticsStorer struct

+ func GetTacticsStorer() *TacticsStorer

+ func (t *TacticsStorer) GetSpeedTestSamplesRecord(networkID string) ([]byte, error)

+ func (t *TacticsStorer) GetTacticsRecord(networkID string) ([]byte, error)

+ func (t *TacticsStorer) SetSpeedTestSamplesRecord(networkID string, record []byte) error

+ func (t *TacticsStorer) SetTacticsRecord(networkID string, record []byte) error

type Tunnel

+ func ConnectTunnel(ctx context.Context, config *Config, sessionId string, ...) (*Tunnel, error)

+ func (tunnel *Tunnel) Activate(ctx context.Context, tunnelOwner TunnelOwner) error

+ func (tunnel *Tunnel) DialPacketTunnelChannel() (net.Conn, error)

+ func (tunnel *Tunnel) IsActivated() bool

type Tunneler

+ DirectDial func(remoteAddr string) (conn net.Conn, err error)

v1.0.0

Jun 21, 2017

Changes in this version

+ const CONNECTION_WORKER_POOL_SIZE

+ const DATA_STORE_FILENAME

+ const DATA_STORE_LAST_CONNECTED_KEY

+ const DATA_STORE_OSL_REGISTRY_KEY

+ const DNS_PORT

+ const DOWNLOAD_UPGRADE_RETRY_PERIOD_SECONDS

+ const DOWNLOAD_UPGRADE_STALE_PERIOD

+ const DOWNLOAD_UPGRADE_TIMEOUT_SECONDS

+ const ESTABLISH_TUNNEL_PAUSE_PERIOD_SECONDS

+ const ESTABLISH_TUNNEL_SERVER_AFFINITY_GRACE_PERIOD

+ const ESTABLISH_TUNNEL_TIMEOUT_SECONDS

+ const ESTABLISH_TUNNEL_WORK_TIME

+ const FEEDBACK_UPLOAD_MAX_RETRIES

+ const FEEDBACK_UPLOAD_RETRY_DELAY_SECONDS

+ const FEEDBACK_UPLOAD_TIMEOUT_SECONDS

+ const FETCH_REMOTE_SERVER_LIST_RETRY_PERIOD_SECONDS

+ const FETCH_REMOTE_SERVER_LIST_STALE_PERIOD

+ const FETCH_REMOTE_SERVER_LIST_TIMEOUT_SECONDS

+ const FETCH_ROUTES_TIMEOUT_SECONDS

+ const FULL_RECEIVE_BUFFER_LENGTH

+ const HTTP_PROXY_MAX_IDLE_CONNECTIONS_PER_HOST

+ const HTTP_PROXY_ORIGIN_SERVER_TIMEOUT_SECONDS

+ const IMPAIRED_PROTOCOL_CLASSIFICATION_DURATION

+ const IMPAIRED_PROTOCOL_CLASSIFICATION_THRESHOLD

+ const LEGACY_DATA_STORE_FILENAME

+ const MAX_POLL_INTERVAL

+ const MAX_POLL_INTERVAL_JITTER

+ const MAX_SEND_PAYLOAD_LENGTH

+ const MEEK_COOKIE_MAX_PADDING

+ const MEEK_PROTOCOL_VERSION

+ const MEEK_ROUND_TRIP_RETRY_DEADLINE

+ const MEEK_ROUND_TRIP_RETRY_DELAY

+ const MEEK_ROUND_TRIP_TIMEOUT

+ const MIN_POLL_INTERVAL

+ const MIN_POLL_INTERVAL_JITTER

+ const PERSISTENT_STAT_TYPE_REMOTE_SERVER_LIST

+ const PERSISTENT_STAT_TYPE_TUNNEL

+ const POLL_INTERVAL_JITTER

+ const POLL_INTERVAL_MULTIPLIER

+ const PSIPHON_API_CLIENT_VERIFICATION_REQUEST_MAX_RETRIES

+ const PSIPHON_API_CLIENT_VERIFICATION_REQUEST_RETRY_PERIOD

+ const PSIPHON_API_CONNECTED_REQUEST_PERIOD

+ const PSIPHON_API_CONNECTED_REQUEST_RETRY_PERIOD

+ const PSIPHON_API_PERSISTENT_STATS_MAX_COUNT

+ const PSIPHON_API_SERVER_TIMEOUT_SECONDS

+ const PSIPHON_API_SHUTDOWN_SERVER_TIMEOUT

+ const PSIPHON_API_STATUS_REQUEST_PADDING_MAX_BYTES

+ const PSIPHON_API_STATUS_REQUEST_PERIOD_MAX

+ const PSIPHON_API_STATUS_REQUEST_PERIOD_MIN

+ const PSIPHON_API_STATUS_REQUEST_SHORT_PERIOD_MAX

+ const PSIPHON_API_STATUS_REQUEST_SHORT_PERIOD_MIN

+ const READ_PAYLOAD_CHUNK_LENGTH

+ const TLSProfileAndroid

+ const TLSProfileChrome

+ const TOTAL_BYTES_TRANSFERRED_NOTICE_PERIOD

+ const TRANSFORM_HOST_NAMES_ALWAYS

+ const TRANSFORM_HOST_NAMES_NEVER

+ const TUNNEL_CONNECT_TIMEOUT_SECONDS

+ const TUNNEL_OPERATE_SHUTDOWN_TIMEOUT

+ const TUNNEL_POOL_SIZE

+ const TUNNEL_PORT_FORWARD_DIAL_TIMEOUT_SECONDS

+ const TUNNEL_SSH_KEEP_ALIVE_PAYLOAD_MAX_BYTES

+ const TUNNEL_SSH_KEEP_ALIVE_PERIODIC_INACTIVE_PERIOD

+ const TUNNEL_SSH_KEEP_ALIVE_PERIODIC_TIMEOUT_SECONDS

+ const TUNNEL_SSH_KEEP_ALIVE_PERIOD_MAX

+ const TUNNEL_SSH_KEEP_ALIVE_PERIOD_MIN

+ const TUNNEL_SSH_KEEP_ALIVE_PROBE_INACTIVE_PERIOD

+ const TUNNEL_SSH_KEEP_ALIVE_PROBE_TIMEOUT_SECONDS

+ const URL_PROXY_DIRECT_REQUEST_PATH

+ const URL_PROXY_TUNNELED_REQUEST_PATH

+ func AddPKCS7Padding(src []byte, blockSize int) []byte

+ func ClearReportedPersistentStats(stats map[string][][]byte) error

+ func CountNonImpairedProtocols(region, tunnelProtocol string, impairedProtocols []string) int

+ func CountSLOKs() int

+ func CountServerEntries(region, tunnelProtocol string) int

+ func CountUnreportedPersistentStats() int

+ func CustomTLSDial(network, addr string, config *CustomTLSConfig) (net.Conn, error)

+ func DecodeCertificate(encodedCertificate string) (certificate *x509.Certificate, err error)

+ func DeleteSLOKs() error

+ func DialPluginProtocol(config *Config, loggerOutput io.Writer, pendingConns *common.Conns, ...) (bool, net.Conn, error)

+ func DialTCP(addr string, config *DialConfig) (conn net.Conn, err error)

+ func DownloadUpgrade(config *Config, attempt int, handshakeVersion string, tunnel *Tunnel, ...) error

+ func FetchCommonRemoteServerList(config *Config, attempt int, tunnel *Tunnel, untunneledDialConfig *DialConfig) error

+ func FetchObfuscatedServerLists(config *Config, attempt int, tunnel *Tunnel, untunneledDialConfig *DialConfig) error

+ func FilterUrlError(err error) error

+ func GetEmitDiagnoticNotices() bool

+ func GetKeyValue(key string) (value string, err error)

+ func GetNotice(notice []byte) (noticeType string, payload map[string]interface{}, err error)

+ func GetSLOK(id []byte) (key []byte, err error)

+ func GetServerEntryIpAddresses() (ipAddresses []string, err error)

+ func GetSplitTunnelRoutesData(region string) (data []byte, err error)

+ func GetSplitTunnelRoutesETag(region string) (etag string, err error)

+ func GetUrlETag(url string) (etag string, err error)

+ func HandleOSLRequest(tunnelOwner TunnelOwner, tunnel *Tunnel, payload []byte) error

+ func HandleServerRequest(tunnelOwner TunnelOwner, tunnel *Tunnel, name string, payload []byte) error

+ func InitDataStore(config *Config) (err error)

+ func IsAddressInUseError(err error) bool

+ func LocalProxyRelay(proxyType string, localConn, remoteConn net.Conn)

+ func LookupIP(host string, config *DialConfig) (addrs []net.IP, err error)

+ func MakeCompatibleServerEntry(serverEntry *protocol.ServerEntry) *protocol.ServerEntry

+ func MakeDownloadHttpClient(config *Config, tunnel *Tunnel, untunneledDialConfig *DialConfig, ...) (*http.Client, string, error)

+ func MakePsiphonUserAgent(config *Config) string

+ func MakeSessionId() (sessionId string, err error)

+ func MakeTunneledHttpClient(config *Config, tunnel *Tunnel, skipVerify bool, requestTimeout time.Duration) (*http.Client, error)

+ func MakeUntunneledHttpsClient(dialConfig *DialConfig, verifyLegacyCertificate *x509.Certificate, ...) (*http.Client, string, error)

+ func NoticeActiveTunnel(ipAddress, protocol string, isTCS bool)

+ func NoticeAlert(format string, args ...interface{})

+ func NoticeAvailableEgressRegions(regions []string)

+ func NoticeBuildInfo()

+ func NoticeBytesTransferred(ipAddress string, sent, received int64)

+ func NoticeCandidateServers(region, protocol string, count int)

+ func NoticeClientIsLatestVersion(availableVersion string)

+ func NoticeClientRegion(region string)

+ func NoticeClientUpgradeAvailable(version string)

+ func NoticeClientUpgradeDownloaded(filename string)

+ func NoticeClientUpgradeDownloadedBytes(bytes int64)

+ func NoticeClientVerificationRequestCompleted(ipAddress string)

+ func NoticeClientVerificationRequired(nonce string, ttlSeconds int, resetCache bool)

+ func NoticeConnectedServer(ipAddress, region, protocol string, tunnelDialStats *TunnelDialStats)

+ func NoticeConnectingServer(ipAddress, region, protocol string, tunnelDialStats *TunnelDialStats)

+ func NoticeError(format string, args ...interface{})

+ func NoticeExiting()

+ func NoticeHomepage(url string)

+ func NoticeHttpProxyPortInUse(port int)

+ func NoticeImpairedProtocolClassification(impairedProtocolClassification map[string]int)

+ func NoticeInfo(format string, args ...interface{})

+ func NoticeListeningHttpProxyPort(port int)

+ func NoticeListeningSocksProxyPort(port int)

+ func NoticeLocalProxyError(proxyType string, err error)

+ func NoticeRemoteServerListResourceDownloaded(url string)

+ func NoticeRemoteServerListResourceDownloadedBytes(url string, bytes int64)

+ func NoticeSLOKSeeded(slokID string, duplicate bool)

+ func NoticeSessionId(sessionId string)

+ func NoticeSocksProxyPortInUse(port int)

+ func NoticeSplitTunnelRegion(region string)

+ func NoticeTotalBytesTransferred(ipAddress string, sent, received int64)

+ func NoticeTunnels(count int)

+ func NoticeUntunneled(address string)

+ func NoticeUpstreamProxyError(err error)

+ func PromoteServerEntry(ipAddress string) error

+ func PutBackUnreportedPersistentStats(stats map[string][][]byte) error

+ func RecordRemoteServerListStat(url, etag string) error

+ func RecordTunnelStat(sessionId string, tunnelNumber int64, tunnelServerIpAddress string, ...) error

+ func RegisterPluginProtocol(protocolDialer PluginProtocolDialer)

+ func RegisterSSHClientVersionPicker(picker func() string)

+ func RegisterUserAgentPicker(picker func() string)

+ func ReportAvailableRegions()

+ func ResolveIP(host string, conn net.Conn) (addrs []net.IP, ttls []time.Duration, err error)

+ func ResumeDownload(httpClient *http.Client, requestUrl string, userAgent string, ...) (int64, string, error)

+ func SelectTLSProfile(useIndistinguishableTLS, useObfuscatedSessionTickets, skipVerify, ... bool) string

+ func SendFeedback(...) error

+ func SetEmitDiagnosticNotices(enable bool)

+ func SetKeyValue(key, value string) error

+ func SetNoticeOutput(output io.Writer)

+ func SetSLOK(id, key []byte) (bool, error)

+ func SetSplitTunnelRoutes(region, etag string, data []byte) error

+ func SetUrlETag(url, etag string) error

+ func StorePersistentStat(statType string, stat []byte) error

+ func StoreServerEntries(serverEntries []*protocol.ServerEntry, replaceIfExists bool) error

+ func StoreServerEntry(serverEntry *protocol.ServerEntry, replaceIfExists bool) error

+ func TakeOutUnreportedPersistentStats(maxCount int) (map[string][][]byte, error)

+ func TrimError(err error) error

+ func UserAgentIfUnset(h http.Header) (http.Header, bool)

+ func WaitForNetworkConnectivity(connectivityChecker NetworkConnectivityChecker, ...) bool

+ type Config struct

+ ClientPlatform string

+ ClientVersion string

+ ConnectionWorkerPoolSize int

+ CustomHeaders http.Header

+ DataStoreDirectory string

+ DeviceBinder DeviceBinder

+ DeviceRegion string

+ DisableApi bool

+ DisablePeriodicSshKeepAlive bool

+ DisableRemoteServerListFetcher bool

+ DnsServerGetter DnsServerGetter

+ DownloadUpgradeRetryPeriodSeconds *int

+ DownloadUpgradeTimeoutSeconds *int

+ EgressRegion string

+ EmitBytesTransferred bool

+ EmitDiagnosticNotices bool

+ EmitSLOKs bool

+ EstablishTunnelPausePeriodSeconds *int

+ EstablishTunnelTimeoutSeconds *int

+ FetchRemoteServerListRetryPeriodSeconds *int

+ FetchRemoteServerListTimeoutSeconds *int

+ FetchRoutesTimeoutSeconds *int

+ HttpProxyOriginServerTimeoutSeconds *int

+ IPv6Synthesizer IPv6Synthesizer

+ ListenInterface string

+ LocalHttpProxyPort int

+ LocalSocksProxyPort int

+ LogFilename string

+ NetworkConnectivityChecker NetworkConnectivityChecker

+ ObfuscatedServerListDownloadDirectory string

+ ObfuscatedServerListRootURL string

+ ObfuscatedServerListRootURLs []*DownloadURL

+ PropagationChannelId string

+ PsiphonApiServerTimeoutSeconds *int

+ RateLimits common.RateLimits

+ RemoteServerListDownloadFilename string

+ RemoteServerListSignaturePublicKey string

+ RemoteServerListURLs []*DownloadURL

+ RemoteServerListUrl string

+ SplitTunnelDnsServer string

+ SplitTunnelRoutesSignaturePublicKey string

+ SplitTunnelRoutesUrlFormat string

+ SponsorId string

+ TargetApiProtocol string

+ TargetServerEntry string

+ TransformHostNames string

+ TrustedCACertificatesFilename string

+ TunnelConnectTimeoutSeconds *int

+ TunnelPoolSize int

+ TunnelPortForwardDialTimeoutSeconds *int

+ TunnelProtocol string

+ TunnelSshKeepAlivePeriodicTimeoutSeconds *int

+ TunnelSshKeepAliveProbeTimeoutSeconds *int

+ TunnelWholeDevice int

+ UpgradeDownloadClientVersionHeader string

+ UpgradeDownloadFilename string

+ UpgradeDownloadURLs []*DownloadURL

+ UpgradeDownloadUrl string

+ UpstreamProxyCustomHeaders http.Header

+ UpstreamProxyUrl string

+ UseIndistinguishableTLS bool

+ UseTrustedCACertificatesForStockTLS bool

+ func LoadConfig(configJson []byte) (*Config, error)

+ type Controller struct

+ func NewController(config *Config) (controller *Controller, err error)

+ func (controller *Controller) Dial(remoteAddr string, alwaysTunnel bool, downstreamConn net.Conn) (conn net.Conn, err error)

+ func (controller *Controller) Run(shutdownBroadcast <-chan struct{})

+ func (controller *Controller) SetClientVerificationPayloadForActiveTunnels(clientVerificationPayload string)

+ func (controller *Controller) SignalComponentFailure()

+ func (controller *Controller) SignalSeededNewSLOK()

+ func (controller *Controller) SignalTunnelFailure(tunnel *Tunnel)

+ type CustomTLSConfig struct

+ Dial Dialer

+ DialAddr string

+ ObfuscatedSessionTicketKey string

+ SNIServerName string

+ SkipVerify bool

+ TLSProfile string

+ Timeout time.Duration

+ TrustedCACertificatesFilename string

+ UseIndistinguishableTLS bool

+ VerifyLegacyCertificate *x509.Certificate

+ type DeviceBinder interface

+ BindToDevice func(fileDescriptor int) error

+ type DialConfig struct

+ ConnectTimeout time.Duration

+ CustomHeaders http.Header

+ DeviceBinder DeviceBinder

+ DeviceRegion string

+ DnsServerGetter DnsServerGetter

+ IPv6Synthesizer IPv6Synthesizer

+ PendingConns *common.Conns

+ ResolvedIPCallback func(string)

+ TrustedCACertificatesFilename string

+ UpstreamProxyUrl string

+ UseIndistinguishableTLS bool

+ type Dialer func(string, string) (net.Conn, error)

+ func NewCustomTLSDialer(config *CustomTLSConfig) Dialer

+ func NewTCPDialer(config *DialConfig) Dialer

+ type DnsServerGetter interface

+ GetPrimaryDnsServer func() string

+ GetSecondaryDnsServer func() string

+ type DownloadURL struct

+ OnlyAfterAttempts int

+ SkipVerify bool

+ URL string

+ type HttpProxy struct

+ func NewHttpProxy(config *Config, untunneledDialConfig *DialConfig, tunneler Tunneler, ...) (proxy *HttpProxy, err error)

+ func (proxy *HttpProxy) Close()

+ func (proxy *HttpProxy) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)

+ type IPv6Synthesizer interface

+ IPv6Synthesize func(IPv4Addr string) string

+ type MeekConfig struct

+ ClientTunnelProtocol string

+ DialAddress string

+ HostHeader string

+ MeekCookieEncryptionPublicKey string

+ MeekObfuscatedKey string

+ PsiphonServerAddress string

+ SNIServerName string

+ SessionID string

+ TLSProfile string

+ TransformedHostName bool

+ UseHTTPS bool

+ UseObfuscatedSessionTickets bool

+ type MeekConn struct

+ func DialMeek(meekConfig *MeekConfig, dialConfig *DialConfig) (meek *MeekConn, err error)

+ func (meek *MeekConn) Close() (err error)

+ func (meek *MeekConn) IsClosed() bool

+ func (meek *MeekConn) LocalAddr() net.Addr

+ func (meek *MeekConn) Read(buffer []byte) (n int, err error)

+ func (meek *MeekConn) RemoteAddr() net.Addr

+ func (meek *MeekConn) SetDeadline(t time.Time) error

+ func (meek *MeekConn) SetReadDeadline(t time.Time) error

+ func (meek *MeekConn) SetWriteDeadline(t time.Time) error

+ func (meek *MeekConn) Write(buffer []byte) (n int, err error)

+ type NetworkConnectivityChecker interface

+ HasNetworkConnectivity func() int

+ type NoticeReceiver struct

+ func NewNoticeConsoleRewriter(writer io.Writer) *NoticeReceiver

+ func NewNoticeReceiver(callback func([]byte)) *NoticeReceiver

+ func (receiver *NoticeReceiver) Write(p []byte) (n int, err error)

+ type NoticeWriter struct

+ func NewNoticeWriter(noticeType string) *NoticeWriter

+ func (writer *NoticeWriter) Write(p []byte) (n int, err error)

+ type PluginProtocolDialer func(config *Config, loggerOutput io.Writer, pendingConns *common.Conns, ...) (bool, net.Conn, error)

+ type RemoteServerListFetcher func(config *Config, attempt int, tunnel *Tunnel, untunneledDialConfig *DialConfig) error

+ type ServerContext struct

+ func NewServerContext(tunnel *Tunnel, sessionId string) (*ServerContext, error)

+ func (serverContext *ServerContext) DoClientVerificationRequest(verificationPayload string, serverIP string) error

+ func (serverContext *ServerContext) DoConnectedRequest() error

+ func (serverContext *ServerContext) DoStatusRequest(tunnel *Tunnel) error

+ func (serverContext *ServerContext) StatsRegexps() *transferstats.Regexps

+ func (serverContext *ServerContext) TryUntunneledStatusRequest(isShutdown bool) error

+ type ServerEntryIterator struct

+ func NewServerEntryIterator(config *Config) (iterator *ServerEntryIterator, err error)

+ func (iterator *ServerEntryIterator) Close()

+ func (iterator *ServerEntryIterator) Next() (serverEntry *protocol.ServerEntry, err error)

+ func (iterator *ServerEntryIterator) Reset() error

+ type SocksProxy struct

+ func NewSocksProxy(config *Config, tunneler Tunneler, listenIP string) (proxy *SocksProxy, err error)

+ func (proxy *SocksProxy) Close()

+ type SplitTunnelClassifier struct

+ func NewSplitTunnelClassifier(config *Config, tunneler Tunneler) *SplitTunnelClassifier

+ func (classifier *SplitTunnelClassifier) IsUntunneled(targetAddress string) bool

+ func (classifier *SplitTunnelClassifier) Shutdown()

+ func (classifier *SplitTunnelClassifier) Start(fetchRoutesTunnel *Tunnel)

+ type SyncFileWriter struct

+ func NewSyncFileWriter(file *os.File) *SyncFileWriter

+ func (writer *SyncFileWriter) Write(p []byte) (n int, err error)

+ type TCPConn struct

+ func (conn *TCPConn) Close() (err error)

+ func (conn *TCPConn) CloseWrite() (err error)

+ func (conn *TCPConn) IsClosed() bool

+ type Tunnel struct

+ func EstablishTunnel(config *Config, untunneledDialConfig *DialConfig, sessionId string, ...) (tunnel *Tunnel, err error)

+ func (tunnel *Tunnel) Close(isDiscarded bool)

+ func (tunnel *Tunnel) Dial(remoteAddr string, alwaysTunnel bool, downstreamConn net.Conn) (conn net.Conn, err error)

+ func (tunnel *Tunnel) IsDiscarded() bool

+ func (tunnel *Tunnel) SendAPIRequest(name string, requestPayload []byte) ([]byte, error)

+ func (tunnel *Tunnel) SetClientVerificationPayload(clientVerificationPayload string)

+ func (tunnel *Tunnel) SignalComponentFailure()

+ type TunnelDialStats struct

+ MeekDialAddress string

+ MeekHostHeader string

+ MeekResolvedIPAddress string

+ MeekSNIServerName string

+ MeekTransformedHostName bool

+ SSHClientVersion string

+ SelectedSSHClientVersion bool

+ SelectedTLSProfile bool

+ SelectedUserAgent bool

+ TLSProfile string

+ UpstreamProxyCustomHeaderNames []string

+ UpstreamProxyType string

+ UserAgent string

+ type TunnelOwner interface

+ SignalSeededNewSLOK func()

+ SignalTunnelFailure func(tunnel *Tunnel)

+ type TunneledConn struct

+ func (conn *TunneledConn) Close() error

+ func (conn *TunneledConn) Read(buffer []byte) (n int, err error)

+ func (conn *TunneledConn) Write(buffer []byte) (n int, err error)

+ type Tunneler interface

+ Dial func(remoteAddr string, alwaysTunnel bool, downstreamConn net.Conn) (conn net.Conn, err error)

+ SignalComponentFailure func()

v0

v0.0.14-beta-ios

Apr 27, 2017

v0.0.14-beta-android

May 9, 2017

v0.0.12-alpha

Dec 5, 2016

v0.0.11-alpha

Dec 5, 2016

v0.0.8-alpha

Jul 6, 2015

v0.0.7-alpha

Feb 18, 2015

v0.0.6-alpha

Feb 11, 2015

v0.0.5-alpha

Dec 15, 2014

Incompatible versions in this module

v2.0.15+incompatible

Aug 13, 2021

v2.0.13+incompatible

Nov 4, 2020

v2.0.11+incompatible

Apr 17, 2020

v2.0.7+incompatible

Jul 30, 2019

v2.0.6+incompatible

Jul 9, 2019

v2.0.4+incompatible

Jun 29, 2019

v2.0.2+incompatible

Mar 5, 2019

v2.0.1+incompatible

Feb 21, 2019

v2.0.0+incompatible

Dec 21, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL