runner

Documentation

Overview

Package runner contains the internal logic

Index

• func GetUpdateCallback() func()
• type Options
  • func ParseOptions() (*Options, error)
• type Runner
  • func NewRunner(options *Options) (*Runner, error)
  • func (r *Runner) Close()
  • func (r *Runner) Run() error

Functions

func GetUpdateCallback

func GetUpdateCallback() func()

GetUpdateCallback returns a callback function that updates proxify

Types

type Options

type Options struct {
	OutputDirectory             string
	ConfigDir                   string
	CertCacheSize               int
	Verbosity                   types.Verbosity
	Version                     bool
	ListenAddrHTTP              string
	ListenAddrSocks5            string
	ListenDNSAddr               string
	DNSMapping                  string              // DNSMapping contains user provided hosts
	DNSFallbackResolver         string              // Listen DNS Ip and port (ip:port)
	NoColor                     bool                // No Color
	RequestDSL                  goflags.StringSlice // Request Filter DSL
	RequestMatchReplaceDSL      goflags.StringSlice // Request Match-Replace DSL
	ResponseDSL                 goflags.StringSlice // Response Filter DSL
	ResponseMatchReplaceDSL     goflags.StringSlice // Request Match-Replace DSL
	UpstreamHTTPProxies         goflags.StringSlice // Upstream HTTP comma separated Proxies (e.g. http://proxyip:proxyport)
	UpstreamSocks5Proxies       goflags.StringSlice // Upstream SOCKS5 comma separated Proxies (e.g. socks5://proxyip:proxyport)
	UpstreamProxyRequestsNumber int                 // Number of requests before switching upstream proxy
	DumpRequest                 bool                // Dump requests in separate files
	DumpResponse                bool                // Dump responses in separate files
	OutCAFile                   string
	Deny                        goflags.StringSlice // Deny ip/cidr
	Allow                       goflags.StringSlice // Allow ip/cidr
	Elastic                     elastic.Options
	Kafka                       kafka.Options
	PassThrough                 goflags.StringSlice // Passthrough items list
	MaxSize                     int
	DisableUpdateCheck          bool // DisableUpdateCheck disables automatic update check
	OutputJsonl                 bool // OutputJsonl outputs data in JSONL format
}

Options of the runner

func ParseOptions

func ParseOptions() (*Options, error)

type Runner

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

Runner contains the internal logic of the program

func NewRunner

func NewRunner(options *Options) (*Runner, error)

NewRunner instance

func (*Runner) Close

func (r *Runner) Close()

Close the runner instance

func (*Runner) Run

func (r *Runner) Run() error

Run polling and notification