comm

type Connection interface {
	// Uri returns the URI of the connection.
	Uri() string

	// Type returns the type of the connection.
	Type() string

	// Parent returns the listener that created this connection.
	Parent() Listener

	// IsOpened checks if the connection is currently open.
	IsOpened() bool

	// Open establishes the connection, with a specified timeout.
	Open(timeout float64) error

	// Close terminates the connection.
	Close()

	// Cancel interrupts any ongoing operation with this connection.
	Cancel()

	// CancelSend interrupts any ongoing sending operation with this connection.
	CancelSend()

	// CancelRecv interrupts any ongoing receiving operation with this connection.
	CancelRecv()

	// Send transmits data over the connection, with a specified timeout.
	Send(data []byte, timeout float64) error

	// SendTo transmits data to addr over the connection, with a specified timeout.
	SendTo(data []byte, addr any, timeout float64) error

	// Recv receives data over the connection, with a specified timeout.
	Recv(timeout float64) (data []byte, err error)

	// RecvFrom receives data from addr over the connection, with a specified timeout.
	RecvFrom(timeout float64) (data []byte, addr any, err error)
}

type KeepaliveConfig struct {
	// Interval defines in seconds the time between keep-alive probes.
	// use 0 to enable keep-alive probes with OS defined values. (default is 0)
	// use -1 to disable keep-alive probes.
	Interval int
}

type LimiterConfig struct {
	// SimultaneousConn defines the at most number of connections that
	// the listener accepts simultaneously.
	// use 0 or negative value to disable connections limit.
	SimultaneousConn int
}

type Listener interface {
	// Uri returns the URI of the listener.
	Uri() string

	// Type returns the type of listener.
	Type() string

	// IsActive checks if the listener is currently active.
	IsActive() bool

	// Start initializes the listener and begins accepting connections.
	Start() error

	// Stop terminates the listener and closes all connections.
	Stop()

	// SetConnHandler sets a callback function to handle incoming connections.
	SetConnHandler(handler func(conn Connection))
}

type PollingConfig struct {
	// Timeout defines the timeout in seconds for read data polling.
	// polling timeout value must be > 0.
	Timeout float64
	// ChunkSize defines the size of chunks to read during polling.
	// polling chunk size value must be > 0.
	ChunkSize int
	// MaxSize defines the maximum size for read data.
	// use 0 or negative value to disable max limit.
	MaxSize int
}

type TlsConfig = tls.Config