server

Documentation

Index

• Constants
• func Init(bp *handler.BP, args interface{}) (p handler.Plugin, err error)
• type Args
• type Server
• type ServerGroup
  • func NewServerGroup(bp *handler.BP, handler server_handler.ServerHandler, configs []*Server) *ServerGroup
  • func (sg *ServerGroup) Activate() error
  • func (sg *ServerGroup) Shutdown() error
  • func (sg *ServerGroup) WaitErr() error

Constants

const PluginType = "server"

Functions

func Init

func Init(bp *handler.BP, args interface{}) (p handler.Plugin, err error)

Types

type Args

type Args struct {
	Server               []*Server     `yaml:"server"`
	Entry                []interface{} `yaml:"entry"`
	MaxConcurrentQueries int           `yaml:"max_concurrent_queries"`
}

type Server

type Server struct {
	// Protocol: server protocol, can be:
	// "", "udp" -> udp
	// "tcp" -> tcp
	// "dot", "tls" -> dns over tls
	// "doh", "https" -> dns over https (rfc 8844)
	// "http" -> dns over https (rfc 8844) but without tls
	Protocol string `yaml:"protocol"`

	// Addr: server "host:port" addr, "port" can be omitted.
	// Addr can not be empty.
	Addr string `yaml:"addr"`

	Cert                string `yaml:"cert"`                    // certificate path, used by dot, doh
	Key                 string `yaml:"key"`                     // certificate key path, used by dot, doh
	URLPath             string `yaml:"url_path"`                // used by doh, http. If it's emtpy, any path will be handled.
	GetUserIPFromHeader string `yaml:"get_user_ip_from_header"` // used by doh, http.

	Timeout     uint `yaml:"timeout"`      // (sec) used by all protocol as query timeout, default is defaultQueryTimeout.
	IdleTimeout uint `yaml:"idle_timeout"` // (sec) used by tcp, dot, doh as connection idle timeout, default is defaultIdleTimeout.
	// contains filtered or unexported fields
}

Server is not safe for concurrent use.

type ServerGroup

type ServerGroup struct {
	*handler.BP
	// contains filtered or unexported fields
}

func NewServerGroup

func NewServerGroup(bp *handler.BP, handler server_handler.ServerHandler, configs []*Server) *ServerGroup

func (*ServerGroup) Activate

func (sg *ServerGroup) Activate() error

func (*ServerGroup) Shutdown

func (sg *ServerGroup) Shutdown() error

func (*ServerGroup) WaitErr

func (sg *ServerGroup) WaitErr() error