transport.go RawHistoryFolder

1package ports
2
3import "context"
4
5// Transport is a framed message channel over a single connection. Close must
6// be safe to call concurrently with Send and Recv, and must unblock active
7// Send and Recv calls.
8type Transport interface {
9	Send(Frame) error
10	Recv() (Frame, error) // blocking; io.EOF on close
11	Close() error
12}
13
14// DatagramTransport marks transports backed by a datagram link. It lets
15// usecases negotiate a conservative output window without importing adapters.
16type DatagramTransport interface {
17	Transport
18	DatagramTransport()
19}
20
21// AsyncTransport accepts frames for ordered background transmission. SendAsync
22// returns once the adapter owns the frame; Send retains its synchronous wire-
23// attempt contract. Daemon paint output may use this capability to pipeline.
24type AsyncTransport interface {
25	SendAsync(Frame) error
26}
27
28// OwnedSynchronousTransport owns the complete bounded synchronous operation,
29// including adapter queues, pacing, write deadlines, and close cancellation.
30type OwnedSynchronousTransport interface {
31	SendSynchronous(Frame) error
32}
33
34// Dialer establishes outbound Transport connections.
35type Dialer interface {
36	Dial(ctx context.Context) (Transport, error)
37}
38
39// Listener accepts incoming Transport connections.
40type Listener interface {
41	Accept() (Transport, error)
42	Close() error
43	Addr() string
44}