l1

type BasicOutTransport interface {
	Send(payload io.WriterTo) error
	SendBytes(b []byte) error
}

type FuncMapOneWayTransport func(OneWayTransport) OneWayTransport

type FuncMapOutputFactory func(OutTransportFactory) OutTransportFactory

type MappedOutputTransportFactory struct {
	OutTransportFactory
	// contains filtered or unexported fields
}

type MappedSessionfullTransportProvider struct {
	SessionfulTransportProvider
	// contains filtered or unexported fields
}

type MappedSessionlessTransportProvider struct {
	SessionlessTransportProvider
	// contains filtered or unexported fields
}

type OneWayTransport interface {
	BasicOutTransport
	io.Closer
	GetTag() int
	SetTag(int)

	WithQuota(ratelimiter.RateQuota) OneWayTransport
}

type OutNetTransport interface {
	io.ReaderFrom
	io.Writer
	OneWayTransport
	NetConn() net.Conn
}

type OutTransportFactory interface {
	// ConnectTo resolves provided address and makes a connection
	// Can return (nil, nil) when the given address is of unsupported type.
	ConnectTo(nwapi.Address) (OneWayTransport, error)
	Close() error
}

type SemiTransport interface {
	TwoWayTransport

	// ConnectReceiver can be used to connect receive side of this transport. It can only be called once.
	// When param is (nil) it will use a receiver func of its factory.
	// Returns result of the applied SessionfulConnectFunc and a relevant transport.
	// Will return (false, nil) when operation is not available, e.g. on repeated call.
	ConnectReceiver(SessionfulConnectFunc) (bool, TwoWayTransport)
}

type SessionfulConnectFunc func(local, remote nwapi.Address, conn io.ReadWriteCloser, w OneWayTransport, err error) (ok bool)

type SessionfulTransportProvider interface {
	// CreateListeningFactory starts listening and provides OutTransportFactory that has same local address as the listening socket.
	// Param (SessionfulConnectFunc) is to handle either inbound connection(s) from listen or inbound direction of an outgoing connection.
	CreateListeningFactory(SessionfulConnectFunc) (OutTransportFactory, nwapi.Address, error)
	// CreateOutgoingOnlyFactory creates a factory to open outgoing connections.
	// Param (SessionfulConnectFunc) is to handle inbound flow of an outgoing connection.
	CreateOutgoingOnlyFactory(SessionfulConnectFunc) (OutTransportFactory, error)
	Close() error
}

type SessionlessReceiveFunc func(local, remote nwapi.Address, b []byte, err error) (ok bool)

type SessionlessTransportProvider interface {
	// CreateListeningFactory starts listening and provides OutTransportFactory that has same local address as the listening socket.
	// Param (SessionlessReceiveFunc) is to handle inbound datagrams.
	CreateListeningFactory(SessionlessReceiveFunc) (OutTransportFactory, nwapi.Address, error)
	// CreateListeningFactoryWithAddress is similar to CreateListeningFactory but uses the given address. Provided address must have port.
	CreateListeningFactoryWithAddress(SessionlessReceiveFunc, nwapi.Address) (OutTransportFactory, error)
	// CreateOutgoingOnlyFactory creates a factory to open outgoing connections.
	CreateOutgoingOnlyFactory() (OutTransportFactory, error)
	// MaxByteSize returns a maximum size of a supported/deliverable datagram.
	MaxByteSize() uint16
	Close() error
}

type TwoWayTransport interface {
	OneWayTransport

	// TwoWayConn returns an underlying two-way connection. Only applies to a sessionful transport.
	TwoWayConn() io.ReadWriteCloser
}

type VerifyPeerCertificateFunc func(rawCerts [][]byte, verifiedChains [][]*x509.Certificate) error