mtglib

package

Go to main page

Versions in this module

v2

v2.1.7

Aug 9, 2022

v2.1.6

Mar 21, 2022

Changes in this version

+ var ErrIPAllowlistIsNotDefined = errors.New("ip allowlist is not defined")

type EventIPBlocklisted

+ IsBlockList bool

+ func NewEventIPAllowlisted(remoteIP net.IP) EventIPBlocklisted

type ProxyOpts

+ IPAllowlist IPBlocklist

v2.1.5

Mar 11, 2022

Changes in this version

+ type EventIPListSize struct

+ IsBlockList bool

+ Size int

+ func NewEventIPListSize(size int, isBlockList bool) EventIPListSize

+ func (e EventIPListSize) StreamID() string

+ func (e EventIPListSize) Timestamp() time.Time

type IPBlocklist

+ Run func(time.Duration)

+ Shutdown func()

v2.1.4

Dec 3, 2021

v2.1.3

Dec 2, 2021

Changes in this version

type ProxyOpts

+ IPWhitelist IPBlocklist

v2.1.2

Oct 5, 2021

Changes in this version

type Logger

+ BindJSON func(name, value string) Logger

type ProxyOpts

+ AllowFallbackOnUnknownDC bool

v2.1.1

Aug 30, 2021

Changes in this version

+ const TCPRelayReadTimeout

v2.1.0

Jul 31, 2021

Changes in this version

type Secret

+ func (s *Secret) Set(text string) error

v2.0.1

May 17, 2021

v2.0.0

May 5, 2021

Changes in this version

+ const ConnectionIDBytesLength

+ const DefaultBufferSize

+ const DefaultConcurrency

+ const DefaultDomainFrontingPort

+ const DefaultIdleTimeout

+ const DefaultPreferIP

+ const DefaultTolerateTimeSkewness

+ const SecretKeyLength

+ var ErrAntiReplayCacheIsNotDefined = errors.New("anti-replay cache is not defined")

+ var ErrEventStreamIsNotDefined = errors.New("event stream is not defined")

+ var ErrIPBlocklistIsNotDefined = errors.New("ip blocklist is not defined")

+ var ErrLoggerIsNotDefined = errors.New("logger is not defined")

+ var ErrNetworkIsNotDefined = errors.New("network is not defined")

+ var ErrSecretEmpty = errors.New("secret is empty")

+ var ErrSecretInvalid = errors.New("secret is invalid")

+ type AntiReplayCache interface

+ SeenBefore func(data []byte) bool

+ type Event interface

+ StreamID func() string

+ Timestamp func() time.Time

+ type EventConcurrencyLimited struct

+ func NewEventConcurrencyLimited() EventConcurrencyLimited

+ func (e EventConcurrencyLimited) StreamID() string

+ func (e EventConcurrencyLimited) Timestamp() time.Time

+ type EventConnectedToDC struct

+ DC int

+ RemoteIP net.IP

+ func NewEventConnectedToDC(streamID string, remoteIP net.IP, dc int) EventConnectedToDC

+ func (e EventConnectedToDC) StreamID() string

+ func (e EventConnectedToDC) Timestamp() time.Time

+ type EventDomainFronting struct

+ func NewEventDomainFronting(streamID string) EventDomainFronting

+ func (e EventDomainFronting) StreamID() string

+ func (e EventDomainFronting) Timestamp() time.Time

+ type EventFinish struct

+ func NewEventFinish(streamID string) EventFinish

+ func (e EventFinish) StreamID() string

+ func (e EventFinish) Timestamp() time.Time

+ type EventIPBlocklisted struct

+ RemoteIP net.IP

+ func NewEventIPBlocklisted(remoteIP net.IP) EventIPBlocklisted

+ func (e EventIPBlocklisted) StreamID() string

+ func (e EventIPBlocklisted) Timestamp() time.Time

+ type EventReplayAttack struct

+ func NewEventReplayAttack(streamID string) EventReplayAttack

+ func (e EventReplayAttack) StreamID() string

+ func (e EventReplayAttack) Timestamp() time.Time

+ type EventStart struct

+ RemoteIP net.IP

+ func NewEventStart(streamID string, remoteIP net.IP) EventStart

+ func (e EventStart) StreamID() string

+ func (e EventStart) Timestamp() time.Time

+ type EventStream interface

+ Send func(context.Context, Event)

+ type EventTraffic struct

+ IsRead bool

+ Traffic uint

+ func NewEventTraffic(streamID string, traffic uint, isRead bool) EventTraffic

+ func (e EventTraffic) StreamID() string

+ func (e EventTraffic) Timestamp() time.Time

+ type IPBlocklist interface

+ Contains func(net.IP) bool

+ type Logger interface

+ BindInt func(name string, value int) Logger

+ BindStr func(name, value string) Logger

+ Debug func(msg string)

+ DebugError func(msg string, err error)

+ Info func(msg string)

+ InfoError func(msg string, err error)

+ Named func(name string) Logger

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

+ Warning func(msg string)

+ WarningError func(msg string, err error)

+ type Network interface

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

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

+ MakeHTTPClient func(func(ctx context.Context, network, address string) (net.Conn, error)) *http.Client

+ type Proxy struct

+ func NewProxy(opts ProxyOpts) (*Proxy, error)

+ func (p *Proxy) DomainFrontingAddress() string

+ func (p *Proxy) Serve(listener net.Listener) error

+ func (p *Proxy) ServeConn(conn net.Conn)

+ func (p *Proxy) Shutdown()

+ type ProxyOpts struct

+ AntiReplayCache AntiReplayCache

+ BufferSize uint

+ Concurrency uint

+ DomainFrontingPort uint

+ EventStream EventStream

+ IPBlocklist IPBlocklist

+ IdleTimeout time.Duration

+ Logger Logger

+ Network Network

+ PreferIP string

+ Secret Secret

+ TolerateTimeSkewness time.Duration

+ UseTestDCs bool

+ type Secret struct

+ Host string

+ Key [SecretKeyLength]byte

+ func GenerateSecret(hostname string) Secret

+ func ParseSecret(secret string) (Secret, error)

+ func (s *Secret) UnmarshalText(data []byte) error

+ func (s Secret) Base64() string

+ func (s Secret) Hex() string

+ func (s Secret) MarshalText() ([]byte, error)

+ func (s Secret) String() string

+ func (s Secret) Valid() bool

v2.0.0-rc1

Apr 9, 2021

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