store

type Attempt struct {
	RetryBaseSeconds  int        `json:"retry_base_seconds"`
	RetryCapSeconds   int        `json:"retry_cap_seconds"`
	ExpiresAt         *time.Time `json:"expires_at,omitempty"`
	EndpointVersion   *int64     `json:"endpoint_version,omitempty"`
	SigningVersion    *int64     `json:"signing_version,omitempty"`
	ReplayPrincipalID *string    `json:"replay_principal_id,omitempty"`
	TraceParent       string     `json:"trace_parent,omitempty"`
	AttemptNumber     int        `json:"attempt_number"`
	CycleAttempt      int        `json:"cycle_attempt"`
	MaxAttempts       int        `json:"max_attempts"`
	AvailableAt       time.Time  `json:"available_at"`
	Retryable         *bool      `json:"retryable,omitempty"`
	ReplayOf          *string    `json:"replay_of,omitempty"`
	ReplayRequestID   *string    `json:"replay_request_id,omitempty"`
	ReplayActor       *string    `json:"replay_actor,omitempty"`
	ReplayReason      *string    `json:"replay_reason,omitempty"`
	ID                string     `json:"id"`
	EventID           string     `json:"event_id"`
	State             string     `json:"state"`
	ClaimCount        int        `json:"claim_count"`
	LastStartedAt     *time.Time `json:"last_started_at,omitempty"`
	CompletedAt       *time.Time `json:"completed_at,omitempty"`
	ResponseStatus    *int       `json:"response_status,omitempty"`
	ErrorCode         *string    `json:"error_code,omitempty"`
	ErrorMessage      *string    `json:"error_message,omitempty"`
	CreatedAt         time.Time  `json:"created_at"`
	UpdatedAt         time.Time  `json:"updated_at"`
}

type BatchItem struct {
	ReplaySelection
	PreviewState    string     `json:"preview_state"`
	PreviewEligible bool       `json:"preview_eligible"`
	Result          string     `json:"result"`
	ReplayAttemptID *string    `json:"replay_attempt_id,omitempty"`
	CompletedAt     *time.Time `json:"completed_at,omitempty"`
}

type BatchRequest struct {
	RequestID   string            `json:"request_id"`
	Reason      string            `json:"reason"`
	Events      []ReplaySelection `json:"events"`
	PrincipalID string            `json:"-"`
	Actor       string            `json:"-"`
}

type ClaimedDelivery struct {
	RetryBaseSeconds int
	RetryCapSeconds  int
	ExpiresAt        *time.Time
	EndpointVersion  int64
	SigningVersion   int64
	TraceParent      string
	QueuedAt         time.Time
	AvailableAt      time.Time
	CycleAttempt     int
	LeaseUntil       time.Time
	AttemptID        string
	EventID          string
	EventType        string
	Payload          []byte
	EndpointID       string
	EndpointURL      string
	SecretCiphertext []byte
	ClaimCount       int
}

type Endpoint struct {
	Version                int64      `json:"version"`
	Paused                 bool       `json:"paused"`
	SigningVersion         int64      `json:"signing_version"`
	RetiringSigningVersion *int64     `json:"retiring_signing_version,omitempty"`
	RetireAfter            *time.Time `json:"retire_after,omitempty"`
	RetryBaseSeconds       int        `json:"retry_base_seconds"`
	RetryCapSeconds        int        `json:"retry_cap_seconds"`
	EventTTLSeconds        int        `json:"event_ttl_seconds"`
	CreatedBy              string     `json:"created_by,omitempty"`
	MaxAttempts            int        `json:"max_attempts"`
	ConcurrencyLimit       int        `json:"concurrency_limit"`
	RateLimit              int        `json:"rate_limit"`
	ID                     string     `json:"id"`
	URL                    string     `json:"url"`
	CreatedAt              time.Time  `json:"created_at"`
}

type EndpointAudit struct {
	Version       int64     `json:"version"`
	PrincipalID   string    `json:"principal_id,omitempty"`
	Action        string    `json:"action"`
	Reason        string    `json:"reason"`
	Configuration Endpoint  `json:"configuration"`
	CreatedAt     time.Time `json:"created_at"`
}

type EndpointChange struct {
	ExpectedVersion int64
	PrincipalID     string
	Reason          string
	Action          string
	Settings        Endpoint
	Ciphertext      []byte
	Overlap         time.Duration
}

type Event struct {
	ProducerReference string    `json:"producer_reference,omitempty"`
	ID                string    `json:"id"`
	EndpointID        string    `json:"endpoint_id"`
	EventType         string    `json:"event_type"`
	State             string    `json:"state"`
	CreatedAt         time.Time `json:"created_at"`
}

type EventFilter struct {
	EndpointID        string     `json:"endpoint_id,omitempty"`
	From              *time.Time `json:"from,omitempty"`
	Until             *time.Time `json:"until,omitempty"`
	State             string     `json:"state,omitempty"`
	ProducerReference string     `json:"producer_reference,omitempty"`
}

type EventPage struct {
	Events    []Investigation `json:"events"`
	NextAfter string          `json:"next_after,omitempty"`
}

type Histogram struct {
	Count   uint64
	Sum     float64
	Buckets map[float64]uint64
}

type IngestionReceipt struct {
	Event     Event
	AttemptID string
	Repeated  bool
}

type Investigation struct {
	Event
	AttemptID      string     `json:"attempt_id"`
	AttemptNumber  int        `json:"attempt_number"`
	NextAttemptAt  *time.Time `json:"next_attempt_at,omitempty"`
	ExpiresAt      *time.Time `json:"expires_at,omitempty"`
	Paused         bool       `json:"paused"`
	FailureCode    string     `json:"failure_code,omitempty"`
	FailureSummary string     `json:"failure_summary,omitempty"`
	ResponseStatus *int       `json:"response_status,omitempty"`
}

type MetricsSnapshot struct {
	WorkersRecent              int64
	WorkerPollAgeSeconds       float64
	WorkerCompletionAgeSeconds float64
	DatabaseBytes              int64
	Events                     int64
	Claims                     int64
	Recoveries                 int64
	Retries                    int64
	Replays                    int64
	Queue                      map[string]int64
	States                     map[string]int64
	Completed                  map[string]int64
	OldestReadySeconds         float64
	Latency                    map[string]Histogram
}

type Outcome struct {
	Status  int
	Code    string
	Message string
	RetryAt *time.Time
}

type ReplayBatch struct {
	ID          string      `json:"id"`
	PrincipalID string      `json:"principal_id"`
	Reason      string      `json:"reason"`
	CreatedAt   time.Time   `json:"created_at"`
	StartedAt   *time.Time  `json:"started_at,omitempty"`
	State       string      `json:"state"`
	Items       []BatchItem `json:"items"`
}

type ReplayRequest struct {
	AttemptID   string `json:"attempt_id"`
	RequestID   string `json:"request_id"`
	Actor       string `json:"-"`
	PrincipalID string `json:"-"`
	Reason      string `json:"reason"`
}

type ReplayResult struct {
	AttemptID string `json:"attempt_id"`
	EventID   string `json:"event_id"`
	RequestID string `json:"request_id"`
}

type ReplaySelection struct {
	EventID   string `json:"event_id"`
	AttemptID string `json:"attempt_id"`
}

type RetentionResult struct {
	Events    int64     `json:"events"`
	Batches   int64     `json:"batches"`
	AuditRows int64     `json:"audit_rows"`
	Applied   bool      `json:"applied"`
	Cutoff    time.Time `json:"cutoff"`
}

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