Documentation
¶
Overview ¶
Package delivery owns receipt renewal, settlement admission, and immutable message snapshots. Native requests and failure wire encoding stay in awsqueue.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type State ¶
type State struct {
// contains filtered or unexported fields
}
State owns one receipt's message and serialization slot. Publish completes the message before exposing it to a handler; renewal never reads the message.
func (*State) KeepAlive ¶
func (state *State) KeepAlive( ctx context.Context, visibility, maximum time.Duration, extend func(context.Context) error, failed func(context.Context, error), ) func()
KeepAlive owns renewal through handler drain. Its idempotent stop cancels pending I/O before joining the worker. The native callback must honor context cancellation; no native operation is abandoned on a detached goroutine.
func (*State) Message ¶
Message returns detached payload and metadata snapshots for concurrent reads.
func (*State) Publish ¶
Publish captures the decoded envelope before its first handler invocation. The caller must not replace a message after publishing the delivery to a handler. Nil containers remain nil; arbitrary metadata values are strings.
Source Files