handler

package
v0.25.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 13, 2021 License: GPL-3.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	PITESExecutable = iota
	PITMatcher
	PITContextConnector
	PITService
)

Variables

This section is empty.

Functions

func DelPlugin added in v0.25.2 

func DelPlugin(tag string)

DelPlugin deletes this plugin. If this plugin is a Service, DelPlugin will call Service.Shutdown(). DelPlugin will panic if Service.Shutdown() returns an err.

func GetConfigurablePluginTypes added in v0.15.0 

func GetConfigurablePluginTypes() []string

GetConfigurablePluginTypes returns all plugin types which are configurable. This should only be used in test or debug.

func InitAndRegPlugin added in v0.10.0 

func InitAndRegPlugin(c *Config, errIfDup bool) (err error)

InitAndRegPlugin inits and registers this plugin globally. This is a help func of NewPlugin + RegPlugin.

func MustRegPlugin added in v0.14.0 

func MustRegPlugin(p Plugin, errIfDup bool)

MustRegPlugin: see RegPlugin. MustRegPlugin will panic if any err occurred.

func PluginFatalErr added in v0.16.0 

func PluginFatalErr(tag string, msg string)

PluginFatalErr: If a plugin has a fatal err, call this.

func PurgePluginRegister added in v0.12.0 

func PurgePluginRegister()

PurgePluginRegister should only be used in test.

func RegInitFunc 

func RegInitFunc(pluginType string, initFunc NewPluginFunc, argsType NewArgsFunc)

RegInitFunc registers this plugin type. This should only be called in init() from the plugin package. Duplicate plugin types are not allowed.

func RegPlugin 

func RegPlugin(p Plugin, errIfDup bool) error

RegPlugin registers this Plugin globally. Duplicate Plugin tag will overwrite the old one.

func WalkExecutableCmd added in v0.24.0 

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

WalkExecutableCmd executes the ExecutableCmd, include its `goto`. This should only be used in root cmd node.

func WeakDecode added in v0.13.0 

func WeakDecode(in map[string]interface{}, output interface{}) error

WeakDecode decodes args from config to output.

Types

type BP added in v0.24.0 

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

BP means basic plugin, which implements Plugin. It also has an internal logger, for convenience.

func NewBP added in v0.24.0 

func NewBP(tag string, typ string) *BP

NewBP creates a new BP and initials its logger.

func (*BP) L added in v0.24.0 

func (p *BP) L() *zap.Logger

func (*BP) Tag added in v0.24.0 

func (p *BP) Tag() string

func (*BP) Type added in v0.24.0 

func (p *BP) Type() string

type Config 

type Config struct {
	// Tag, required
	Tag string `yaml:"tag"`

	// Type, required
	Type string `yaml:"type"`

	// Args, might be required by some plugins
	Args map[string]interface{} `yaml:"args"`
}

type Context 

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

Context is a query context that pass through plugins A Context will always have a non-nil Q. Context MUST be created by NewContext.

func NewContext added in v0.17.1 

func NewContext(q *dns.Msg, from net.Addr) *Context

NewContext creates a new query Context. q is the query dns msg. it cannot be nil, or NewContext will panic. from is the client net.Addr. It can be nil.

func (*Context) Copy 

func (ctx *Context) Copy() *Context

Copy deep copies this Context. Note that Copy won't copy registered deferred Executable. To copy them, use CopyDeferFrom after Copy.

func (*Context) CopyDeferFrom added in v0.25.2 

func (ctx *Context) CopyDeferFrom(src *Context)

CopyDeferFrom copies defer Executable from other Context.

func (*Context) DeferExec added in v0.25.0 

func (ctx *Context) DeferExec(e Executable)

DeferExec registers an deferred Executable at this Context.

func (*Context) ExecDefer added in v0.25.0 

func (ctx *Context) ExecDefer(cCtx context.Context) error

ExecDefer executes all deferred Executable registered by DeferExec.

func (*Context) From 

func (ctx *Context) From() net.Addr

From returns the client net.Addr. It might be nil.

func (*Context) Id added in v0.24.0 

func (ctx *Context) Id() uint32

Id returns the Context id. Note: This id is not the dns msg id. It's a unique uint32 growing with the number of query.

func (*Context) InfoField added in v0.24.0 

func (ctx *Context) InfoField() zap.Field

InfoField returns a zap.Field. Just for convenience.

func (*Context) Q 

func (ctx *Context) Q() *dns.Msg

Q returns the query msg. It always returns a non-nil msg.

func (*Context) R 

func (ctx *Context) R() *dns.Msg

func (*Context) SetResponse added in v0.21.0 

func (ctx *Context) SetResponse(r *dns.Msg, status ContextStatus)

func (*Context) StartTime added in v0.24.0 

func (ctx *Context) StartTime() time.Time

StartTime returns the time when the Context was created.

