net

type ConnPool interface {
	// Insert returns a no error false case only when we try to insert
	// beyond our max connections limit
	Insert(ConnPoolObject) (bool, error)
	Get() ConnPoolContext
}

type ConnPoolContext interface {
	ConnPoolObject() ConnPoolObject
	// NumberOfUsers can be used in determining value for min heap
	NumberOfUsers() int64
	// Done reports to the ConnPool that you are done using this ConnPoolObject.
	// This should be done after ALL operations against the object are resolved
	Done()
}

type ConnPoolObject interface {
	// Close handles any cleanup required for the connection
	// and is called whenever an object has been queued for deletion
	Close() error

	// ShouldDelete indicates whether a ConnPoolObject should be deleted from the pool
	// An example here would be if an http2 connection runs out of streams
	// NOTE: ShouldDelete should resolve quickly, as it has the possibility to deadlock the queue
	ShouldDelete() bool
}

type ConnPoolObjectCanMux interface {
	ConnPoolObject
	Value() <-chan int
}

type CopyDirection int

type ExtendedAddr interface {
	Data() interface{}
	net.Addr
}

type FanInListenerFactoryArgs struct {
	Factories []FanInListenerFactoryEntry
	Logger    *logrus.Logger
}

type FanInListenerFactoryEntry struct {
	// Factory identifies the factory
	Factory ListenerFactory

	// ShouldCleanup determines if the given factory should close if the fan-in
	// factory closes too
	ShouldCleanup bool
}

type ListenerFactory interface {
	// Listener returns a net.Listener
	Listener(args *ListenerFromFactoryArgs) (net.Listener, error)

	// Close tears down the factory and all required additions
	Close() error
}

type ListenerFromFactoryArgs struct {
	// ID specifies an ID provided in an SNI
	// for now is ignored unless used from a sharedPortTLSListenerFactory instance
	ID string

	// BindHost allows us to wrap the returning Addr to report a hostname:port rather than an ip:port
	// If unspecified will use the IP
	BindHost string
}

type ListenerOpt func(*listenerOpts)

type MultiAddr interface {
	Addrs() []net.Addr
	net.Addr
}

type MultiPortTCPListenerFactoryArgs struct {
	// BindAddr should be only an IP or HostName. :0 will be appended to any given value
	BindAddr string
	Logger   *logrus.Logger
}

type ServerConnTracker struct {
	net.Conn
	// contains filtered or unexported fields
}

type SharedPortTLSListenerFactoryArgs struct {
	TLSConfig *tls.Config
	Address   string
	Logger    *logrus.Logger
}

type SharedTLSAddrExtendedData struct {
	ID     string
	CACert []byte
}

type TLSWrapperFunc func(conn net.Conn, cfg *tls.Config) *tls.Conn