common

package

Go to main page

Versions in this module

v1

v1.0.10

Dec 21, 2018

Changes in this version

+ func ContextErrorMsg(err error, message string) error

v1.0.9

Nov 13, 2018

Changes in this version

+ func CopyNBuffer(dst io.Writer, src io.Reader, n int64, buf []byte) (written int64, err error)

+ func WriteRuntimeProfiles(logger Logger, outputDirectory string, blockSampleDurationSeconds int, ...)

type Conns

+ func NewConns() *Conns

+ type MetricsSource interface

+ GetMetrics func() LogFields

+ type NetDialer interface

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

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

v1.0.8

Aug 14, 2018

v1.0.7

Aug 3, 2018

Changes in this version

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

v1.0.6

Jun 26, 2018

Changes in this version

+ func ContainsWildcard(patterns []string, target string) bool

+ func TerminateHTTPConnection(responseWriter http.ResponseWriter, request *http.Request)

v1.0.5

Jun 5, 2018

Changes in this version

+ const RFC3339Milli

+ func ContainsAny(list, targets []string) bool

+ func ContainsInt(list []int, target int) bool

+ func FlipWeightedCoin(weight float64) bool

+ func FormatByteCount(bytes uint64) string

+ func GetInterfaceIPAddresses(interfaceName string) (net.IP, net.IP, error)

+ func GetStringSlice(value interface{}) ([]string, bool)

+ func MakeSecureRandomPeriod(min, max time.Duration) (time.Duration, error)

+ func MakeSecureRandomPerm(max int) ([]int, error)

+ func MakeSecureRandomRange(min, max int) (int, error)

+ func MakeSecureRandomStringBase64(byteLength int) (string, error)

+ func MakeSecureRandomStringHex(byteLength int) (string, error)

+ func NewAuthenticatedDataPackageReader(dataPackage io.ReadSeeker, signingPublicKey string) (io.Reader, error)

+ type APIParameterLogFieldFormatter func(GeoIPData, APIParameters) LogFields

+ type APIParameterValidator func(APIParameters) error

+ type APIParameters map[string]interface

+ type GeoIPData struct

+ City string

+ Country string

+ DiscoveryValue int

+ ISP string

+ type LogContext interface

+ Debug func(args ...interface{})

+ Error func(args ...interface{})

+ Info func(args ...interface{})

+ Warning func(args ...interface{})

+ type LogFields map[string]interface

+ type Logger interface

+ LogMetric func(metric string, fields LogFields)

+ WithContext func() LogContext

+ WithContextFields func(fields LogFields) LogContext

v1.0.0

Jun 21, 2017

Changes in this version

+ const OBFUSCATE_CLIENT_TO_SERVER_IV

+ const OBFUSCATE_HASH_ITERATIONS

+ const OBFUSCATE_KEY_LENGTH

+ const OBFUSCATE_MAGIC_VALUE

+ const OBFUSCATE_MAX_PADDING

+ const OBFUSCATE_SEED_LENGTH

+ const OBFUSCATE_SERVER_TO_CLIENT_IV

+ const OBFUSCATION_CONN_MODE_CLIENT

+ const OBFUSCATION_CONN_MODE_SERVER

+ const OBFUSCATION_READ_STATE_FINISHED

+ const OBFUSCATION_READ_STATE_FLUSH

+ const OBFUSCATION_READ_STATE_IDENTIFICATION_LINES

+ const OBFUSCATION_READ_STATE_KEX_PACKETS

+ const OBFUSCATION_WRITE_STATE_CLIENT_SEND_SEED_MESSAGE

+ const OBFUSCATION_WRITE_STATE_FINISHED

+ const OBFUSCATION_WRITE_STATE_IDENTIFICATION_LINE

+ const OBFUSCATION_WRITE_STATE_KEX_PACKETS

+ const OBFUSCATION_WRITE_STATE_SERVER_SEND_IDENTIFICATION_LINE_PADDING

+ const SSH_MAX_PACKET_LENGTH

+ const SSH_MAX_PADDING_LENGTH

+ const SSH_MAX_SERVER_LINE_LENGTH

+ const SSH_MSG_NEWKEYS

+ const SSH_PACKET_PREFIX_LENGTH

+ const SSH_PADDING_MULTIPLE

+ func Compress(data []byte) []byte

+ func Contains(list []string, target string) bool

+ func ContextError(err error) error

+ func Decompress(data []byte) ([]byte, error)

+ func FlipCoin() bool

+ func GenerateAuthenticatedDataPackageKeys() (string, string, error)

+ func GenerateHostName() string

+ func GetCurrentTimestamp() string

+ func GetInterfaceIPAddress(listenInterface string) (string, error)

+ func GetParentContext() string

+ func IPAddressFromAddr(addr net.Addr) string

+ func Jitter(n int64, factor float64) int64

+ func JitterDuration(d time.Duration, factor float64) time.Duration

+ func MakeRandomPeriod(min, max time.Duration) (time.Duration, error)

+ func MakeRandomStringBase64(byteLength int) (string, error)

+ func MakeRandomStringHex(byteLength int) (string, error)

