server

package

Go to main page

Versions in this module

v1

v1.0.10

Dec 21, 2018

Changes in this version

+ const PADDING_MAX_BYTES

type TrafficRulesFilter

+ ISPs []string

type TrafficRulesSet

+ MeekRateLimiterISPs []string

v1.0.9

Nov 13, 2018

Changes in this version

+ const PRE_HANDSHAKE_RANDOM_STREAM_MAX_COUNT

+ const RANDOM_STREAM_MAX_BYTES

type Config

+ MarionetteFormat string

type GenerateConfigParams

+ MarionetteFormat string

type TunnelServer

+ func (server *TunnelServer) UpdateClientAPIParameters(sessionID string, apiParams common.APIParameters) error

v1.0.8

Aug 14, 2018

v1.0.7

Aug 3, 2018

v1.0.6

Jun 26, 2018

Changes in this version

+ const DEFAULT_MEEK_RATE_LIMITER_GARBAGE_COLLECTOR_TRIGGER_COUNT

+ const DEFAULT_MEEK_RATE_LIMITER_REAP_HISTORY_FREQUENCY_SECONDS

type TrafficRulesSet

+ MeekRateLimiterGarbageCollectionTriggerCount int

+ MeekRateLimiterHistorySize int

+ MeekRateLimiterReapHistoryFrequencySeconds int

+ MeekRateLimiterRegions []string

+ MeekRateLimiterThresholdSeconds int

+ func (set *TrafficRulesSet) GetMeekRateLimiterConfig() (int, int, []string, int, int)

v1.0.5

Jun 5, 2018

Changes in this version

+ const MAX_AUTHORIZATIONS

+ const SERVER_OSL_CONFIG_FILENAME

+ const SERVER_TACTICS_CONFIG_FILENAME

+ const SERVER_TRAFFIC_RULES_CONFIG_FILENAME

+ const SSH_BEGIN_HANDSHAKE_TIMEOUT

+ const SSH_KEEP_ALIVE_PAYLOAD_MAX_BYTES

+ const SSH_KEEP_ALIVE_PAYLOAD_MIN_BYTES

+ func CommonLogger(contextLogger *ContextLogger) *commonLogger

type Config

+ AccessControlVerificationKeyRing accesscontrol.VerificationKeyRing

+ MaxConcurrentSSHHandshakes int

+ PacketTunnelDownstreamPacketQueueSize int

+ PacketTunnelEgressInterface string

+ PacketTunnelSessionIdleExpirySeconds int

+ PacketTunnelSudoNetworkConfigCommands bool

+ PeriodicGarbageCollectionSeconds int

+ RunPacketTunnel bool

+ TacticsConfigFilename string

+ func (config *Config) RunPeriodicGarbageCollection() bool

type DNSResolver

+ func (dns *DNSResolver) GetAllIPv4() []net.IP

+ func (dns *DNSResolver) GetAllIPv6() []net.IP

type GenerateConfigParams

+ OSLConfigFilename string

+ TacticsConfigFilename string

+ TacticsRequestObfuscatedKey string

+ TacticsRequestPublicKey string

+ TrafficRulesConfigFilename string

type GeoIPService

+ func (geoIP *GeoIPService) InSessionCache(sessionID string) bool

type RateLimits

+ UnthrottleFirstTunnelOnly *bool

type SupportServices

+ PacketTunnelServer *tun.Server

+ TacticsServer *tactics.Server

type TrafficRulesFilter

+ AuthorizationsRevoked bool

+ AuthorizedAccessTypes []string

type TunnelServer

+ func (server *TunnelServer) ExpectClientDomainBytes(sessionID string) (bool, error)

v1.0.0

Jun 21, 2017

Changes in this version

+ const CLIENT_PLATFORM_ANDROID

+ const CLIENT_PLATFORM_IOS

+ const CLIENT_PLATFORM_WINDOWS

+ const CLIENT_VERIFICATION_TTL_SECONDS

+ const DEFAULT_DIAL_TCP_PORT_FORWARD_TIMEOUT_MILLISECONDS

