pool

package

v0.0.0-...-2de874f Latest Latest Go to latest Published: Apr 19, 2021 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

func Worker(pool *Pool)

type ByPriority []Server

func (servers ByPriority) Len() int

func (servers ByPriority) Less(i, j int) bool

func (servers ByPriority) Swap(i, j int)

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

func (domain *Domain) Add(typeId uint16, resolver chan<- *MessageResult) (resolve *Resolver)

func (domain *Domain) Delete(typeId uint16) bool

func (domain *Domain) Get(typeId uint16) *Resolver

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

func (domainListing *DomainListing) Add(name string) (domain *Domain)

func (domainListing *DomainListing) Delete(name string)

func (domainListing *DomainListing) Get(name string) *Domain

type Message struct {
	Name string
	Type uint16
}

type MessageResult struct {
	Message *dns.Msg
	Error   error
	Server  *Server
}

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

func MakePool(knownServers *[]Server, serverOrder *[]Server, wg *sync.WaitGroup, timeout time.Duration) *Pool

func (pool Pool) Do(message Message) (*dns.Msg, *Server, error)

func (pool *Pool) GetClientTimeout() time.Duration

func (pool *Pool) NumUpstreams() int

func (pool *Pool) ServerIter() (serverChan chan ServerIter, successChan chan ServerSuccess)

type Query struct {
	Message     dns.Msg
	ResolveChan chan<- *MessageResult
}

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

func (poolResolver *Resolver) Add(resolver chan<- *MessageResult)

type Server struct {
	Name     string
	Address  string
	Port     string
	Priority uint
}

type ServerIter struct {
	Server *Server
	Index  int
}

type ServerSuccess struct {
	Succeeded bool
	Index     int
}