+ func MakeSecureRandomBytes(length int) ([]byte, error)

+ func MakeSecureRandomInt(max int) (int, error)

+ func MakeSecureRandomInt64(max int64) (int64, error)

+ func MakeSecureRandomPadding(minLength, maxLength int) ([]byte, error)

+ func ReadAuthenticatedDataPackage(packageJSON []byte, signingPublicKey string) (string, error)

+ func RegisterHostNameGenerator(generator func() string)

+ func TruncateTimestampToHour(timestamp string) string

+ func WriteAuthenticatedDataPackage(data string, signingPublicKey, signingPrivateKey string) ([]byte, error)

+ type ActivityMonitoredConn struct

+ func NewActivityMonitoredConn(conn net.Conn, inactivityTimeout time.Duration, activeOnWrite bool, ...) (*ActivityMonitoredConn, error)

+ func (conn *ActivityMonitoredConn) GetActiveDuration() time.Duration

+ func (conn *ActivityMonitoredConn) GetLastActivityMonotime() monotime.Time

+ func (conn *ActivityMonitoredConn) GetStartTime() time.Time

+ func (conn *ActivityMonitoredConn) IsClosed() bool

+ func (conn *ActivityMonitoredConn) Read(buffer []byte) (int, error)

+ func (conn *ActivityMonitoredConn) Write(buffer []byte) (int, error)

+ type ActivityUpdater interface

+ UpdateProgress func(bytesRead, bytesWritten int64, durationNanoseconds int64)

+ type AuthenticatedDataPackage struct

+ Data string

+ Signature []byte

+ SigningPublicKeyDigest []byte

+ type BuildInfo struct

+ BuildDate string

+ BuildRepo string

+ BuildRev string

+ Dependencies json.RawMessage

+ GoVersion string

+ GomobileVersion string

+ func GetBuildInfo() *BuildInfo

+ func (bi *BuildInfo) ToMap() *map[string]interface{}

+ type Closer interface

+ IsClosed func() bool

+ type Conns struct

+ func (conns *Conns) Add(conn net.Conn) bool

+ func (conns *Conns) CloseAll()

+ func (conns *Conns) Remove(conn net.Conn)

+ func (conns *Conns) Reset()

+ type LRUConns struct

+ func NewLRUConns() *LRUConns

+ func (conns *LRUConns) Add(conn net.Conn) *LRUConnsEntry

+ func (conns *LRUConns) CloseOldest()

+ type LRUConnsEntry struct

+ func (entry *LRUConnsEntry) Remove()

+ func (entry *LRUConnsEntry) Touch()

+ type ObfuscatedSshConn struct

+ func NewObfuscatedSshConn(mode ObfuscatedSshConnMode, conn net.Conn, obfuscationKeyword string) (*ObfuscatedSshConn, error)

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

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

+ type ObfuscatedSshConnMode int

+ type ObfuscatedSshReadState int

+ type ObfuscatedSshWriteState int

+ type Obfuscator struct

+ func NewClientObfuscator(config *ObfuscatorConfig) (obfuscator *Obfuscator, err error)

+ func NewServerObfuscator(clientReader io.Reader, config *ObfuscatorConfig) (obfuscator *Obfuscator, err error)

+ func (obfuscator *Obfuscator) ObfuscateClientToServer(buffer []byte)

+ func (obfuscator *Obfuscator) ObfuscateServerToClient(buffer []byte)

+ func (obfuscator *Obfuscator) SendSeedMessage() []byte

+ type ObfuscatorConfig struct

+ Keyword string

+ MaxPadding int

+ type RateLimits struct

+ CloseAfterExhausted bool

+ ReadBytesPerSecond int64

+ ReadUnthrottledBytes int64

+ WriteBytesPerSecond int64

+ WriteUnthrottledBytes int64

+ type ReloadableFile struct

+ func NewReloadableFile(fileName string, reloadAction func([]byte) error) ReloadableFile

+ func (reloadable *ReloadableFile) LogDescription() string

+ func (reloadable *ReloadableFile) Reload() (bool, error)

+ func (reloadable *ReloadableFile) WillReload() bool

+ type Reloader interface

+ LogDescription func() string

+ Reload func() (bool, error)

+ WillReload func() bool

+ type SubnetLookup []net.IPNet

+ func NewSubnetLookup(CIDRs []string) (SubnetLookup, error)

+ func NewSubnetLookupFromRoutes(routesData []byte) (SubnetLookup, error)

+ func (lookup SubnetLookup) ContainsIPAddress(addr net.IP) bool

+ func (lookup SubnetLookup) Len() int

+ func (lookup SubnetLookup) Less(i, j int) bool

+ func (lookup SubnetLookup) Swap(i, j int)

+ type ThrottledConn struct

+ func NewThrottledConn(conn net.Conn, limits RateLimits) *ThrottledConn

+ func (conn *ThrottledConn) Read(buffer []byte) (int, error)

+ func (conn *ThrottledConn) SetLimits(limits RateLimits)

+ func (conn *ThrottledConn) Write(buffer []byte) (int, error)

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.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