+ const DEFAULT_IDLE_TCP_PORT_FORWARD_TIMEOUT_MILLISECONDS

+ const DEFAULT_IDLE_UDP_PORT_FORWARD_TIMEOUT_MILLISECONDS

+ const DEFAULT_MAX_TCP_DIALING_PORT_FORWARD_COUNT

+ const DEFAULT_MAX_TCP_PORT_FORWARD_COUNT

+ const DEFAULT_MAX_UDP_PORT_FORWARD_COUNT

+ const DEFAULT_SERVER_IP_ADDRESS

+ const DISCOVERY_VALUE_KEY_BYTE_LENGTH

+ const DNS_RESOLVER_PORT

+ const DNS_SYSTEM_CONFIG_FILENAME

+ const DNS_SYSTEM_CONFIG_RELOAD_PERIOD

+ const GEOIP_SESSION_CACHE_TTL

+ const GEOIP_UNKNOWN_VALUE

+ const MAX_API_PARAMS_SIZE

+ const MEEK_DEFAULT_POOL_BUFFER_COUNT

+ const MEEK_DEFAULT_POOL_BUFFER_LENGTH

+ const MEEK_DEFAULT_RESPONSE_BUFFER_LENGTH

+ const MEEK_EXTENDED_TURN_AROUND_TIMEOUT

+ const MEEK_HTTP_CLIENT_IO_TIMEOUT

+ const MEEK_MAX_REQUEST_PAYLOAD_LENGTH

+ const MEEK_MAX_SESSION_ID_LENGTH

+ const MEEK_MAX_SESSION_STALENESS

+ const MEEK_MIN_SESSION_ID_LENGTH

+ const MEEK_PROTOCOL_VERSION_1

+ const MEEK_PROTOCOL_VERSION_2

+ const MEEK_PROTOCOL_VERSION_3

+ const MEEK_TURN_AROUND_TIMEOUT

+ const OSL_SESSION_CACHE_TTL

+ const SERVER_CONFIG_FILENAME

+ const SERVER_ENTRY_FILENAME

+ const SERVER_TRAFFIC_RULES_FILENAME

+ const SSH_AUTH_LOG_PERIOD

+ const SSH_CONNECTION_READ_DEADLINE

+ const SSH_HANDSHAKE_TIMEOUT

+ const SSH_OBFUSCATED_KEY_BYTE_LENGTH

+ const SSH_PASSWORD_BYTE_LENGTH

+ const SSH_RSA_HOST_KEY_BITS

+ const SSH_SEND_OSL_INITIAL_RETRY_DELAY

+ const SSH_SEND_OSL_RETRY_FACTOR

+ const SSH_TCP_PORT_FORWARD_COPY_BUFFER_SIZE

+ const SSH_TCP_PORT_FORWARD_QUEUE_SIZE

+ const SSH_USERNAME_SUFFIX_BYTE_LENGTH

+ const WEB_SERVER_IO_TIMEOUT

+ const WEB_SERVER_SECRET_BYTE_LENGTH

+ var CLIENT_VERIFICATION_REQUIRED = false

+ func GenerateConfig(params *GenerateConfigParams) ([]byte, []byte, []byte, error)

+ func GenerateWebServerCertificate(commonName string) (string, string, error)

+ func InitLogging(config *Config) (retErr error)

+ func NewIntentionalPanicError(errorMessage string) error

+ func NewLogWriter() *io.PipeWriter

+ func RunServices(configJSON []byte) error

+ func RunWebServer(support *SupportServices, shutdownBroadcast <-chan struct{}) error

+ type CachedResponse struct

+ func NewCachedResponse(bufferSize int, extendedBufferPool *CachedResponseBufferPool) *CachedResponse

+ func (response *CachedResponse) Available() int

+ func (response *CachedResponse) CopyFromPosition(position int, writer io.Writer) (int, error)

+ func (response *CachedResponse) HasPosition(position int) bool

+ func (response *CachedResponse) Reset()