func (*Context) Status added in v0.21.0 

func (ctx *Context) Status() ContextStatus

type ContextConnector added in v0.25.0 

type ContextConnector interface {
	// Connect connects this ContextPlugin to its predecessor.
	Connect(ctx context.Context, qCtx *Context, pipeCtx *PipeContext) (err error)
}

type ContextPlugin added in v0.19.1 

type ContextPlugin interface {
	Plugin
	ContextConnector
}

ContextPlugin

type ContextStatus added in v0.21.0 

type ContextStatus uint8
const (
	ContextStatusWaitingResponse ContextStatus = iota
	ContextStatusResponded
	ContextStatusServerFailed
	ContextStatusDropped
	ContextStatusRejected
)

func (ContextStatus) String added in v0.21.0 

func (status ContextStatus) String() string

type DefaultServerHandler added in v0.15.0 

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

func NewDefaultServerHandler added in v0.21.0 

func NewDefaultServerHandler(config *DefaultServerHandlerConfig) *DefaultServerHandler

NewDefaultServerHandler: concurrentLimit <= 0 means no concurrent limit. Also see DefaultServerHandler.ServeDNS.

func (*DefaultServerHandler) ServeDNS added in v0.15.0 

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

ServeDNS: If entry returns an err, a SERVFAIL response will be sent back to client. If concurrentLimit is reached, the query will block and wait available token until ctx is done.

type DefaultServerHandlerConfig added in v0.21.0 

type DefaultServerHandlerConfig struct {
	// Logger is used for logging, it cannot be nil.
	Logger *zap.Logger
	// Entry is the entry ExecutablePlugin's tag. This shouldn't be empty.
	Entry string
	// ConcurrentLimit controls the max concurrent queries.
	// If ConcurrentLimit <= 0, means no limit.
	ConcurrentLimit int
}

type DummyESExecutablePlugin added in v0.25.2 

type DummyESExecutablePlugin struct {
	*BP
	WantR    *dns.Msg
	WantSkip bool
	WantErr  error
}

func (*DummyESExecutablePlugin) ExecES added in v0.25.2 

func (d *DummyESExecutablePlugin) ExecES(_ context.Context, qCtx *Context) (earlyStop bool, err error)

type DummyExecutablePlugin added in v0.24.0 

type DummyExecutablePlugin struct {
	*BP
	WantR   *dns.Msg
	WantErr error
}

func (*DummyExecutablePlugin) Exec added in v0.24.0 

func (d *DummyExecutablePlugin) Exec(_ context.Context, qCtx *Context) (err error)

type DummyMatcherPlugin added in v0.24.0 

type DummyMatcherPlugin struct {
	*BP
	Matched bool
	WantErr error
}

func (*DummyMatcherPlugin) Match added in v0.24.0 

func (d *DummyMatcherPlugin) Match(_ context.Context, _ *Context) (matched bool, err error)

type DummyServerHandler added in v0.16.0 

type DummyServerHandler struct {
	T       *testing.T
	WantMsg *dns.Msg
	WantErr error
}

func (*DummyServerHandler) ServeDNS added in v0.16.0 

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

type DummyServicePlugin added in v0.24.0 

type DummyServicePlugin struct {
	*BP
	WantShutdownErr error
}

func (*DummyServicePlugin) Shutdown added in v0.24.0 

func (d *DummyServicePlugin) Shutdown() error

type ESExecutable added in v0.25.0 

type ESExecutable interface {
	// ExecES: Execute something. earlyStop indicates that it wants
	// to stop the ExecutableCmdSequence ASAP.
	ExecES(ctx context.Context, qCtx *Context) (earlyStop bool, err error)
}

ESExecutable: Early Stoppable Executable.

type ESExecutablePlugin added in v0.25.0 

type ESExecutablePlugin interface {
	Plugin
	ESExecutable
}

type Executable added in v0.19.1 

type Executable interface {
	Exec(ctx context.Context, qCtx *Context) (err error)
}

type ExecutableCmd added in v0.20.0 

type ExecutableCmd interface {
	ExecCmd(ctx context.Context, qCtx *Context, logger *zap.Logger) (goTwo string, earlyStop bool, err error)
}

type ExecutableCmdSequence added in v0.20.0 

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

func ParseExecutableCmdSequence added in v0.24.0 

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

func (*ExecutableCmdSequence) ExecCmd added in v0.20.0 

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

ExecCmd executes the sequence.

func (*ExecutableCmdSequence) Len added in v0.24.0 

func (es *ExecutableCmdSequence) Len() int

type ExecutablePlugin added in v0.19.1 

type ExecutablePlugin interface {
	Plugin
	Executable
}

type FallbackConfig added in v0.24.0 

