inbox

type Record struct {
	ID        uint64 `json:"id"`
	Topic     string `json:"topic"`
	StreamSeq uint64 `json:"stream_seq"`
	Command   string `json:"command"`
	Status    Status `json:"status"`
	ErrorMsg  string `json:"error_msg,omitempty"`
	CreatedAt int64  `json:"created_at"`
	UpdatedAt int64  `json:"updated_at"`
}

type RunInbox interface {
	// PutIfAbsent inserts a new record. Returns (true, nil) on insert,
	// (false, existing record, nil) if already exists, or an error.
	PutIfAbsent(ctx context.Context, topic string, streamSeq uint64, cmd messaging.WorkerCommand) (bool, *Record, error)

	// MarkProcessing transitions a record to processing.
	MarkProcessing(ctx context.Context, topic string, streamSeq uint64) error

	// MarkCompleted transitions a record to completed.
	MarkCompleted(ctx context.Context, topic string, streamSeq uint64) error

	// MarkFailed transitions a record to failed.
	MarkFailed(ctx context.Context, topic string, streamSeq uint64, errMsg string) error

	// GetNonTerminal returns non-terminal records for a topic, ordered by stream_seq.
	GetNonTerminal(ctx context.Context, topic string) ([]Record, error)

	// DeleteTerminalBefore deletes terminal records older than the given time.
	DeleteTerminalBefore(ctx context.Context, topic string, before time.Time) (int64, error)

	// Close closes the database.
	Close() error
}

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

type Status string