utils

Feb 3, 2021

Changes in this version

+ func SplitLineReg(s string) []string

+ func SplitString2(s, symbol string) (s1 string, s2 string, ok bool)

+ type ConcurrentLimiter struct

+ func NewConcurrentLimiter(max int) *ConcurrentLimiter

+ func (l *ConcurrentLimiter) Available() int

+ func (l *ConcurrentLimiter) Done()

+ func (l *ConcurrentLimiter) Wait() <-chan struct{}

Jan 29, 2021

Changes in this version

+ func ApplyMaximumTTL(m *dns.Msg, ttl uint32)

+ func ApplyMinimalTTL(m *dns.Msg, ttl uint32)

+ func GetMinimalTTL(m *dns.Msg) uint32

+ func SetTTL(m *dns.Msg, ttl uint32)

+ func SplitSchemeAndHost(addr string) (protocol, host string)

+ type BytesBufPool struct

+ func NewBytesBufPool(initSize int) *BytesBufPool

+ func (p *BytesBufPool) Get() *bytes.Buffer

+ func (p *BytesBufPool) Release(b *bytes.Buffer)

+ type LRU struct

+ func NewLRU(maxSize int, onEvict func(key string, v interface{})) *LRU

+ func (q *LRU) Add(key string, v interface{})

+ func (q *LRU) Clean(f func(key string, v interface{}) (remove bool)) (removed int)

+ func (q *LRU) Del(key string)

+ func (q *LRU) Get(key string) (interface{}, bool)

+ func (q *LRU) Len() int

+ func (q *LRU) PopFirst() (key string, v interface{}, ok bool)

type NetAddr

+ func (n *NetAddr) IP() net.IP

+ type Upstream interface

+ Address func() string

+ Exchange func(qCtx *handler.Context) (*dns.Msg, error)

+ Trusted func() bool

Jan 24, 2021

Changes in this version

+ func BytesToStringUnsafe(b []byte) string

+ func GetMinimalAnswerTTL(m *dns.Msg) uint32

+ func SetAnswerTTL(m *dns.Msg, ttl uint32)

Jan 16, 2021

Changes in this version

type FallbackConfig

+ AlwaysStandby bool

+ FastFallback int

Jan 15, 2021

Changes in this version

+ func WalkExecutableCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger, ...) (err error)

+ type DefaultServerHandler struct

+ func NewDefaultServerHandler(config *DefaultServerHandlerConfig) *DefaultServerHandler

+ func (h *DefaultServerHandler) ServeDNS(ctx context.Context, qCtx *handler.Context, w ResponseWriter)

+ type DefaultServerHandlerConfig struct

+ ConcurrentLimit int

+ Entry string

+ Logger *zap.Logger

+ type DummyServerHandler struct

+ T *testing.T

+ WantErr error

+ WantMsg *dns.Msg

+ func (d *DummyServerHandler) ServeDNS(_ context.Context, qCtx *handler.Context, w ResponseWriter)

+ type ExecutableCmd interface

