dispatcher

Nov 26, 2020

Changes in this version

type Dispatcher

+ func (d *Dispatcher) Dispatch(ctx context.Context, q *dns.Msg) (*dns.Msg, error)

Sep 11, 2020

Changes in this version

+ type BasicUpstreamConfig struct

+ Addr string

+ Deduplicate bool

+ DoH struct{ ... }

+ DoT struct{ ... }

+ EDNS0 struct{ ... }

+ InsecureSkipVerify bool

+ MaxConcurrentQueries int

+ Policies struct{ ... }

+ Protocol string

+ Socks5 string

+ TCP struct{ ... }

Aug 19, 2020

Changes in this version

+ var ErrUpstreamsFailed = errors.New("all upstreams failed or not respond in time")

+ func SetLoggerLevel(level logrus.Level)

type BasicServerConfig

+ Deduplicate bool

+ EDNS0 struct{ ... }

+ MaxConcurrentQueries int

+ Policies struct{ ... }

type Config

+ Upstream map[string]*BasicServerConfig

Aug 5, 2020

Changes in this version

type Dispatcher

+ func (d *Dispatcher) StartServer() error

Jun 12, 2020

Changes in this version

+ const MaxUDPSize

+ var ErrServerFailed = errors.New("server failed")

+ func GenConfig(p string) error

+ type BasicServerConfig struct

+ Addr string

+ DoH struct{ ... }

+ DoT struct{ ... }

+ InsecureSkipVerify bool

+ Protocol string

+ Socks5 string

+ TCP struct{ ... }

+ type Config struct

+ Bind struct{ ... }

+ CA struct{ ... }

+ Dispatcher struct{ ... }

+ ECS struct{ ... }

+ Server struct{ ... }

+ func LoadConfig(p string) (*Config, error)

+ type Dispatcher struct

+ func InitDispatcher(conf *Config, entry *logrus.Entry) (*Dispatcher, error)

+ func (d *Dispatcher) ListenAndServe(network, addr string, maxUDPSize int) error

+ func (d *Dispatcher) ServeDNS(ctx context.Context, q *dns.Msg) (r *dns.Msg, err error)

+ type Upstream interface

+ Exchange func(ctx context.Context, qRaw []byte) (rRaw *bufpool.MsgBuf, err error)

+ func NewUpstream(sc *BasicServerConfig, maxConcurrentQueries int, rootCAs *x509.CertPool) (Upstream, error)