client

Documentation

Overview

Package client contains types and logic dealing with AdGuard Home's DNS clients.

TODO(a.garipov): Expand.

Index

• Constants
• type AddressProcessor
• type AddressUpdater
• type DefaultAddrProc
  • func NewDefaultAddrProc(c *DefaultAddrProcConfig) (p *DefaultAddrProc)
  • func (p *DefaultAddrProc) Close() (err error)
  • func (p *DefaultAddrProc) Process(ip netip.Addr)
• type DefaultAddrProcConfig
• type EmptyAddrProc
  • func (EmptyAddrProc) Close() (_ error)
  • func (EmptyAddrProc) Process(_ netip.Addr)
• type Runtime
  • func (r *Runtime) Info() (cs Source, host string)
  • func (r *Runtime) IsEmpty() (ok bool)
  • func (r *Runtime) SetInfo(cs Source, hosts []string)
  • func (r *Runtime) SetWHOIS(info *whois.Info)
  • func (r *Runtime) Unset(cs Source)
  • func (r *Runtime) WHOIS() (info *whois.Info)
• type Source
  • func (cs Source) MarshalText() (text []byte, err error)
  • func (cs Source) String() (s string)

Constants

const ErrClosed errors.Error = "use of closed address processor"

ErrClosed is returned from [AddressProcessor.Close] if it's closed more than once.

Types

type AddressProcessor

type AddressProcessor interface {
	Process(ip netip.Addr)
	Close() (err error)
}

AddressProcessor is the interface for types that can process clients.

type AddressUpdater

type AddressUpdater interface {
	// UpdateAddress updates information about an IP address, setting host (if
	// not empty) and WHOIS information (if not nil).
	UpdateAddress(ip netip.Addr, host string, info *whois.Info)
}

AddressUpdater is the interface for storages of DNS clients that can update information about them.

TODO(a.garipov): Consider using the actual client storage once it is moved into this package.

type DefaultAddrProc

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

DefaultAddrProc processes incoming client addresses with rDNS and WHOIS, if configured, and updates that information in a client storage.

func NewDefaultAddrProc

func NewDefaultAddrProc(c *DefaultAddrProcConfig) (p *DefaultAddrProc)

NewDefaultAddrProc returns a new running client address processor. c must not be nil.

func (*DefaultAddrProc) Close

func (p *DefaultAddrProc) Close() (err error)

Close implements the AddressProcessor interface for *DefaultAddrProc.

func (*DefaultAddrProc) Process

func (p *DefaultAddrProc) Process(ip netip.Addr)

Process implements the AddressProcessor interface for *DefaultAddrProc.

type DefaultAddrProcConfig

type DefaultAddrProcConfig struct {
	// DialContext is used to create TCP connections to WHOIS servers.
	// DialContext must not be nil if [DefaultAddrProcConfig.UseWHOIS] is true.
	DialContext aghnet.DialContextFunc

	// Exchanger is used to perform rDNS queries.  Exchanger must not be nil if
	// [DefaultAddrProcConfig.UseRDNS] is true.
	Exchanger rdns.Exchanger

	// PrivateSubnets are used to determine if an incoming IP address is
	// private.  It must not be nil.
	PrivateSubnets netutil.SubnetSet

	// AddressUpdater is used to update the information about a client's IP
	// address.  It must not be nil.
	AddressUpdater AddressUpdater

	// InitialAddresses are the addresses that are queued for processing
	// immediately by [NewDefaultAddrProc].
	InitialAddresses []netip.Addr

	// CatchPanics, if true, makes the address processor catch and log panics.
	//
	// TODO(a.garipov): Consider better ways to do this or apply this method to
	// other parts of the codebase.
	CatchPanics bool

	// UseRDNS, if true, enables resolving of client IP addresses using reverse
	// DNS.
	UseRDNS bool

	// UsePrivateRDNS, if true, enables resolving of private client IP addresses
	// using reverse DNS.  See [DefaultAddrProcConfig.PrivateSubnets].
	UsePrivateRDNS bool

	// UseWHOIS, if true, enables resolving of client IP addresses using WHOIS.
	UseWHOIS bool
}

DefaultAddrProcConfig is the configuration structure for address processors.

type EmptyAddrProc

type EmptyAddrProc struct{}

EmptyAddrProc is an AddressProcessor that does nothing.

func (EmptyAddrProc) Close

func (EmptyAddrProc) Close() (_ error)

Close implements the AddressProcessor interface for EmptyAddrProc.

func (EmptyAddrProc) Process

func (EmptyAddrProc) Process(_ netip.Addr)

Process implements the AddressProcessor interface for EmptyAddrProc.

type Runtime

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

Runtime is a client information from different sources.

func (*Runtime) Info

func (r *Runtime) Info() (cs Source, host string)

Info returns a client information from the highest-priority source.

func (*Runtime) IsEmpty

func (r *Runtime) IsEmpty() (ok bool)

IsEmpty returns true if there is no information from any source.

func (*Runtime) SetInfo

func (r *Runtime) SetInfo(cs Source, hosts []string)

SetInfo sets a host as a client information from the cs.

func (*Runtime) SetWHOIS

func (r *Runtime) SetWHOIS(info *whois.Info)

SetWHOIS sets a WHOIS client information. info must be non-nil.

func (*Runtime) Unset

func (r *Runtime) Unset(cs Source)

Unset clears a cs information.

func (*Runtime) WHOIS

func (r *Runtime) WHOIS() (info *whois.Info)

WHOIS returns a WHOIS client information.

type Source

type Source uint8

Source represents the source from which the information about the client has been obtained.

const (
	SourceWHOIS Source = iota + 1
	SourceARP
	SourceRDNS
	SourceDHCP
	SourceHostsFile
	SourcePersistent
)

Clients information sources. The order determines the priority.

func (Source) MarshalText

func (cs Source) MarshalText() (text []byte, err error)

MarshalText implements encoding.TextMarshaler for the Source.

func (Source) String

func (cs Source) String() (s string)

String returns a human-readable name of cs.