+ func (response *CachedResponse) Write(data []byte) (int, error)

+ type CachedResponseBufferPool struct

+ func NewCachedResponseBufferPool(bufferSize, bufferCount int) *CachedResponseBufferPool

+ func (pool *CachedResponseBufferPool) Get() []byte

+ func (pool *CachedResponseBufferPool) Put(buffer []byte)

+ type Config struct

+ DNSResolverIPAddress string

+ DiscoveryValueHMACKey string

+ GeoIPDatabaseFilenames []string

+ HostID string

+ LoadMonitorPeriodSeconds int

+ LogFilename string

+ LogLevel string

+ MeekCachedResponseBufferSize int

+ MeekCachedResponsePoolBufferCount int

+ MeekCachedResponsePoolBufferSize int

+ MeekCookieEncryptionPrivateKey string

+ MeekObfuscatedKey string

+ MeekProhibitedHeaders []string

+ MeekProxyForwardedForHeaders []string

+ OSLConfigFilename string

+ ObfuscatedSSHKey string

+ ProcessBlockProfileDurationSeconds int

+ ProcessCPUProfileDurationSeconds int

+ ProcessProfileOutputDirectory string

+ PsinetDatabaseFilename string

+ SSHPassword string

+ SSHPrivateKey string

+ SSHServerVersion string

+ SSHUserName string

+ ServerIPAddress string

+ SkipPanickingLogWriter bool

+ TrafficRulesFilename string

+ TunnelProtocolPorts map[string]int

+ UDPInterceptUdpgwServerAddress string

+ WebServerCertificate string

+ WebServerPort int

+ WebServerPortForwardAddress string

+ WebServerPortForwardRedirectAddress string

+ WebServerPrivateKey string

+ WebServerSecret string

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

+ func (config *Config) RunLoadMonitor() bool

+ func (config *Config) RunWebServer() bool

+ type ContextLogger struct

+ func (logger *ContextLogger) LogPanicRecover(recoverValue interface{}, stack []byte)

+ func (logger *ContextLogger) LogRawFieldsWithTimestamp(fields LogFields)

+ func (logger *ContextLogger) WithContext() *logrus.Entry

+ func (logger *ContextLogger) WithContextFields(fields LogFields) *logrus.Entry

+ type CustomJSONFormatter struct

+ func (f *CustomJSONFormatter) Format(entry *logrus.Entry) ([]byte, error)

+ type DNSResolver struct

+ func NewDNSResolver(defaultResolver string) (*DNSResolver, error)

+ func (dns *DNSResolver) Get() net.IP

+ type GenerateConfigParams struct

+ EnableSSHAPIRequests bool

+ LogFilename string

+ LogLevel string

+ ServerIPAddress string

+ SkipPanickingLogWriter bool

+ TrafficRulesFilename string

+ TunnelProtocolPorts map[string]int

+ WebServerPort int

+ type GeoIPData struct

+ City string

+ Country string

+ DiscoveryValue int

+ ISP string

+ func NewGeoIPData() GeoIPData

+ type GeoIPService struct

+ func NewGeoIPService(databaseFilenames []string, discoveryValueHMACKey string) (*GeoIPService, error)

+ func (geoIP *GeoIPService) GetSessionCache(sessionID string) GeoIPData

+ func (geoIP *GeoIPService) Lookup(ipAddress string) GeoIPData

+ func (geoIP *GeoIPService) MarkSessionCacheToExpire(sessionID string)

+ func (geoIP *GeoIPService) Reloaders() []common.Reloader

+ func (geoIP *GeoIPService) SetSessionCache(sessionID string, geoIPData GeoIPData)

+ type HTTPSServer struct

+ func (server *HTTPSServer) ServeTLS(listener net.Listener, config *tls.Config) error

+ type IntentionalPanicError struct

+ func (err IntentionalPanicError) Error() string

+ type LogFields logrus.Fields

+ type MeekServer struct

+ func NewMeekServer(support *SupportServices, listener net.Listener, ...) (*MeekServer, error)

+ func (server *MeekServer) Run() error

+ func (server *MeekServer) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)

+ type MetricsSource interface

+ GetMetrics func() LogFields

+ type PanickingLogWriter struct

+ func NewPanickingLogWriter(name string, writer io.Writer) *PanickingLogWriter

+ func (w *PanickingLogWriter) Write(p []byte) (n int, err error)

+ type ProtocolStats map[string]map[string]int64

+ type RateLimits struct

+ CloseAfterExhausted *bool

+ ReadBytesPerSecond *int64

+ ReadUnthrottledBytes *int64

+ WriteBytesPerSecond *int64

+ WriteUnthrottledBytes *int64

+ func (rateLimits *RateLimits) CommonRateLimits() common.RateLimits

+ type RegionStats map[string]map[string]map[string]int64

+ type SupportServices struct

+ Config *Config

+ DNSResolver *DNSResolver

+ GeoIPService *GeoIPService

+ OSLConfig *osl.Config

+ PsinetDatabase *psinet.Database

+ TrafficRulesSet *TrafficRulesSet

+ TunnelServer *TunnelServer

+ func NewSupportServices(config *Config) (*SupportServices, error)

+ func (support *SupportServices) Reload()

+ type TrafficRules struct

+ AllowSubnets []string

+ AllowTCPPorts []int

+ AllowUDPPorts []int

+ DialTCPPortForwardTimeoutMilliseconds *int

+ IdleTCPPortForwardTimeoutMilliseconds *int

+ IdleUDPPortForwardTimeoutMilliseconds *int

+ MaxTCPDialingPortForwardCount *int

+ MaxTCPPortForwardCount *int

+ MaxUDPPortForwardCount *int

+ RateLimits RateLimits

+ type TrafficRulesFilter struct

+ APIProtocol string

+ HandshakeParameters map[string][]string

+ Regions []string

+ TunnelProtocols []string

+ type TrafficRulesSet struct

+ DefaultRules TrafficRules

+ FilteredRules []struct{ ... }

+ func NewTrafficRulesSet(filename string) (*TrafficRulesSet, error)

+ func (set *TrafficRulesSet) GetTrafficRules(tunnelProtocol string, geoIPData GeoIPData, state handshakeState) TrafficRules

+ func (set *TrafficRulesSet) Validate() error

+ type TunnelServer struct

+ func NewTunnelServer(support *SupportServices, shutdownBroadcast <-chan struct{}) (*TunnelServer, error)

+ func (server *TunnelServer) GetClientHandshaked(sessionID string) (bool, bool, error)

+ func (server *TunnelServer) GetEstablishTunnels() bool

+ func (server *TunnelServer) GetLoadStats() (ProtocolStats, RegionStats)

+ func (server *TunnelServer) ResetAllClientOSLConfigs()

+ func (server *TunnelServer) ResetAllClientTrafficRules()

+ func (server *TunnelServer) Run() error

+ func (server *TunnelServer) SetClientHandshakeState(sessionID string, state handshakeState) error

+ func (server *TunnelServer) SetEstablishTunnels(establish bool)

+ type X5C []string

v0

v0.0.14-beta-ios

Apr 27, 2017

v0.0.14-beta-android

May 9, 2017

v0.0.13-alpha

Feb 14, 2017

v0.0.12-alpha

Dec 5, 2016

v0.0.11-alpha

Dec 5, 2016

Incompatible versions in this module

v2.0.13+incompatible

Nov 4, 2020

v2.0.12+incompatible

Aug 19, 2020

v2.0.11+incompatible

Apr 17, 2020

v2.0.10+incompatible

Jan 29, 2020

v2.0.9+incompatible

Aug 6, 2019

v2.0.8+incompatible

Jul 31, 2019

v2.0.7+incompatible

Jul 30, 2019

v2.0.6+incompatible

Jul 9, 2019

v2.0.5+incompatible

Jul 9, 2019

v2.0.4+incompatible

Jun 29, 2019

v2.0.3+incompatible

May 10, 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