csfpg

type AcquireExpiredCronOccurrenceParams struct {
	LeaseOwner   *string
	LeaseToken   *string
	LeaseUntil   pgtype.Timestamptz
	ClaimedAt    pgtype.Timestamptz
	OccurrenceID string
}

type AdvanceCronTriggerParams struct {
	NextRunAt   pgtype.Timestamptz
	UpdatedAt   pgtype.Timestamptz
	TriggerName string
}

type ClaimJobSubmissionParams struct {
	Executor string
	Kinds    []string
}

type ClaimJobTraceDeliveryParams struct {
	Destination string
	JobID       string
	TraceID     string
}

type ClaimProjectionTaskParams struct {
	LeaseSeconds int32
	MaxAttempts  int32
}

type ClaimProjectionTaskRow struct {
	SourceID        string
	Revision        string
	Status          CsfProjectionStatus
	Attempts        int32
	LeaseGeneration int64
	LeaseUntil      pgtype.Timestamptz
	NextAttemptAt   pgtype.Timestamptz
	LastError       string
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type CompleteProjectionTaskParams struct {
	SourceID        string
	Revision        string
	LeaseGeneration int64
}

type CountJobStatesRow struct {
	Kind     string
	Executor string
	State    CsfJobState
	Jobs     int64
}

type CountProjectionTasksRow struct {
	Status CsfProjectionStatus
	Count  int64
}

type CreateAgentConfigurationParams struct {
	AgentID                        string
	LangfuseEndpointUrl            string
	LangfusePublicKeySecretRef     string
	LangfuseSecretKeySecretRef     string
	OpensearchEndpointUrl          string
	OpensearchIndex                string
	OpensearchEmbeddingModel       string
	OpensearchCredentialsSecretRef string
}

type CreateDocumentParams struct {
	ContentHash string
	ByteSize    int64
	ArtifactRef string
}

type CreateEdgeParams struct {
	Relation   string
	AuthorKind string
	AuthorRef  string
	Rationale  string
	FromNodeID string
	ToNodeID   string
}

type CreateNodeParams struct {
	NodeID              string
	Kind                string
	SymbolKey           string
	Title               string
	Statement           string
	ParentNodeID        *string
	AuthorKind          string
	AuthorRef           string
	CitationContentHash *string
	CitationSourceID    *string
	CitationRevision    *string
	CitationChunkID     *string
	CitationStartByte   *int64
	CitationEndByte     *int64
	TextProjectionRef   *string
	VectorProjectionRef *string
}

type CreateSourceRevisionParams struct {
	SourceID             string
	Revision             string
	ContentHash          string
	RawSourceContentHash *string
	SourceUri            string
	Title                string
	MediaType            string
	License              string
	RetrievedAt          pgtype.Timestamptz
}

type CsfAgentConfiguration struct {
	AgentID                        string
	Revision                       int64
	LangfuseEndpointUrl            string
	LangfusePublicKeySecretRef     string
	LangfuseSecretKeySecretRef     string
	OpensearchEndpointUrl          string
	OpensearchIndex                string
	OpensearchEmbeddingModel       string
	OpensearchCredentialsSecretRef string
	UpdatedAt                      pgtype.Timestamptz
}

type CsfCronOccurrence struct {
	OccurrenceID string
	TriggerName  string
	ScheduledAt  pgtype.Timestamptz
	Status       string
	Attempt      int32
	LeaseOwner   *string
	LeaseToken   *string
	LeaseUntil   pgtype.Timestamptz
	StartedAt    pgtype.Timestamptz
	FinishedAt   pgtype.Timestamptz
	ErrorSummary *string
	SkipReason   *string
	CreatedAt    pgtype.Timestamptz
	UpdatedAt    pgtype.Timestamptz
}

type CsfCronTrigger struct {
	TriggerName         string
	ScheduleKind        string
	LocalHour           *int16
	LocalMinute         *int16
	Weekday             *int16
	MonthDay            *int16
	IntervalNanoseconds *int64
	RawExpression       *string
	Timezone            string
	IntervalAnchorAt    pgtype.Timestamptz
	NextRunAt           pgtype.Timestamptz
	CatchUpPolicy       string
	OverlapPolicy       string
	Enabled             bool
	CreatedAt           pgtype.Timestamptz
	UpdatedAt           pgtype.Timestamptz
}

type CsfDocument struct {
	ContentHash string
	ByteSize    int64
	ArtifactRef string
	CreatedAt   pgtype.Timestamptz
}

type CsfEdge struct {
	FromNodeID string
	ToNodeID   string
	Relation   string
	AuthorKind string
	AuthorRef  string
	Rationale  string
	CreatedAt  pgtype.Timestamptz
}

type CsfIntent struct {
	IntentID  string
	SliceID   *string
	Intent    []byte
	CreatedAt pgtype.Timestamptz
}

type CsfJob struct {
	JobID                 string
	Kind                  string
	Executor              string
	BudgetAccount         string
	Request               []byte
	RequestSha256         string
	State                 CsfJobState
	TotalUnits            int64
	CompletedUnits        int64
	Managed               bool
	ExecutorTarget        string
	ExecutorImage         string
	ExternalID            string
	ArtifactUri           string
	ReservationUsdMicros  int64
	TimeoutSeconds        int32
	Reason                string
	LogStream             string
	LogCursor             string
	InspectionError       string
	CancellationRequested bool
	CleanupConfirmed      bool
	TraceUrl              string
	TraceExportError      string
	TraceRetryAt          pgtype.Timestamptz
	LogDocumentID         string
	LogProjectionError    string
	LogIndexedAt          pgtype.Timestamptz
	LogRetryAt            pgtype.Timestamptz
	CreatedAt             pgtype.Timestamptz
	UpdatedAt             pgtype.Timestamptz
}

type CsfJobBudget struct {
	Account           string
	LimitUsdMicros    int64
	ReservedUsdMicros int64
	CreatedAt         pgtype.Timestamptz
}

type CsfJobMeasurement struct {
	JobID        string
	Metric       string
	Step         int64
	Value        float64
	RecordedAt   pgtype.Timestamptz
	EvidenceHash string
}

type CsfJobMetricDefinition struct {
	JobID       string
	Name        string
	Unit        string
	Description string
}

type CsfJobState string

type CsfJobTraceDelivery struct {
	Destination string
	TraceID     string
	JobID       string
	State       CsfTraceDeliveryState
	Error       string
	CreatedAt   pgtype.Timestamptz
	FinishedAt  pgtype.Timestamptz
}

type CsfNode struct {
	NodeID              string
	Kind                string
	SymbolKey           string
	Title               string
	Statement           string
	ParentNodeID        *string
	AuthorKind          string
	AuthorRef           string
	CitationContentHash *string
	CitationSourceID    *string
	CitationRevision    *string
	CitationChunkID     *string
	CitationStartByte   *int64
	CitationEndByte     *int64
	TextProjectionRef   *string
	VectorProjectionRef *string
	CreatedAt           pgtype.Timestamptz
}

type CsfProjectionStatus string

type CsfProjectionTask struct {
	SourceID        string
	Revision        string
	Status          CsfProjectionStatus
	Attempts        int32
	LeaseGeneration int64
	LeaseUntil      pgtype.Timestamptz
	NextAttemptAt   pgtype.Timestamptz
	LastError       string
	CreatedAt       pgtype.Timestamptz
	UpdatedAt       pgtype.Timestamptz
}

type CsfSlice struct {
	SliceID        string
	Sequence       int64
	Title          string
	Recipe         []byte
	TouchSet       []byte
	Provenance     []byte
	State          CsfSliceState
	AssignmentID   string
	PullRequestUrl string
	Attempts       int32
	Checkpoint     string
	Error          string
	CreatedAt      pgtype.Timestamptz
	UpdatedAt      pgtype.Timestamptz
}

type CsfSliceEdge struct {
	FromSliceID string
	ToSliceID   string
	Relation    string
}

type CsfSliceState string

type CsfSourceRevision struct {
	SourceID             string
	Revision             string
	ContentHash          string
	RawSourceContentHash *string
	SourceUri            string
	Title                string
	MediaType            string
	License              string
	RetrievedAt          pgtype.Timestamptz
}

type CsfTraceDeliveryState string

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DisableCronTriggerParams struct {
	UpdatedAt   pgtype.Timestamptz
	TriggerName string
}

type EnqueueProjectionTaskParams struct {
	SourceID string
	Revision string
}

type EnsureJobBudgetParams struct {
	Account        string
	LimitUsdMicros int64
}

type FailProjectionTaskParams struct {
	MaxAttempts      int32
	RetryMaxSeconds  int32
	RetryBaseSeconds int32
	LastError        string
	SourceID         string
	Revision         string
	LeaseGeneration  int64
}

type FinishCronOccurrenceParams struct {
	Status       string
	FinishedAt   pgtype.Timestamptz
	ErrorSummary *string
	OccurrenceID string
	LeaseToken   *string
}

type FinishJobSubmissionParams struct {
	JobID      string
	State      CsfJobState
	ExternalID string
	Reason     string
}

type FinishJobTraceDeliveryParams struct {
	State       CsfTraceDeliveryState
	Error       string
	Destination string
	TraceID     string
}

type GetEdgeParams struct {
	FromNodeID string
	ToNodeID   string
	Relation   string
}

type GetJobParams struct {
	JobID string
	Kinds []string
}

type GetJobTraceDeliveryParams struct {
	Destination string
	TraceID     string
}

type GetProjectionTaskParams struct {
	SourceID string
	Revision string
}

type GetSourceRevisionParams struct {
	SourceID string
	Revision string
}

type IDB interface {
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, arguments ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, arguments ...any) pgx.Row
	Begin(ctx context.Context) (pgx.Tx, error)
	BeginTx(ctx context.Context, options pgx.TxOptions) (pgx.Tx, error)
	Ping(ctx context.Context) error
}

