Versions in this module Expand all Collapse all v0 v0.2.1 Oct 22, 2026 v0.2.0 Oct 22, 2026 v0.1.1 Oct 20, 2026 v0.1.0 Oct 20, 2026 Changes in this version + const DefaultAttempts + const DefaultHost + const Version + var ErrAccountBlocked = &KindError + var ErrAccountSuspended = &KindError + var ErrDedupClaimed = &KindError + var ErrDedupDisabled = &KindError + var ErrDedupInFlight = &KindError + var ErrInvalidRequest = errors.New("invalid request") + var ErrInvalidToken = &KindError + var ErrNotFailed = &KindError + var ErrOperationUnconfirmed = &KindError + var ErrPayloadTooLarge = &KindError + var ErrQueueBusy = &KindError + var ErrQueueCreating = &KindError + var ErrQueueDeleting = &KindError + var ErrQueueExists = &KindError + var ErrQueueLimit = &KindError + var ErrQueueNotFound = &KindError + var ErrQueueReplaced = &KindError + var ErrRateLimited = &KindError + var ErrResultUnknown = errors.New("result unknown") + var ErrRetentionLimit = &KindError + var ErrSpoolFull = &KindError + var ErrSpoolNotFound = &KindError + var ErrStaleToken = &KindError + var ErrUnauthenticated = &KindError + var ErrUnavailable = errors.New("unavailable") + var ErrUnknownHeader = &KindError + func Messages(ctx context.Context, c *Client, req MessagesRequest) iter.Seq2[Message, error] + func Queues(ctx context.Context, c *Client, req QueuesRequest) iter.Seq2[Queue, error] + type AckAndSendRequest struct + Data []byte + DataSource DataSource + Dedup Dedup + DelaySeconds int + Lease Lease + Queue string + RetryUnknown bool + ReturnHandle bool + Spool string + type AckAndSendResult struct + Handle Handle + ID string + type AckRequest struct + Lease Lease + Spool string + type Client struct + APIKey string + Attempts int + DebugWriter io.Writer + Host string + InsecureDisableTLS bool + Trace ClientTrace + func (c *Client) Ack(ctx context.Context, req AckRequest) error + func (c *Client) AckAndSend(ctx context.Context, req AckAndSendRequest) (AckAndSendResult, error) + func (c *Client) Clone() *Client + func (c *Client) CreateQueue(ctx context.Context, req CreateQueueRequest) (Queue, error) + func (c *Client) DeleteQueue(ctx context.Context, req DeleteQueueRequest) error + func (c *Client) Discard(ctx context.Context, req DiscardRequest) error + func (c *Client) Fail(ctx context.Context, req FailRequest) error + func (c *Client) Inspect(ctx context.Context, req InspectRequest) (InspectResult, error) + func (c *Client) Messages(ctx context.Context, req MessagesRequest) (Page[Message], error) + func (c *Client) Nack(ctx context.Context, req NackRequest) error + func (c *Client) Queue(ctx context.Context, req QueueRequest) (Queue, error) + func (c *Client) Queues(ctx context.Context, req QueuesRequest) (Page[Queue], error) + func (c *Client) Recover(ctx context.Context, req RecoverRequest) error + func (c *Client) Recv(ctx context.Context, req RecvRequest) (ret RecvResult, ok bool, err error) + func (c *Client) Release(ctx context.Context, req ReleaseRequest) error + func (c *Client) Renew(ctx context.Context, req RenewRequest) (RenewResult, error) + func (c *Client) Send(ctx context.Context, req SendRequest) (SendResult, error) + func (c *Client) Spool(ctx context.Context, req SpoolRequest) (Spool, error) + func (c *Client) UpdateQueue(ctx context.Context, req UpdateQueueRequest) error + type ClientTrace struct + OnConnect func(network, addr string) func(error) + OnMalformedResponse func(context.Context, RequestTrace, error) + OnRequest func(context.Context, RequestTrace) func(error) + func LoggerClientTrace(logger *slog.Logger) ClientTrace + func (t ClientTrace) Compose(x ClientTrace) (ret ClientTrace) + type CreateQueueRequest struct + Queue string + Settings QueueSettingsCreate + Spool string + type DataSource struct + func DataSourceReadSeeker(rs io.ReadSeeker) DataSource + func DataSourceReader(r io.Reader) DataSource + func (d DataSource) IsZero() bool + type Dedup struct + func DedupHash(h string) Dedup + func DedupString(str string) Dedup + type DedupClaimedError struct + ID string + func (e *DedupClaimedError) Error() string + type DeleteQueueRequest struct + Mode QueueDeleteMode + Queue string + QueueUID *string + Spool string + type DiscardRequest struct + Handle Handle + Lease Lease + Spool string + type Error struct + Details error + Kind ErrorKind + Message string + func (e *Error) Error() string + func (e *Error) Is(x error) bool + func (e *Error) Unwrap() error + type ErrorKind uint + const ErrorKindAccountBlocked + const ErrorKindAccountSuspended + const ErrorKindDedupClaimed + const ErrorKindDedupDisabled + const ErrorKindDedupInFlight + const ErrorKindInvalidToken + const ErrorKindNotFailed + const ErrorKindOperationUnconfirmed + const ErrorKindPayloadTooLarge + const ErrorKindQueueBusy + const ErrorKindQueueCreating + const ErrorKindQueueDeleting + const ErrorKindQueueExists + const ErrorKindQueueLimit + const ErrorKindQueueNotFound + const ErrorKindQueueReplaced + const ErrorKindRateLimited + const ErrorKindRetentionLimit + const ErrorKindSpoolFull + const ErrorKindSpoolNotFound + const ErrorKindStaleToken + const ErrorKindUnauthenticated + const ErrorKindUnknown + const ErrorKindUnknownHeader + func (k ErrorKind) String() string + type FailRequest struct + Lease Lease + Spool string + type Handle string + func (Handle) String() string + type InspectRequest struct + Handle Handle + Spool string + Stream bool + type InspectResult struct + CreatedAt time.Time + Data []byte + DataSize int64 + DataStream io.ReadCloser + ExpiresAt time.Time + ID string + LeaseExpiresAt time.Time + Retries int + State MessageState + VisibleAt time.Time + type KindError struct + Kind ErrorKind + func (e *KindError) Error() string + type Lease string + func (Lease) String() string + type Message struct + CreatedAt time.Time + ExpiresAt time.Time + Handle Handle + ID string + LeaseExpiresAt time.Time + Retries int + State MessageState + VisibleAt time.Time + type MessageState uint + const MessageStateDelayed + const MessageStateFailed + const MessageStatePending + const MessageStateUnavailable + const MessageStateUnknown + const MessageStateVisible + func ParseMessageState(s string) (MessageState, error) + func (s MessageState) String() string + type MessageStats struct + AckedTotal int64 + AddedTotal int64 + DataBytes int64 + Delayed int64 + DiscardedTotal int64 + ExpiredTotal int64 + Failed int64 + FailedTotal int64 + NackedTotal int64 + Pending int64 + ReleasedTotal int64 + SampledAt time.Time + StartedAt time.Time + Total int64 + Unavailable int64 + Visible int64 + type MessagesRequest struct + After string + Limit int + Queue string + ReturnHandle bool + Spool string + State MessageState + type NackRequest struct + Lease Lease + Spool string + type Op uint + const OpAck + const OpAckAndSend + const OpCreateQueue + const OpDeleteQueue + const OpDiscard + const OpFail + const OpInspect + const OpMessages + const OpNack + const OpQueue + const OpQueues + const OpRecover + const OpRecv + const OpRelease + const OpRenew + const OpSend + const OpSpool + const OpUnknown + const OpUpdateQueue + func (o Op) String() string + type Page struct + Items []T + Next string + type Queue struct + CreatedAt time.Time + Name string + Settings QueueSettings + State QueueState + Stats MessageStats + UID string + type QueueDeleteMode uint + const QueueDeleteModeDrain + const QueueDeleteModeForce + const QueueDeleteModeUnknown + func ParseQueueDeleteMode(s string) (QueueDeleteMode, error) + func (q QueueDeleteMode) String() string + type QueueLimitError struct + Max int64 + func (e *QueueLimitError) Error() string + type QueueNotFoundError struct + Queue string + func (e *QueueNotFoundError) Error() string + type QueueReplacedError struct + UID string + func (e *QueueReplacedError) Error() string + type QueueRequest struct + Queue string + Spool string + type QueueSettings struct + DedupWindowSeconds int + EffectiveRetentionSeconds int + LeaseTimeoutSeconds int + MaxRetries int + RecvRateLimit RateLimit + RetentionSeconds int + type QueueSettingsCreate struct + DedupWindowSeconds *int + LeaseTimeoutSeconds *int + MaxRetries *int + RecvRateLimit *RateLimit + RetentionSeconds *int + type QueueSettingsUpdate struct + DedupWindowSeconds *int + LeaseTimeoutSeconds *int + MaxRetries *int + RecvRateLimit *RateLimit + RetentionSeconds *int + type QueueState uint + const QueueStateActive + const QueueStateDeleting + const QueueStateDraining + const QueueStateUnknown + func (s QueueState) String() string + type QueuesRequest struct + After string + Limit int + Match *regexp.Regexp + Spool string + type RateLimit struct + Burst int + IntervalMicros int64 + func (r RateLimit) IsZero() bool + type RateLimitedError struct + RetryAfter time.Duration + func (e *RateLimitedError) Error() string + type RecoverRequest struct + DelaySeconds int + Handle Handle + Spool string + type RecvRequest struct + Queue string + Spool string + Stream bool + WaitSeconds *int + type RecvResult struct + CreatedAt time.Time + Data []byte + DataSize int64 + DataStream io.ReadCloser + ID string + Lease Lease + LeaseExpiresAt time.Time + Retries int + type ReleaseRequest struct + DelaySeconds int + Lease Lease + Spool string + type RenewRequest struct + Lease Lease + Spool string + type RenewResult struct + LeaseExpiresAt time.Time + type RequestTrace struct + Op Op + Queue string + Spool string + func (t RequestTrace) LogValue() slog.Value + type RetentionLimitError struct + Max time.Duration + func (e *RetentionLimitError) Error() string + type SendRequest struct + Data []byte + DataSource DataSource + Dedup Dedup + DelaySeconds int + Queue string + RetryUnknown bool + ReturnHandle bool + Spool string + type SendResult struct + Duplicate bool + Handle Handle + ID string + type Spool struct + Name string + QueueCount int64 + Stats MessageStats + type SpoolFullError struct + Limit SpoolLimit + Max int64 + func (e *SpoolFullError) Error() string + type SpoolLimit uint + const SpoolLimitDataBytes + const SpoolLimitMessages + const SpoolLimitUnknown + func (l SpoolLimit) String() string + type SpoolRequest struct + Spool string + type UnknownHeaderError struct + Header string + func (e *UnknownHeaderError) Error() string + type UpdateQueueRequest struct + Queue string + QueueUID *string + Settings QueueSettingsUpdate + Spool string
Go to main page