broker_pool.go RawHistoryFolder

1package ports
2
3// BrokerMaxAddressBytes bounds the opaque adapter route.
4const BrokerMaxAddressBytes = 4096
5
6// BrokerStreamPurpose keeps observation and control independent from attachments.
7type BrokerStreamPurpose uint8
8
9const (
10	BrokerStreamAttachment BrokerStreamPurpose = iota + 1
11	BrokerStreamControl
12	BrokerStreamObservation
13)
14
15// Resolve must validate current registration and reject conflicting requested
16// policy. It must honor cancellation and return bounded, authenticated values.
17// No resolver cache or alias normalization in the pool can bypass this check.
18// Resolver, connector and OpenStream adapters should return BrokerError for
19// semantic rejection and context errors for cancellation/deadline. Unknown
20// errors become Unavailable; causes remain accessible through errors.Is/As.
21// Never place secrets or unbounded adapter diagnostics in BrokerError.Text.
22// BrokerLogicalConnection supplies terminal notification independent of reads.
23// Done closes exactly once; Err is stable afterwards (nil for orderly close).
24// Close is concurrent-safe, prompt, and unblocks all I/O. Physical Close and
25// connector/resolver/open cancellation must likewise complete promptly. The
26// pool does not buffer traffic: adapters must isolate bounded per-stream queues.
27type BrokerLogicalConnection interface {
28	ClientConnection
29	Done() <-chan struct{}
30	Err() error
31}
32
33// BrokerAdmissionError distinguishes resource/identity rejection from transport
34// failure. Rejected or failed reservations still consume the monotonic stream
35// ID; callers must use a fresh ID. A connection ID is never reused in an epoch.
36type BrokerAdmissionError string
37
38func (e BrokerAdmissionError) Error() string { return "broker admission: " + string(e) }
39
40const (
41	BrokerAdmissionLimit   BrokerAdmissionError = "limit"
42	BrokerAdmissionClosed  BrokerAdmissionError = "closed"
43	BrokerAdmissionStale   BrokerAdmissionError = "stale connection or stream"
44	BrokerAdmissionInvalid BrokerAdmissionError = "invalid request"
45)