kpx

package module

Go to main page

Versions in this module

v1

v1.7.2

Mar 22, 2024

v1.7.1

Feb 20, 2024

Changes in this version

+ var NativeKerberos = &NoKerberos — darwin/amd64, js/wasm

+ type NoKerberos struct — darwin/amd64, js/wasm

+ func (k *NoKerberos) SafeGetToken(protocol string, host string) (*string, error)

+ func (k *NoKerberos) SafeTryLogin() error

v1.7.0

Feb 20, 2024

Changes in this version

+ const CREDENTIAL_KERBEROS

+ var NativeKerberos = &LinuxKerberos — linux/amd64

+ var NativeKerberos = &WindowsKerberos — windows/amd64

+ type LinuxKerberos struct — linux/amd64

+ func (k *LinuxKerberos) SafeGetToken(protocol string, host string) (*string, error)

+ func (k *LinuxKerberos) SafeTryLogin() error

+ type WindowsKerberos struct — windows/amd64

+ func (k *WindowsKerberos) SafeGetToken(protocol string, host string) (*string, error)

+ func (k *WindowsKerberos) SafeTryLogin() error

v1.6.1

Jan 30, 2024

v1.6.0

Jan 30, 2024

Changes in this version

+ const EXPERIMENTAL_CONNETION_POOLS

+ const EXPERIMENTAL_HOSTS_CACHE

type Conf

+ Experimental string

+ type HostCache struct

v1.5.5

Nov 22, 2023

v1.5.4

Nov 22, 2023

v1.5.3

Aug 30, 2023

v1.5.2

Aug 30, 2023

v1.5.1

Aug 29, 2023

Changes in this version

+ func ConfigureConn(conn net.Conn)

+ type CloseAwareConn struct

+ func NewCloseAwareConn(dialer *net.Dialer, network string, proxy string, reqId int32) (*CloseAwareConn, error)

+ func (cc *CloseAwareConn) Close() error

+ func (cc *CloseAwareConn) LocalAddr() net.Addr

+ func (cc *CloseAwareConn) ReOpen() error

+ func (cc *CloseAwareConn) Read(b []byte) (n int, err error)

+ func (cc *CloseAwareConn) RemoteAddr() net.Addr

+ func (cc *CloseAwareConn) Reset(reqId int32)

+ func (cc *CloseAwareConn) SetDeadline(t time.Time) error

+ func (cc *CloseAwareConn) SetReadDeadline(t time.Time) error

+ func (cc *CloseAwareConn) SetWriteDeadline(t time.Time) error

+ func (cc *CloseAwareConn) Write(b []byte) (n int, err error)

v1.5.0

Aug 25, 2023

Changes in this version

+ const CT_PLAIN_UTF8

+ const DEFAULT_CLOSE_TIMEOUT

+ const DEFAULT_CONNECT_TIMEOUT

+ const DEFAULT_IDLE_TIMOUT

+ const ENCRYPTED

+ const HEADER_MAX_SIZE

+ const POOL_CLOSE_TIMEOUT

+ const POOL_CLOSE_TIMEOUT_ADD

+ var AppDefaultDomain = ".EXAMPLE.COM"

+ var AppDefaultKrb5 = ...

+ var AppName = "kpx"

+ var AppUpdateUrl = "https://api.github.com/repos/momiji/kpx/releases/latest"

+ var AppUrl = "https://github.com/momiji/kpx"

+ var AppVersion = "dev"

+ var ConfProxyContinue = ConfProxy

+ var ErrLineTooLong = errors.New("header line too long")

+ var HelpTemplate = ...

+ var HelpValue = ""

+ var HttpVersions = [...]HttpVersion

+ var UsageTemplate = ...

+ var UsageValue = ""

+ var VersionTemplate = "{{.AppName}} {{.AppVersion}} - {{.AppUrl}}"

+ var VersionValue = ""

+ func Main()

+ func NewBasicCACertConfig(cn string, serial int64) *x509.Certificate

+ func NewBasicHttpsCertConfig(cn string, names []string, serial int64) *x509.Certificate

+ func NewChunkedReader(r io.Reader) io.Reader

+ func NewChunkedWriter(w io.Writer) io.WriteCloser

+ type AtomicBool int32

+ func NewAtomicBool(ok bool) *AtomicBool

+ func (ab *AtomicBool) IsSet() bool

+ func (ab *AtomicBool) Set()

+ func (ab *AtomicBool) SetTo(yes bool)

+ func (ab *AtomicBool) SetToIf(old, new bool) (set bool)

+ func (ab *AtomicBool) UnSet()

+ type AtomicInt int32

+ func NewAtomicInt(val int32) *AtomicInt

+ func (ab *AtomicInt) DecrementAndGet(delta int32) int32

+ func (ab *AtomicInt) Get() int32

+ func (ab *AtomicInt) IncrementAndGet(delta int32) int32

