persistence

type BatchAckItem struct {
	MessageID    string
	ReceiptToken string
}

type BatchNackItem struct {
	MessageID    string
	ReceiptToken string
	RetryDelay   time.Duration
	Error        string
}

type CancellationRow = cancellationRow

type CheckpointMode = sqliteCheckpointMode

type CheckpointResult = sqliteCheckpointResult

type DeliveryError struct {
	ID           string    `db:"id"`
	MessageID    string    `db:"message_id"`
	SubscriberID string    `db:"subscriber_id"`
	FailureCount int       `db:"failure_count"`
	Error        string    `db:"error"`
	FailedAt     time.Time `db:"failed_at"`
}

type DeliveryRow = deliveryRow

type MessageDeliveryStatus struct {
	SubscriberID  string     `db:"subscriber_id"`
	Subscriber    string     `db:"subscriber"`
	Status        string     `db:"status"`
	DeliveryCount int        `db:"delivery_count"`
	FailureCount  int        `db:"failure_count"`
	VisibleAt     time.Time  `db:"visible_at"`
	ProcessedAt   *time.Time `db:"processed_at"`
	CancelledAt   *time.Time `db:"cancelled_at"`
	CancelReason  string     `db:"cancel_reason"`
}

type MessageStatus struct {
	ID             string
	TopicID        string
	Message        string
	Headers        map[string]string
	CorrelationID  string
	IdempotencyKey string
	Priority       int
	ScheduledAt    time.Time
	CreatedAt      time.Time
	Deliveries     []MessageDeliveryStatus
}

type PersistWriteResult struct {
	Duplicates  []bool
	ScheduledAt []time.Time
}

type RetryPolicy struct {
	InitialDelay  string  `json:"initial_delay,omitempty"`
	MaxDelay      string  `json:"max_delay,omitempty"`
	Multiplier    float64 `json:"multiplier,omitempty"`
	Jitter        float64 `json:"jitter,omitempty"`
	DisableJitter bool    `json:"disable_jitter,omitempty"`
}

type Schedule struct {
	ID             string         `db:"id"`
	TopicID        string         `db:"topic_id"`
	Name           string         `db:"name"`
	CronExpression string         `db:"cron_expression"`
	Timezone       string         `db:"timezone"`
	Message        string         `db:"message"`
	Headers        string         `db:"headers"`
	CorrelationID  sql.NullString `db:"correlation_id"`
	Priority       int            `db:"priority"`
	MisfirePolicy  string         `db:"misfire_policy"`
	OverlapPolicy  string         `db:"overlap_policy"`
	Paused         bool           `db:"paused"`
	Version        int            `db:"version"`
	NextRunAt      time.Time      `db:"next_run_at"`
	OwnerID        sql.NullString `db:"owner_id"`
	LeaseExpiresAt sql.NullTime   `db:"lease_expires_at"`
	FencingToken   int64          `db:"fencing_token"`
	CreatedAt      time.Time      `db:"created_at"`
	UpdatedAt      time.Time      `db:"updated_at"`
	ClaimedAt      time.Time      `db:"-"`
}

type ScheduleRun struct {
	ID           string         `db:"id"`
	ScheduleID   string         `db:"schedule_id"`
	MessageID    sql.NullString `db:"message_id"`
	ScheduledFor time.Time      `db:"scheduled_for"`
	StartedAt    time.Time      `db:"started_at"`
	FinishedAt   sql.NullTime   `db:"finished_at"`
	Status       string         `db:"status"`
	Error        sql.NullString `db:"error"`
	CreatedAt    time.Time      `db:"created_at"`
}

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

type Subscriber struct {
	ID        uuid.UUID         `db:"id"`
	TopicID   uuid.UUID         `db:"topic_id"`
	TopicName string            `db:"topic_name"`
	Name      string            `db:"name"`
	Options   SubscriberOptions `db:"option"`
	Paused    bool              `db:"paused"`
	CreatedAt time.Time         `db:"created_at"`
	DeletedAt *time.Time        `db:"deleted_at"`
}

type SubscriberFilter struct {
	TopicIDs    []uuid.UUID
	Names       []string
	WithDeleted bool
}

type SubscriberOptions struct {
	MaxAttempts        int         `json:"max_attempts"`
	VisibilityDuration string      `json:"visibility_duration"`
	DequeueBatchSize   int         `json:"dequeue_batch_size,omitempty"`
	RetryPolicy        RetryPolicy `json:"retry_policy,omitempty"`
}

type SubscriberQueueStats struct {
	Pending   int `db:"pending"`
	Delivered int `db:"delivered"`
}

type SubscriberStatusRow struct {
	ID        string `db:"id"`
	Name      string `db:"name"`
	Pending   int    `db:"pending"`
	Delivered int    `db:"delivered"`
}

type Subscribers []Subscriber

type Topic struct {
	ID        uuid.UUID  `db:"id"`
	Name      string     `db:"name"`
	Paused    bool       `db:"paused"`
	CreatedAt time.Time  `db:"created_at"`
	DeletedAt *time.Time `db:"deleted_at"`
}

type TopicFilter struct {
	Names       []string
	WithDeleted bool
}

type Topics []Topic

type WriteRequest struct {
	TopicID         uuid.UUID
	MessageID       string
	Message         string
	Headers         []byte
	CorrelationID   string
	IdempotencyKey  string
	IdempotencyHash string
	ScheduleMode    string
	ScheduleDelay   time.Duration
	Priority        int
	VisibleAt       time.Time
	CreatedAt       time.Time
}