+ ExecCmd func(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (goTwo string, earlyStop bool, err error)

+ type ExecutableCmdSequence struct

+ func ParseExecutableCmdSequence(in []interface{}) (*ExecutableCmdSequence, error)

+ func (es *ExecutableCmdSequence) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (goTwo string, earlyStop bool, err error)

+ func (es *ExecutableCmdSequence) Len() int

+ type FallbackConfig struct

+ Primary []interface{}

+ Secondary []interface{}

+ StatLength int

+ Threshold int

+ type FallbackECS struct

+ func ParseFallbackECS(primary, secondary []interface{}, threshold, statLength int) (*FallbackECS, error)

+ func (f *FallbackECS) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (goTwo string, earlyStop bool, err error)

+ type IfBlock struct

+ func ParseIfBlock(in map[string]interface{}) (*IfBlock, error)

+ func (b *IfBlock) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (goTwo string, earlyStop bool, err error)

+ type IfBlockConfig struct

+ Exec []interface{}

+ Goto string

+ If []string

+ IfAnd []string

+ type ParallelECS struct

+ func ParseParallelECS(c *ParallelECSConfig) (*ParallelECS, error)

+ func (p *ParallelECS) ExecCmd(ctx context.Context, qCtx *handler.Context, logger *zap.Logger) (goTwo string, earlyStop bool, err error)

+ type ParallelECSConfig struct

+ Parallel [][]interface{}

+ Timeout uint

+ type ResponseWriter interface

+ Write func(m *dns.Msg) (n int, err error)

+ type ServerHandler interface

+ ServeDNS func(ctx context.Context, qCtx *handler.Context, w ResponseWriter)

Jan 13, 2021

Changes in this version

+ func ExchangeParallel(ctx context.Context, qCtx *handler.Context, upstreams []TrustedUpstream, ...) (r *dns.Msg, err error)

+ type TrustedUpstream interface

+ Address func() string

+ Exchange func(m *dns.Msg) (*dns.Msg, error)

+ Trusted func() bool

Jan 2, 2021

Changes in this version

+ func BoolLogic(ctx context.Context, qCtx *handler.Context, fs []handler.Matcher, ...) (matched bool, err error)

Dec 29, 2020

Changes in this version

+ func GenerateCertificate(dnsName string) (cert tls.Certificate, err error)

+ func LoadCertPool(certs []string) (*x509.CertPool, error)

+ func RemoveComment(s, symbol string) string

+ func SplitLine(s string) []string

+ type ExchangeSingleFlightGroup struct

+ func (g *ExchangeSingleFlightGroup) Exchange(ctx context.Context, q *dns.Msg, exchange exchangeFunc) (r *dns.Msg, err error)

Dec 18, 2020

Changes in this version

+ func GetMsgKey(m *dns.Msg) (string, error)

+ type NetAddr struct

+ func NewNetAddr(str string, network string) *NetAddr

+ func (n *NetAddr) Network() string

+ func (n *NetAddr) String() string

Dec 9, 2020

Changes in this version

+ func GetIPFromAddr(addr net.Addr) (ip net.IP, err error)

+ func ParseAddr(addr string) (protocol, host string)

+ func TryAddPort(host string, port uint16) string

Nov 27, 2020

Changes in this version

+ const IPv4UdpMaxPayload

+ const IPv6UdpMaxPayload

+ func GetMsgBuf(size int) []byte

+ func GetMsgBufFor(m *dns.Msg) ([]byte, error)

+ func GetTimer(t time.Duration) *time.Timer

+ func ReadMsgFromTCP(c io.Reader) (m *dns.Msg, n int, err error)

+ func ReadMsgFromUDP(c io.Reader, bufSize int) (m *dns.Msg, n int, err error)

+ func ReadUDPMsgFrom(c net.PacketConn, bufSize int) (m *dns.Msg, from net.Addr, n int, err error)

+ func ReleaseMsgBuf(buf []byte)

+ func ReleaseTimer(timer *time.Timer)

+ func ResetAndDrainTimer(timer *time.Timer, d time.Duration)

+ func WriteMsgToTCP(c io.Writer, m *dns.Msg) (n int, err error)

+ func WriteMsgToUDP(c io.Writer, m *dns.Msg) (n int, err error)

+ func WriteRawMsgToTCP(c io.Writer, b []byte) (n int, err error)

+ func WriteRawMsgToUDP(c io.Writer, b []byte) (n int, err error)

+ func WriteUDPMsgTo(m *dns.Msg, c net.PacketConn, to net.Addr) (n int, err error)

+ type Allocator struct

+ func NewAllocator() *Allocator

+ func (alloc *Allocator) Get(size int) []byte

+ func (alloc *Allocator) Put(buf []byte)

+ type LoadOnceCache struct

+ func NewCache() *LoadOnceCache

+ func (c *LoadOnceCache) Load(key string) (interface{}, bool)

+ func (c *LoadOnceCache) LoadFromCacheOrRawDisk(file string) (interface{}, []byte, error)

+ func (c *LoadOnceCache) Put(key string, data interface{}, ttl time.Duration)

+ func (c *LoadOnceCache) Remove(key string)