type InsertIntentParams struct {
	IntentID  string
	SliceID   *string
	Intent    []byte
	CreatedAt pgtype.Timestamptz
}

type InsertJobMeasurementParams struct {
	JobID        string
	Metric       string
	Step         int64
	Value        float64
	RecordedAt   pgtype.Timestamptz
	EvidenceHash string
}

type InsertJobMetricDefinitionParams struct {
	JobID       string
	Name        string
	Unit        string
	Description string
}

type InsertJobParams struct {
	JobID                string
	Kind                 string
	Executor             string
	BudgetAccount        string
	Request              []byte
	RequestSha256        string
	TotalUnits           int64
	Managed              bool
	ExecutorTarget       string
	ExecutorImage        string
	ArtifactUri          string
	ReservationUsdMicros int64
	TimeoutSeconds       int32
}

type InsertRunningCronOccurrenceParams struct {
	OccurrenceID string
	TriggerName  string
	ScheduledAt  pgtype.Timestamptz
	LeaseOwner   *string
	LeaseToken   *string
	LeaseUntil   pgtype.Timestamptz
	ClaimedAt    pgtype.Timestamptz
}

type InsertSkippedCronOccurrenceParams struct {
	OccurrenceID string
	TriggerName  string
	ScheduledAt  pgtype.Timestamptz
	SkippedAt    pgtype.Timestamptz
	SkipReason   *string
}

