Versions in this module Expand all Collapse all v1 v1.0.1 Aug 28, 2026 v1.0.0 Aug 26, 2026 Changes in this version + const MaxBatchSize + var ErrInvalidSemanticRequest = errors.New("streamqueue: invalid semantic request") + var ErrMalformedDelivery = errors.New("streamqueue: malformed delivery") + func ApplyMessageMetadata(record *management.JobRecord, metadata *job.Metadata) + func MessageAge(id string, now time.Time) (time.Duration, error) + func MessageMetadata(body []byte) *job.Metadata + type AckRequest struct + Group string + ID string + Stream string + func (r AckRequest) Validate() error + type AddRequest struct + Body []byte + MaxLength int64 + Stream string + func (r AddRequest) Validate(maxPayloadBytes int) error + type ClaimRequest struct + Consumer string + Count int64 + Group string + MinIdle time.Duration + Start string + Stream string + func (r ClaimRequest) Validate() error + type ClaimResult struct + Deliveries []Delivery + Next string + type DeadLetterRequest struct + Delivery Delivery + Destination string + Failure FailureMetadata + Group string + Source string + func (r DeadLetterRequest) Validate(maxPayloadBytes int) error + type Delivery struct + Attempts int64 + Body []byte + ID string + OriginalDeadLetterID string + PriorDeadLetterID string + Reclaimed bool + ReplayGeneration uint32 + type FailureMetadata struct + Classification management.Classification + Code string + func (m FailureMetadata) Validate() error + type GroupState struct + Lag int64 + OldestPendingID string + Pending int64 + func (s GroupState) Stats() Stats + type ReadRequest struct + Block time.Duration + Consumer string + Count int64 + Group string + Stream string + func (r ReadRequest) Validate() error + type RequestError struct + Cause error + Command string + Field string + func (e *RequestError) Error() string + func (e *RequestError) Unwrap() []error + type Stats struct + Depth int64 + Lag int64 + LagKnown bool + Pending int64 + type Transport interface + Ack func(context.Context, AckRequest) error + Add func(context.Context, AddRequest) (string, error) + Claim func(context.Context, ClaimRequest) (ClaimResult, error) + Close func() error + DeadLetter func(context.Context, DeadLetterRequest) error + EnsureGroup func(context.Context, string, string) error + GroupState func(context.Context, string, string) (GroupState, error) + Read func(context.Context, ReadRequest) ([]Delivery, error)
Go to main page