type FallbackConfig struct {
	// Primary exec sequence, must have at least one element.
	Primary []interface{} `yaml:"primary"`
	// Secondary exec sequence, must have at least one element.
	Secondary []interface{} `yaml:"secondary"`

	StatLength int `yaml:"stat_length"` // default is 10
	Threshold  int `yaml:"threshold"`   // default is 5
}

type FallbackECS added in v0.24.0 

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

func ParseFallbackECS added in v0.24.0 

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

func (*FallbackECS) ExecCmd added in v0.24.0 

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

type IfBlock added in v0.25.2 

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

func ParseIfBlock added in v0.24.0 

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

func (*IfBlock) ExecCmd added in v0.25.2 

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

type IfBlockConfig added in v0.20.0 

type IfBlockConfig struct {
	If    []string      `yaml:"if"`
	IfAnd []string      `yaml:"if_and"`
	Exec  []interface{} `yaml:"exec"`
	Goto  string        `yaml:"goto"`
}

type Matcher added in v0.10.0 

type Matcher interface {
	Match(ctx context.Context, qCtx *Context) (matched bool, err error)
}

type MatcherPlugin added in v0.10.0 

type MatcherPlugin interface {
	Plugin
	Matcher
}

type NewArgsFunc added in v0.24.0 

type NewArgsFunc func() interface{}

type NewPluginFunc 

type NewPluginFunc func(bp *BP, args interface{}) (p Plugin, err error)

type ParallelECS added in v0.24.0 

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

func ParseParallelECS added in v0.24.0 

func ParseParallelECS(in [][]interface{}) (*ParallelECS, error)

func (*ParallelECS) ExecCmd added in v0.24.0 

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

type ParallelECSConfig added in v0.24.0 

type ParallelECSConfig struct {
	Parallel [][]interface{} `yaml:"parallel"`
}

type PipeContext added in v0.17.1 

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

func NewPipeContext added in v0.17.1 

func NewPipeContext(s []string, logger *zap.Logger) *PipeContext

func (*PipeContext) ExecNextPlugin added in v0.17.1 

func (c *PipeContext) ExecNextPlugin(ctx context.Context, qCtx *Context) error

type Plugin 

type Plugin interface {
	Tag() string
	Type() string
}

Plugin represents the basic plugin.

func GetPluginAll added in v0.25.2 

func GetPluginAll() []Plugin

GetPluginAll returns all registered plugins. This should only be used in test or debug.

func NewPlugin added in v0.10.0 

func NewPlugin(c *Config) (p Plugin, err error)

type PluginError added in v0.25.2 

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

func NewPluginError added in v0.19.1 

func NewPluginError(tag string, err error) *PluginError

func (*PluginError) Error added in v0.25.2 

func (e *PluginError) Error() string

func (*PluginError) Unwrap added in v0.25.2 

func (e *PluginError) Unwrap() error

type PluginInterfaceType added in v0.25.0 

type PluginInterfaceType uint8

type PluginWrapper added in v0.25.0 

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

PluginWrapper wraps the original plugin to avoid extremely frequently interface conversion. To access the original plugin, use PluginWrapper.GetPlugin() Note: PluginWrapper not implements Executable. It automatically converts Executable to ESExecutable.

func GetPlugin 

func GetPlugin(tag string) (p *PluginWrapper, err error)

func (*PluginWrapper) Connect added in v0.25.0 

func (w *PluginWrapper) Connect(ctx context.Context, qCtx *Context, pipeCtx *PipeContext) (err error)

func (*PluginWrapper) ExecES added in v0.25.0 

func (w *PluginWrapper) ExecES(ctx context.Context, qCtx *Context) (earlyStop bool, err error)

func (*PluginWrapper) GetPlugin added in v0.25.0 

func (w *PluginWrapper) GetPlugin() Plugin

func (*PluginWrapper) Is added in v0.25.0 

func (w *PluginWrapper) Is(t PluginInterfaceType) bool

func (*PluginWrapper) Match added in v0.25.0 

func (w *PluginWrapper) Match(ctx context.Context, qCtx *Context) (matched bool, err error)

func (*PluginWrapper) Shutdown added in v0.25.2 

func (w *PluginWrapper) Shutdown() error

type ResponseWriter added in v0.15.0 

type ResponseWriter interface {
	Write(m *dns.Msg) (n int, err error)
}

ResponseWriter can write msg to the client.

type ServerHandler added in v0.15.0 

type ServerHandler interface {
	// ServeDNS uses ctx to control deadline, exchanges qCtx, and writes response to w.
	ServeDNS(ctx context.Context, qCtx *Context, w ResponseWriter)
}

type Service added in v0.24.0 

type Service interface {
	// Shutdown and release resources.
	Shutdown() error
}

type ServicePlugin added in v0.24.0 

type ServicePlugin interface {
	Plugin
	Service
}

ServicePlugin is a plugin that has one or more background tasks that will keep running after Init().

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.