type InsertSliceEdgeParams struct {
	FromSliceID string
	ToSliceID   string
	Relation    string
}

type InsertSliceParams struct {
	SliceID    string
	Sequence   int64
	Title      string
	Recipe     []byte
	TouchSet   []byte
	Provenance []byte
	State      CsfSliceState
	CreatedAt  pgtype.Timestamptz
}

type LatestJobProgressRow struct {
	Kind           string
	Executor       string
	TotalUnits     int64
	CompletedUnits int64
	UpdatedAt      pgtype.Timestamptz
}

type ListChildNodesParams struct {
	ParentNodeID *string
	ResultOffset int64
	ResultLimit  int32
}

type ListDocumentNodesParams struct {
	ContentHash  *string
	ResultOffset int64
	ResultLimit  int32
}

type ListDocumentSourcesParams struct {
	ContentHash  string
	ResultOffset int64
	ResultLimit  int32
}

type ListDocumentsParams struct {
	ResultOffset int64
	ResultLimit  int32
}

type ListExpiredCronOccurrencesParams struct {
	ExpiredAt pgtype.Timestamptz
	RowLimit  int32
}

type ListJobsParams struct {
	Kinds    []string
	RowLimit int32
}

type ListNodeEdgesParams struct {
	NodeID       string
	ResultOffset int64
	ResultLimit  int32
}

type ListSourceRevisionsParams struct {
	SourceID     string
	ResultOffset int64
	ResultLimit  int32
}

