transport

type DnsConn interface {
	// ReserveNewQuery reserves a query. It MUST be fast and non-block. If DnsConn
	// cannot serve more query due to its capacity, ReserveNewQuery returns nil.
	// If DnsConn is closed and can no longer serve more query, returns closed = true.
	ReserveNewQuery() (_ ReservedExchanger, closed bool)
	io.Closer
}

type NetConn interface {
	io.ReadWriteCloser
	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type PipelineOpts struct {
	// DialContext specifies the method to dial a connection to the server.
	// DialContext MUST NOT be nil.
	DialContext func(ctx context.Context) (DnsConn, error)

	// DialTimeout specifies the timeout for DialFunc.
	// Default is defaultDialTimeout.
	DialTimeout time.Duration

	// When connection is dialing, how many queries can be queued up in that
	// connection. Default is defaultLazyConnMaxConcurrentQuery.
	// Note: If the connection turns out having a smaller limit, part of queued up
	// queries will fail.
	MaxConcurrentQueryWhileDialing int

	Logger *zap.Logger
}

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

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

type ReservedExchanger interface {
	// ExchangeReserved sends q to the server and returns it's response.
	// ExchangeReserved MUST not modify nor keep the q.
	// q MUST be a valid dns message.
	// resp (if no err) should be released by ReleaseResp().
	ExchangeReserved(ctx context.Context, q []byte) (resp *[]byte, err error)

	// WithdrawReserved aborts the query.
	WithdrawReserved()
}

type ReuseConnOpts struct {
	// DialContext specifies the method to dial a connection to the server.
	// DialContext MUST NOT be nil.
	DialContext func(ctx context.Context) (NetConn, error)

	// DialTimeout specifies the timeout for DialFunc.
	// Default is defaultDialTimeout.
	DialTimeout time.Duration

	// Default is defaultIdleTimeout
	IdleTimeout time.Duration

	Logger *zap.Logger
}

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

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

type TraditionalDnsConnOpts struct {
	// Set to true if underlayer connection require a length header.
	// e.g. TCP and DoT.
	WithLengthHeader bool

	// IdleTimeout controls the maximum idle time for each connection.
	// Default is defaultIdleTimeout.
	IdleTimeout time.Duration

	// MaxConcurrentQuery limits the number of maximum concurrent queries
	// in the connection. Default is defaultTdcMaxConcurrentQuery.
	MaxConcurrentQuery int
}