dns

Documentation

Overview

Package dns is a generated protocol buffer package.

It is generated from these files:

v2ray.com/core/app/dns/config.proto

It has these top-level messages:

Config

Index

• Constants
• type ARecord
• type CacheServer
  • func NewCacheServer(space app.Space, config *Config) *CacheServer
  • func (this *CacheServer) Get(domain string) []net.IP
  • func (this *CacheServer) GetCached(domain string) []net.IP
  • func (this *CacheServer) Release()
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (m *Config) GetHosts() map[string]*v2ray_core_common_net.AddressPB
  • func (this *Config) GetInternalHosts() map[string]net.IP
  • func (m *Config) GetNameServers() []*v2ray_core_common_net2.DestinationPB
  • func (*Config) ProtoMessage()
  • func (m *Config) Reset()
  • func (m *Config) String() string
• type DomainRecord
• type LocalNameServer
  • func (this *LocalNameServer) QueryA(domain string) <-chan *ARecord
• type NameServer
• type PendingRequest
• type Server
• type UDPNameServer
  • func NewUDPNameServer(address v2net.Destination, dispatcher dispatcher.PacketDispatcher) *UDPNameServer
  • func (this *UDPNameServer) AssignUnusedID(response chan<- *ARecord) uint16
  • func (this *UDPNameServer) BuildQueryA(domain string, id uint16) *alloc.Buffer
  • func (this *UDPNameServer) Cleanup()
  • func (this *UDPNameServer) DispatchQuery(payload *alloc.Buffer)
  • func (this *UDPNameServer) HandleResponse(dest v2net.Destination, payload *alloc.Buffer)
  • func (this *UDPNameServer) QueryA(domain string) <-chan *ARecord

Constants

const (
	DefaultTTL       = uint32(3600)
	CleanupInterval  = time.Second * 120
	CleanupThreshold = 512
)

const (
	APP_ID = app.ID(2)
)

const (
	QueryTimeout = time.Second * 8
)

Types

type ARecord

type ARecord struct {
	IPs    []net.IP
	Expire time.Time
}

type CacheServer

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

func NewCacheServer

func NewCacheServer(space app.Space, config *Config) *CacheServer

func (*CacheServer) Get

func (this *CacheServer) Get(domain string) []net.IP

func (*CacheServer) GetCached

func (this *CacheServer) GetCached(domain string) []net.IP

Private: Visible for testing.

func (*CacheServer) Release

func (this *CacheServer) Release()

type Config

type Config struct {
	NameServers []*v2ray_core_common_net2.DestinationPB     `protobuf:"bytes,1,rep,name=NameServers,json=nameServers" json:"NameServers,omitempty"`
	Hosts       map[string]*v2ray_core_common_net.AddressPB `` /* 141-byte string literal not displayed */
}

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

func (*Config) GetHosts

func (m *Config) GetHosts() map[string]*v2ray_core_common_net.AddressPB

func (*Config) GetInternalHosts

func (this *Config) GetInternalHosts() map[string]net.IP

func (*Config) GetNameServers

func (m *Config) GetNameServers() []*v2ray_core_common_net2.DestinationPB

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) Reset

func (m *Config) Reset()

func (*Config) String

func (m *Config) String() string

type DomainRecord

type DomainRecord struct {
	A *ARecord
}

type LocalNameServer

type LocalNameServer struct {
}

func (*LocalNameServer) QueryA

func (this *LocalNameServer) QueryA(domain string) <-chan *ARecord

type NameServer

type NameServer interface {
	QueryA(domain string) <-chan *ARecord
}

type PendingRequest

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

type Server

type Server interface {
	Get(domain string) []net.IP
}

A DnsCache is an internal cache of DNS resolutions.

type UDPNameServer

type UDPNameServer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewUDPNameServer

func NewUDPNameServer(address v2net.Destination, dispatcher dispatcher.PacketDispatcher) *UDPNameServer

func (*UDPNameServer) AssignUnusedID

func (this *UDPNameServer) AssignUnusedID(response chan<- *ARecord) uint16

Private: Visible for testing.

func (*UDPNameServer) BuildQueryA

func (this *UDPNameServer) BuildQueryA(domain string, id uint16) *alloc.Buffer

func (*UDPNameServer) Cleanup

func (this *UDPNameServer) Cleanup()

Private: Visible for testing.

func (*UDPNameServer) DispatchQuery

func (this *UDPNameServer) DispatchQuery(payload *alloc.Buffer)

func (*UDPNameServer) HandleResponse

func (this *UDPNameServer) HandleResponse(dest v2net.Destination, payload *alloc.Buffer)

Private: Visible for testing.

func (*UDPNameServer) QueryA

func (this *UDPNameServer) QueryA(domain string) <-chan *ARecord