dns

package

v2.3.1 Latest Latest Go to latest Published: Apr 22, 2024 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/metal-stack/firewall-controller

Links

Open Source Insights

Documentation ¶

Index ¶

type DNSCache
- func (c *DNSCache) Update(lookupTime time.Time, qname string, msg *dnsgo.Msg, fqdnsfield ...[]string) (bool, error)
type DNSHandler
type DNSProxy
- func NewDNSProxy(dns string, port *uint, log logr.Logger) (*DNSProxy, error)
type DNSProxyHandler
- func NewDNSProxyHandler(log logr.Logger, cache *DNSCache) *DNSProxyHandler
- func (h *DNSProxyHandler) ServeDNS(w dnsgo.ResponseWriter, request *dnsgo.Msg)
- func (h *DNSProxyHandler) UpdateDNSServerAddr(addr string) error
type IPVersion
type RenderIPSet

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DNSCache ¶

type DNSCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*DNSCache) Update ¶

func (c *DNSCache) Update(lookupTime time.Time, qname string, msg *dnsgo.Msg, fqdnsfield ...[]string) (bool, error)

Update DNS cache. It expects that there was only one question to DNS(majority of cases). So it picks first qname and skips all others(if there is).

type DNSHandler ¶

type DNSHandler interface {
	ServeDNS(w dnsgo.ResponseWriter, r *dnsgo.Msg)
	UpdateDNSServerAddr(addr string) error
}

type DNSProxy ¶

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

func NewDNSProxy ¶

func NewDNSProxy(dns string, port *uint, log logr.Logger) (*DNSProxy, error)

func (*DNSProxy) CacheAddr ¶ added in v2.3.1

func (p *DNSProxy) CacheAddr() (string, error)

func (*DNSProxy) GetSetsForFQDN ¶

func (p *DNSProxy) GetSetsForFQDN(fqdn firewallv1.FQDNSelector, fqdnSets []firewallv1.IPSet) (result []firewallv1.IPSet)

func (*DNSProxy) GetSetsForRendering ¶

func (p *DNSProxy) GetSetsForRendering(fqdns []firewallv1.FQDNSelector) (result []RenderIPSet)

func (*DNSProxy) IsInitialized ¶

func (p *DNSProxy) IsInitialized() bool

func (*DNSProxy) Run ¶

func (p *DNSProxy) Run(ctx context.Context)

Run starts TCP/UDP servers

func (*DNSProxy) Stop ¶

func (p *DNSProxy) Stop()

Stop starts TCP/UDP servers

func (*DNSProxy) UpdateDNSServerAddr ¶

func (p *DNSProxy) UpdateDNSServerAddr(addr string) error

type DNSProxyHandler ¶

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

func NewDNSProxyHandler ¶

func NewDNSProxyHandler(log logr.Logger, cache *DNSCache) *DNSProxyHandler

func (*DNSProxyHandler) ServeDNS ¶

func (h *DNSProxyHandler) ServeDNS(w dnsgo.ResponseWriter, request *dnsgo.Msg)

func (*DNSProxyHandler) UpdateDNSServerAddr ¶

func (h *DNSProxyHandler) UpdateDNSServerAddr(addr string) error

UpdateDNSServerAddr validates and if successful updates DNS server address

type IPVersion ¶

type IPVersion string

const (

	// Versions specifically for nftables rendering purposes
	IPv4 IPVersion = "ipv4_addr"
	IPv6 IPVersion = "ipv6_addr"
)

type RenderIPSet ¶

type RenderIPSet struct {
	SetName string    `json:"setName,omitempty"`
	IPs     []string  `json:"ips,omitempty"`
	Version IPVersion `json:"version,omitempty"`
}

RenderIPSet stores set info for rendering

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL