adaptivemsg

type Client struct {
	// contains filtered or unexported fields
}

type ClientRecoveryOptions struct {
	// Enable activates recovery mode. Default: false.
	Enable bool
	// ReconnectMinBackoff is the minimum backoff duration between reconnect
	// attempts. Default: 100ms.
	ReconnectMinBackoff time.Duration
	// ReconnectMaxBackoff is the maximum backoff duration between reconnect
	// attempts. Default: 2s.
	ReconnectMaxBackoff time.Duration
	// MaxReplayBytes is the maximum number of bytes buffered for replay of
	// unacknowledged messages. Default: 8 MiB.
	MaxReplayBytes int64
}

type CodecID byte

type CodecImpl interface {
	ID() CodecID
	Name() string
	// Encode returns a payload owned by the caller. Implementations must not
	// mutate or reuse the returned backing storage after Encode returns.
	Encode(Message) ([]byte, error)
	DecodeEnvelope([]byte) (Envelope, error)
	DecodeInto(body any, dst any) error
}

type Connection struct {
	// contains filtered or unexported fields
}

type ConnectionCounters struct {
	// StreamsOpened is the total number of streams opened.
	StreamsOpened uint64
	// StreamsClosed is the total number of streams closed.
	StreamsClosed uint64
	// DataMessagesSent is the total number of application-level messages sent.
	DataMessagesSent uint64
	// DataMessagesReceived is the total number of application-level messages received.
	DataMessagesReceived uint64
	// FramesWritten is the total number of wire frames written.
	FramesWritten uint64
	// FramesRead is the total number of wire frames read.
	FramesRead uint64
	// BytesWritten is the total number of bytes written to the transport.
	BytesWritten uint64
	// BytesRead is the total number of bytes read from the transport.
	BytesRead uint64
	// ControlFramesWritten is the total number of control frames written.
	ControlFramesWritten uint64
	// ControlFramesRead is the total number of control frames read.
	ControlFramesRead uint64
	// ProtocolErrors is the total number of protocol errors detected.
	ProtocolErrors uint64
	// ProtocolErrorReplySendFailure is how many times sending a protocol error reply failed.
	ProtocolErrorReplySendFailure uint64
	// RemoteErrors is the total number of remote ErrorReply messages received.
	RemoteErrors uint64
	// DecodeErrors is the total number of message decode failures.
	DecodeErrors uint64
	// HandlerCalls is the total number of handler invocations.
	HandlerCalls uint64
	// HandlerErrors is the total number of handler invocations that returned an error.
	HandlerErrors uint64
	// ReconnectAttempts is the total number of recovery reconnect attempts.
	ReconnectAttempts uint64
	// ReconnectSuccesses is the total number of successful recovery reconnects.
	ReconnectSuccesses uint64
	// ReconnectFailures is the total number of failed recovery reconnect attempts.
	ReconnectFailures uint64
	// TransportAttaches is the total number of times a transport was attached.
	TransportAttaches uint64
	// TransportDetaches is the total number of times a transport was detached.
	TransportDetaches uint64
}

type ConnectionDebugState struct {
	// Closed is true if the connection has been closed.
	Closed bool
	// LastFailureCode is the code of the most recent failure on this connection.
	LastFailureCode DebugFailureCode
	// LastFailure is the human-readable description of the most recent failure.
	LastFailure string
	// LastFailureAt is the timestamp of the most recent failure.
	LastFailureAt time.Time
	// Protocol is the negotiated protocol version byte.
	Protocol byte
	// CodecID is the negotiated codec identifier.
	CodecID CodecID
	// CodecName is the human-readable name of the negotiated codec.
	CodecName string
	// MaxFrame is the negotiated maximum frame size in bytes.
	MaxFrame uint32
	// StreamCount is the current number of streams (open and closing).
	StreamCount int
	// NextSendSeq is the next sequence number to be assigned to an outbound frame.
	NextSendSeq uint64
	// Counters holds the cumulative connection counters.
	Counters ConnectionCounters
	// Streams contains a snapshot of each stream's debug state.
	Streams []StreamDebugState
	// Recovery contains the recovery subsystem state, or nil if recovery is not enabled.
	Recovery *RecoveryDebugState
}

type DebugFailureCode string

type Envelope struct {
	// Wire is the message type name extracted from the payload.
	Wire string
	// Body holds the codec-specific raw data for deferred decoding.
	Body any
}

type ErrBadHandshakeMagic struct{}

type ErrClosed struct{}

type ErrCodec struct {
	// Message contains the human-readable error detail.
	Message string
}

type ErrCompactFieldCount struct {
	// Expected is the number of fields the local struct definition has.
	Expected int
	// Got is the number of fields found in the incoming payload.
	Got int
}

type ErrConcurrentRecv struct{}

type ErrConnectTimeout struct{}

type ErrFrameTooLarge struct {
	// Size is the offending payload size in bytes.
	Size int
}

type ErrHandlerTaskBusy struct{}

type ErrHandshakeRejected struct{}

type ErrInvalidMessage struct {
	// Reason contains the human-readable detail of what is invalid.
	Reason string
}

type ErrNoCommonCodec struct{}

type ErrNoCommonVersion struct {
	// ClientMin is the minimum protocol version supported by the client.
	ClientMin byte
	// ClientMax is the maximum protocol version supported by the client.
	ClientMax byte
	// ServerMin is the minimum protocol version supported by the server.
	ServerMin byte
	// ServerMax is the maximum protocol version supported by the server.
	ServerMax byte
}

type ErrRecvTimeout struct{}

type ErrRemote struct {
	// Code is the error code from the remote ErrorReply.
	Code string
	// Message is the error message from the remote ErrorReply.
	Message string
}

type ErrReplayBufferFull struct {
	// Limit is the configured maximum replay buffer size in bytes.
	Limit int64
	// Size is the current replay buffer size in bytes.
	Size int64
}

type ErrResumeRejected struct {
	// Reason contains the human-readable rejection detail.
	Reason string
}

type ErrTooManyCodecs struct {
	// Count is the number of codecs offered by the client.
	Count int
}

type ErrTypeMismatch struct {
	// Expected is the wire name of the expected message type.
	Expected string
	// Got is the wire name of the actually received message.
	Got string
}

type ErrUnknownMessage struct {
	// Name is the unrecognized wire name.
	Name string
}

type ErrUnsupportedCodec struct {
	// Value is the unrecognized codec ID byte.
	Value byte
}

type ErrUnsupportedFrameVersion struct {
	// Version is the unrecognized protocol version byte.
	Version byte
}

type ErrUnsupportedTransport struct {
	// Reason contains the human-readable detail of the unsupported feature.
	Reason string
}

type ErrorReply struct {
	Code    string `am:"code"`
	Message string `am:"message"`
}

type Link interface {
	// contains filtered or unexported methods
}

type Message interface{}

type NamedMessage interface {
	WireName() string
}

type Netconn struct {
	// contains filtered or unexported fields
}

type OkReply struct{}

type OnceConn struct {
	// contains filtered or unexported fields
}