type ListSymbolNodesParams struct {
	SymbolKey    string
	ResultOffset int64
	ResultLimit  int32
}

type LiveCronOccurrenceParams struct {
	TriggerName          string
	At                   pgtype.Timestamptz
	ExcludedOccurrenceID string
}

type LockJobParams struct {
	JobID string
	Kinds []string
}

type MarkInterruptedJobSubmissionsParams struct {
	Reason       string
	Executor     string
	GraceSeconds int32
}

type NextHostJobParams struct {
	Executor string
	Kinds    []string
}

type NextUnarchivedJobParams struct {
	Executor string
	Kinds    []string
}

type NextUntracedJobParams struct {
	Executor string
	Kinds    []string
}

type NullCsfJobState struct {
	CsfJobState CsfJobState
	Valid       bool // Valid is true if CsfJobState is not NULL
}

type NullCsfProjectionStatus struct {
	CsfProjectionStatus CsfProjectionStatus
	Valid               bool // Valid is true if CsfProjectionStatus is not NULL
}

type NullCsfSliceState struct {
	CsfSliceState CsfSliceState
	Valid         bool // Valid is true if CsfSliceState is not NULL
}

type NullCsfTraceDeliveryState struct {
	CsfTraceDeliveryState CsfTraceDeliveryState
	Valid                 bool // Valid is true if CsfTraceDeliveryState is not NULL
}

type PollableJobsParams struct {
	Executor string
	Kinds    []string
	RowLimit int32
}

type Pool struct {
	*pgxpool.Pool
}

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

type RecordJobProgressParams struct {
	CompletedUnits int64
	State          CsfJobState
	Reason         string
	JobID          string
}

type RenewCronOccurrenceLeaseParams struct {
	LeaseUntil   pgtype.Timestamptz
	RenewedAt    pgtype.Timestamptz
	OccurrenceID string
	LeaseToken   *string
}

type RequestJobCancellationParams struct {
	JobID string
	Kinds []string
}

type ReserveJobBudgetParams struct {
	Amount  int64
	Account string
}

type SearchSourceRevisionsParams struct {
	Query        string
	ResultOffset int64
	ResultLimit  int32
}

type SetJobInspectionErrorParams struct {
	JobID           string
	InspectionError string
}

type SetJobLogArchiveParams struct {
	JobID              string
	LogDocumentID      string
	LogProjectionError string
	LogIndexedAt       pgtype.Timestamptz
}

type SetJobLogCursorParams struct {
	JobID     string
	LogCursor string
}

type SetJobTraceParams struct {
	JobID            string
	TraceUrl         string
	TraceExportError string
}

type Settings struct {
	// URL is a PostgreSQL connection string or URL as pgx parses it.
	URL string `json:"url"`
}

type SkipExpiredCronOccurrenceParams struct {
	SkippedAt    pgtype.Timestamptz
	SkipReason   *string
	OccurrenceID string
}

type UpdateAgentConfigurationParams struct {
	LangfuseEndpointUrl            string
	LangfusePublicKeySecretRef     string
	LangfuseSecretKeySecretRef     string
	OpensearchEndpointUrl          string
	OpensearchIndex                string
	OpensearchEmbeddingModel       string
	OpensearchCredentialsSecretRef string
	AgentID                        string
	ExpectedRevision               int64
}

type UpdateJobExecutionParams struct {
	JobID            string
	State            CsfJobState
	ExternalID       string
	Reason           string
	LogStream        string
	CleanupConfirmed bool
}

type UpdateSliceStateParams struct {
	SliceID        string
	State          CsfSliceState
	AssignmentID   string
	PullRequestUrl string
	Attempts       int32
	Checkpoint     string
	Error          string
	UpdatedAt      pgtype.Timestamptz
}

type UpsertCronTriggerParams struct {
	TriggerName         string
	ScheduleKind        string
	LocalHour           *int16
	LocalMinute         *int16
	Weekday             *int16
	MonthDay            *int16
	IntervalNanoseconds *int64
	RawExpression       *string
	Timezone            string
	IntervalAnchorAt    pgtype.Timestamptz
	NextRunAt           pgtype.Timestamptz
	CatchUpPolicy       string
	OverlapPolicy       string
	UpdatedAt           pgtype.Timestamptz
}