pipeline

Documentation

Index

• Constants
• type DNSPipelineConn
  • func NewDNSPipelineConn(ctx context.Context, udpSize uint16, conn net.Conn, closeFunc func()) *DNSPipelineConn
  • func (c *DNSPipelineConn) Clone() *DNSPipelineConn
  • func (c *DNSPipelineConn) Close()
  • func (c *DNSPipelineConn) Exchange(ctx context.Context, req *dns.Msg) (*dns.Msg, error)
  • func (c *DNSPipelineConn) IsClosed() bool
  • func (c *DNSPipelineConn) LastUseUnix() int64
• type DNSPipelineConnPool
  • func NewDNSPipelineConnPool(ctx context.Context, maxSize int, udpSize uint16, idleTimeout time.Duration, ...) *DNSPipelineConnPool
  • func (p *DNSPipelineConnPool) Close()
  • func (p *DNSPipelineConnPool) Exchange(ctx context.Context, req *dns.Msg) (*dns.Msg, error)

Constants

const DefaultDNSPipelineConnPoolSize = 16

Types

type DNSPipelineConn

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

func NewDNSPipelineConn

func NewDNSPipelineConn(ctx context.Context, udpSize uint16, conn net.Conn, closeFunc func()) *DNSPipelineConn

func (*DNSPipelineConn) Clone

func (c *DNSPipelineConn) Clone() *DNSPipelineConn

func (*DNSPipelineConn) Close

func (c *DNSPipelineConn) Close()

func (*DNSPipelineConn) Exchange

func (c *DNSPipelineConn) Exchange(ctx context.Context, req *dns.Msg) (*dns.Msg, error)

func (*DNSPipelineConn) IsClosed

func (c *DNSPipelineConn) IsClosed() bool

func (*DNSPipelineConn) LastUseUnix

func (c *DNSPipelineConn) LastUseUnix() int64

type DNSPipelineConnPool

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

func NewDNSPipelineConnPool

func NewDNSPipelineConnPool(ctx context.Context, maxSize int, udpSize uint16, idleTimeout time.Duration, newFunc func(ctx context.Context) (net.Conn, error), closeFunc func()) *DNSPipelineConnPool

func (*DNSPipelineConnPool) Close

func (p *DNSPipelineConnPool) Close()

func (*DNSPipelineConnPool) Exchange

func (p *DNSPipelineConnPool) Exchange(ctx context.Context, req *dns.Msg) (*dns.Msg, error)