remotes

Documentation

Index

• type CachePutter
• type MotivatedTarget
• type Pool
  • func NewPool(ctx context.Context) *Pool
  • func (p *Pool) Add(addr string) error
  • func (p *Pool) Len() int
  • func (p *Pool) Query(q packet.ParsedPacket) (*packet.ParsedPacket, string, error)
• type Target

Types

type CachePutter

type CachePutter interface {
	PutResult(packet.QuestionFormat, *packet.ParsedPacket) error
}

type MotivatedTarget

type MotivatedTarget interface {
	Target
	Motivation(packet.QuestionFormat) uint8
}

type Pool

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

func NewPool

func NewPool(ctx context.Context) *Pool

func (*Pool) Add

func (p *Pool) Add(addr string) error

Add adds a new remote to the pool.

func (*Pool) Len

func (p *Pool) Len() int

Len returns the number of configured remotes.

func (*Pool) Query

func (p *Pool) Query(q packet.ParsedPacket) (*packet.ParsedPacket, string, error)

type Target

type Target interface {
	Query(context.Context, packet.ParsedPacket) (*packet.ParsedPacket, error)
	Healthy(context.Context) bool
	String() string
}