queue

type Candidate struct {
	Descriptor MessageDescriptor
	NextCursor string
}

type Config struct {
	DefaultVisibilityTimeout time.Duration
	DefaultMaxAttempts       int
	DefaultTTL               time.Duration
	QueuePollInterval        time.Duration
	Crypto                   *storage.Crypto
}

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

type DispatcherOption func(*Dispatcher)

type EnqueueOptions struct {
	Delay       time.Duration
	Visibility  time.Duration
	TTL         time.Duration
	MaxAttempts int
	Attributes  map[string]any
	ContentType string
}

type LeaseKeyParts struct {
	Queue string
	ID    string
}

type Message struct {
	Namespace        string
	Queue            string
	ID               string
	EnqueuedAt       time.Time
	NotVisibleUntil  time.Time
	Visibility       time.Duration
	MaxAttempts      int
	Attempts         int
	FailureAttempts  int
	TTLDeadline      time.Time
	PayloadBytes     int64
	PayloadContent   string
	MetadataObject   string
	PayloadObject    string
	MetadataRevision string
	CorrelationID    string
}

type MessageCandidateResult struct {
	Descriptor *MessageDescriptor
	NextCursor string
}

type MessageDescriptor struct {
	Namespace    string
	ID           string
	MetadataKey  string
	MetadataETag string
	Document     messageDocument
}

type MessageDocument struct {
	Type               string         `json:"type"`
	Namespace          string         `json:"namespace,omitempty"`
	Queue              string         `json:"queue"`
	ID                 string         `json:"id"`
	EnqueuedAt         time.Time      `json:"enqueued_at"`
	UpdatedAt          time.Time      `json:"updated_at"`
	Attempts           int            `json:"attempts"`
	FailureAttempts    int            `json:"failure_attempts,omitempty"`
	NotVisibleUntil    time.Time      `json:"not_visible_until"`
	MaxAttempts        int            `json:"max_attempts"`
	Attributes         map[string]any `json:"attributes,omitempty"`
	LastError          any            `json:"last_error,omitempty"`
	PayloadBytes       int64          `json:"payload_bytes,omitempty"`
	PayloadContentType string         `json:"payload_content_type,omitempty"`
	VisibilityTimeout  int64          `json:"visibility_timeout_seconds,omitempty"`
	ExpiresAt          *time.Time     `json:"expires_at,omitempty"`
	CorrelationID      string         `json:"correlation_id,omitempty"`
	LeaseID            string         `json:"lease_id,omitempty"`
	LeaseFencingToken  int64          `json:"lease_fencing_token,omitempty"`
	LeaseTxnID         string         `json:"lease_txn_id,omitempty"`
	PayloadDescriptor  []byte         `json:"payload_descriptor,omitempty"`
	MetaDescriptor     []byte         `json:"meta_descriptor,omitempty"`
}

type MessageListResult struct {
	Descriptors    []MessageDescriptor
	NextStartAfter string
	Truncated      bool
}

type MessageResult struct {
	Document *MessageDocument
	ETag     string
}

type PayloadResult struct {
	Reader io.ReadCloser
	Info   *storage.ObjectInfo
}

type ReadyCacheStats struct {
	InflightSkips    int64
	CursorResets     int64
	InflightClears   int64
	ListScans        int64
	ListObjects      int64
	ListNanos        int64
	LoadCount        int64
	LoadNanos        int64
	NextCalls        int64
	RefreshWaits     int64
	RefreshWaitNanos int64
}

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

type StateDocument struct {
	Type          string    `json:"type"`
	Namespace     string    `json:"namespace"`
	Queue         string    `json:"queue"`
	MessageID     string    `json:"message_id"`
	CreatedAt     time.Time `json:"created_at"`
	UpdatedAt     time.Time `json:"updated_at"`
	CorrelationID string    `json:"correlation_id,omitempty"`
}

type StateResult struct {
	Document *StateDocument
	ETag     string
}

type Stats struct {
	Namespace         string
	Queue             string
	WaitingConsumers  int
	PendingCandidates int
	TotalConsumers    int
}

type WatchFactory interface {
	Subscribe(namespace, queue string) (WatchSubscription, error)
}

type WatchSubscription interface {
	Events() <-chan struct{}
	Close() error
}