type RecoveryDebugState struct {
	// Role is "client" or "server", indicating which recovery role this connection has.
	Role string
	// ConnectionID is the hex-encoded recovery connection identifier.
	ConnectionID string
	// TransportAttached is true if a live transport is currently connected.
	TransportAttached bool
	// TransportGen is the generation counter for transport attach/detach cycles.
	TransportGen uint64
	// ReconnectActive is true if a reconnect attempt is currently in progress.
	ReconnectActive bool
	// LastRecvSeq is the sequence number of the last received data frame.
	LastRecvSeq uint64
	// LastAckedSeq is the sequence number of the last acknowledged data frame.
	LastAckedSeq uint64
	// AckPending is the number of received frames not yet acknowledged.
	AckPending uint32
	// AckDue is true if an ACK is pending and should be sent soon.
	AckDue bool
	// AckEvery is the negotiated ACK frequency (every N data frames).
	AckEvery uint32
	// AckDelay is the negotiated delay before flushing a pending ACK.
	AckDelay time.Duration
	// HeartbeatInterval is the negotiated interval between heartbeat pings.
	HeartbeatInterval time.Duration
	// HeartbeatTimeout is the negotiated inactivity timeout for the connection.
	HeartbeatTimeout time.Duration
	// ReplayQueued is the number of frames currently buffered for replay.
	ReplayQueued int
	// ReplayBytes is the total size in bytes of frames buffered for replay.
	ReplayBytes int64
	// LiveQueueDepth is the number of frames in the live send queue.
	LiveQueueDepth int
	// ResumeQueueDepth is the number of frames queued for resume replay.
	ResumeQueueDepth int
}

type Server struct {
	// contains filtered or unexported fields
}

type ServerRecoveryOptions struct {
	// Enable activates recovery mode. Default: false.
	Enable bool
	// DetachedTTL is how long the server retains a detached connection's state
	// before discarding it. Default: 30s.
	DetachedTTL time.Duration
	// MaxReplayBytes is the maximum number of bytes buffered for replay of
	// unacknowledged messages. Default: 8 MiB.
	MaxReplayBytes int64
	// AckEvery sends a cumulative ACK every N data frames. Default: 64.
	AckEvery uint32
	// AckDelay is the delay before flushing a pending ACK. Default: 20ms.
	AckDelay time.Duration
	// HeartbeatInterval is the interval between heartbeat pings when the
	// connection is idle. Default: 30s.
	HeartbeatInterval time.Duration
	// HeartbeatTimeout closes the connection if no inbound frame is received
	// within this duration. Must be ≥ 2×HeartbeatInterval. Default: 90s.
	HeartbeatTimeout time.Duration
}

type Stream[T any] struct {
	// contains filtered or unexported fields
}

type StreamContext struct {
	// contains filtered or unexported fields
}

type StreamCounters struct {
	// DataMessagesSent is the total number of application-level messages sent on this stream.
	DataMessagesSent uint64
	// DataMessagesReceived is the total number of application-level messages received on this stream.
	DataMessagesReceived uint64
	// ProtocolErrors is the total number of protocol errors detected on this stream.
	ProtocolErrors uint64
	// ProtocolErrorReplySendFailure is how many times sending a protocol error reply failed on this stream.
	ProtocolErrorReplySendFailure uint64
	// RemoteErrors is the total number of remote ErrorReply messages received on this stream.
	RemoteErrors uint64
	// DecodeErrors is the total number of message decode failures on this stream.
	DecodeErrors uint64
	// HandlerCalls is the total number of handler invocations on this stream.
	HandlerCalls uint64
	// HandlerErrors is the total number of handler invocations that returned an error on this stream.
	HandlerErrors uint64
}

type StreamDebugState struct {
	// ID is the stream's numeric identifier within the connection.
	ID uint32
	// Closed is true if the stream has been closed.
	Closed bool
	// LastFailureCode is the code of the most recent failure on this stream.
	LastFailureCode DebugFailureCode
	// LastFailure is the human-readable description of the most recent failure.
	LastFailure string
	// LastFailureAt is the timestamp of the most recent failure.
	LastFailureAt time.Time
	// RecvTimeout is the stream's current receive timeout duration.
	RecvTimeout time.Duration
	// InboxDepth is the number of decoded messages waiting in the stream's inbox.
	InboxDepth int
	// IncomingDepth is the number of raw frames waiting to be decoded.
	IncomingDepth int
	// HandlerQDepth is the number of messages queued for handler dispatch.
	HandlerQDepth int
	// Counters holds the cumulative stream counters.
	Counters StreamCounters
}