+ func (ab *AtomicInt) Set(val int32)

+ type Cert struct

+ Priv *rsa.PrivateKey

+ Pub *x509.Certificate

+ func NewCert(cert *x509.Certificate, bits int, ca *Cert) (*Cert, error)

+ func NewCertFromFiles(public, private string) (*Cert, error)

+ func NewCertFromPEM(public, private string) (*Cert, error)

+ func NewPbkdfCert(cert *x509.Certificate, bits int, ca *Cert, password []byte, salt []byte, ...) (*Cert, error)

+ func (c *Cert) SaveToFiles(public, private string) error

+ func (c *Cert) ToPEM() (string, string, error)

+ type CertsManager struct

+ func NewCertsManager(ca *Cert, prefix string, names []string) (*CertsManager, error)

+ func (c *CertsManager) GetCertificate(dns string) (*tls.Certificate, error)

+ type Conf struct

+ Bind string

+ Check *bool

+ CloseTimeout int

+ ConnectTimeout int

+ Credentials map[string]*ConfCred

+ Debug bool

+ Domains map[string]*string

+ IdleTimeout int

+ Krb5 string

+ Port int

+ Proxies map[string]*ConfProxy

+ Restart bool

+ Rules []*ConfRule

+ Trace bool

+ Update bool

+ Verbose bool

+ type ConfCred struct

+ Login *string

+ Password *string

+ type ConfProxy struct

+ Credential *string

+ Credentials *string

+ Host *string

+ Pac *string

+ Port int

+ Realm *string

+ Spn *string

+ Ssl bool

+ Type *ProxyType

+ Url *string

+ Verbose *bool

+ type ConfRegex struct

+ type ConfRule struct

+ Dns *string

+ Host *string

+ Mitm bool

+ Proxy *string

+ Verbose *bool

+ type Config struct

+ func NewConfig(name string) (*Config, error)

+ type FlushAfterChunkWriter struct

+ type HttpVersion string

+ const Http10

+ const Http11

+ const Http2

+ func GetHttpVersion(version string) HttpVersion

+ func (hv HttpVersion) Order() int

+ func (hv HttpVersion) Version() string

+ type Kerberos struct

+ func NewKerberos(config *Config) *Kerberos

+ func (k *Kerberos) NewWithPassword(username, realm, password string) *client.Client

+ type KerberosClient struct

+ func NewKerberosClient(krbClient *client.Client) *KerberosClient

+ type KerberosStore struct

+ func NewKerberosStore(config *Config) (*KerberosStore, error)

+ type ManualResetEvent struct

+ func NewManualResetEvent(s bool) *ManualResetEvent

+ func (e *ManualResetEvent) Channel() chan struct{}

+ func (e *ManualResetEvent) IsSignaled() bool

+ func (e *ManualResetEvent) Reset()

+ func (e *ManualResetEvent) Signal()

+ func (e *ManualResetEvent) Wait()

+ func (e *ManualResetEvent) WaitContext(ctx context.Context) error

+ type Options struct

+ Config string

+ Debug bool

+ Encrypt bool

+ Listen string

+ Proxy string

+ ShowHelp bool

+ ShowVersion bool

+ Timeout int

+ Trace bool

+ User string

+ Verbose bool

+ type PacExecutor struct

+ func NewPac(pacJs string) (*PacExecutor, error)

+ func (p *PacExecutor) Run(url, host string) (string, error)

+ type PacResult struct

+ type PooledConnection struct

+ type PooledConnectionInfo struct

+ type Process struct

+ func NewProcess(proxy *Proxy, conn net.Conn) *Process

+ type Proxy struct

+ type ProxyRequest struct

+ func (r *ProxyRequest) ReadFull(buffer []byte) (int, error)

+ type ProxyType string

+ const ProxyAnonymous

+ const ProxyBasic

+ const ProxyDirect

+ const ProxyKerberos

+ const ProxyNone

+ const ProxyPac

+ const ProxySocks

+ func (pt ProxyType) Name() string

+ func (pt ProxyType) Value() int

+ type RandomReader struct

+ func (r RandomReader) Read(p []byte) (n int, err error)

+ type RequestHeader struct

+ type TimedConn struct

+ func NewTimedConn(conn net.Conn, ti *traceInfo) *TimedConn

+ func (tc *TimedConn) Close() error

+ func (tc *TimedConn) LocalAddr() net.Addr

+ func (tc *TimedConn) Read(b []byte) (n int, err error)

+ func (tc *TimedConn) RemoteAddr() net.Addr

+ func (tc *TimedConn) SetDeadline(_ time.Time) error

+ func (tc *TimedConn) SetReadDeadline(_ time.Time) error

+ func (tc *TimedConn) SetWriteDeadline(_ time.Time) error

+ func (tc *TimedConn) Write(b []byte) (n int, err error)

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