base

Documentation

Index

• Variables
• func IsConnectionClosed(err error) bool
• func NetAddrToNetipAddrPort(a net.Addr) netip.AddrPort
• type ActionNotAllowedError
  • func (e ActionNotAllowedError) Error() string
• type Proxy
  • func NewBaseProxy(cfg common.ProxyConfig, rs *rules.RuleSet, db *database.DB, actions []string) (*Proxy, error)
  • func (p *Proxy) GetLogger() *zerolog.Logger
  • func (p *Proxy) RunFilters(e wrapper.Entity, logger zerolog.Logger) bool
  • func (p *Proxy) String() string

Variables

var (
	ErrShutdownTimeout = errors.New("proxy shutdown timeout")
	ErrDropped         = errors.New("connection dropped")
	ErrTLSUnsupported  = errors.New("TLS is unsopported")
)

Functions

func IsConnectionClosed

func IsConnectionClosed(err error) bool

func NetAddrToNetipAddrPort

func NetAddrToNetipAddrPort(a net.Addr) netip.AddrPort

Types

type ActionNotAllowedError

type ActionNotAllowedError struct {
	// contains filtered or unexported fields
}

func (ActionNotAllowedError) Error

func (e ActionNotAllowedError) Error() string

type Proxy

type Proxy struct {
	Config    common.ProxyConfig
	TLSConfig *tls.Config

	Closing bool
	WG      sync.WaitGroup
	Logger  zerolog.Logger
	// contains filtered or unexported fields
}

func NewBaseProxy

func NewBaseProxy(
	cfg common.ProxyConfig,
	rs *rules.RuleSet,
	db *database.DB,
	actions []string,
) (*Proxy, error)

func (*Proxy) GetLogger

func (p *Proxy) GetLogger() *zerolog.Logger

func (*Proxy) RunFilters

func (p *Proxy) RunFilters(e wrapper.Entity, logger zerolog.Logger) bool

Return true if entity passed all checks and false if filtered.

func (*Proxy) String

func (p *Proxy) String() string