postgres

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type EnqueueScheduledParams struct {
	Payload     string
	ScheduledAt time.Time
}

type GetImmediateJobsParams struct {
	LastProcessedAt            time.Time
	LastProcessedTransactionID int64
	LastProcessedID            int64
	BatchSize                  int32
}

type GetScheduledJobsReadyRow struct {
	ID          int64
	Payload     string
	ScheduledAt time.Time
}

type InsertDeadLetterBatchParams struct {
	Ids           []int64
	Payloads      []string
	ErrorMessages []string
	RetryCounts   []int32
}

type InsertDeadLetterParams struct {
	ID           int64
	Payload      string
	ErrorMessage sql.NullString
	RetryCount   int32
}

type InsertFailedBatchParams struct {
	Ids           []int64
	Payloads      []string
	ErrorMessages []string
	RetryCounts   []int32
}

type InsertFailedParams struct {
	ID           int64
	Payload      string
	ErrorMessage sql.NullString
	RetryCount   int32
}

type InsertPartitionMetaParams struct {
	PartitionName string
	RangeStart    time.Time
	RangeEnd      time.Time
}

type KeepaliveRequest struct {
	// ServerWALEnd is the server's current write-ahead log position.
	ServerWALEnd LSN
	// ReplyRequested indicates if the client should send a status update.
	ReplyRequested bool
}

type LSN = pglogrepl.LSN

type ListPartitionsRow struct {
	PartitionName string
	RangeStart    time.Time
	RangeEnd      time.Time
}

type LogicalReplChange struct {
	// ID is the job identifier from the database.
	ID int64
	// Payload is the job data as bytes (typically JSON).
	Payload []byte
	// CreatedAt is when the change was created in the database.
	CreatedAt time.Time
	// TransactionID is the transaction ID that produced this change.
	TransactionID int64
	// CommitLsn is the LSN as stored in the immediate table.
	CommitLsn string
	// LSN is the write-ahead log position of this change.
	LSN LSN
}

type MessageParser interface {
	// Parse decodes raw WAL data into a pglogrepl message.
	Parse(walData []byte) (pglogrepl.Message, error)
	// ParseRelation extracts table metadata from a relation message.
	ParseRelation(msg *pglogrepl.RelationMessage) *RelationMetadata
	// ParseInsert extracts change data from an insert message.
	ParseInsert(msg *pglogrepl.InsertMessageV2, relMeta *RelationMetadata, lsn LSN) (*LogicalReplChange, error)
}

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

type PgoutputParser struct{}

type PoutboxCursor struct {
	ID                         int32
	LastProcessedID            int64
	LastProcessedAt            time.Time
	LastProcessedTransactionID int64
	LastLsn                    string
	UpdatedAt                  time.Time
}

type PoutboxDeadLetter struct {
	ID           int64
	Payload      string
	ErrorMessage sql.NullString
	RetryCount   int32
	FailedAt     time.Time
	DeadAt       time.Time
}

type PoutboxFailed struct {
	ID           int64
	Payload      string
	ErrorMessage sql.NullString
	RetryCount   int32
	FailedAt     time.Time
	NextRetryAt  time.Time
}

type PoutboxImmediate struct {
	ID            int64
	Payload       string
	CreatedAt     time.Time
	TransactionID int64
	CommitLsn     string
}

type PoutboxPartitionMetum struct {
	PartitionName string
	RangeStart    time.Time
	RangeEnd      time.Time
	CreatedAt     time.Time
}

type PoutboxScheduled struct {
	ID          int64
	Payload     string
	ScheduledAt time.Time
	CreatedAt   time.Time
}

type Queries struct {
}

type RelationMetadata struct {
	// ID is the relation OID.
	ID uint32
	// Name is the table name.
	Name string
	// Columns describes the table columns.
	Columns []*pglogrepl.RelationMessageColumn
}

type ReplicationEvent struct {
	// Type is the event type: "keepalive" or "insert".
	Type string
	// Change contains the logical replication change data for insert events.
	Change *LogicalReplChange
	// Keepalive contains the server keepalive request for keepalive events.
	Keepalive *KeepaliveRequest
}

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

type UpdateCursorParams struct {
	LastProcessedID            int64
	LastProcessedAt            time.Time
	LastProcessedTransactionID int64
	LastLsn                    string
}

type UpdateFailedParams struct {
	ErrorMessage sql.NullString
	RetryCount   int32
	ID           int64
}