sqlc

type AcquireMessagesByTopicParams struct {
	Topic string      `json:"topic"`
	Limit pgtype.Int4 `json:"limit"`
}

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
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

type DeleteExpiredMessagesParams struct {
	Topic  string             `json:"topic"`
	Cutoff pgtype.Timestamptz `json:"cutoff"`
}

type DeleteMessagesByIdsParams struct {
	Topic string  `json:"topic"`
	Ids   []int64 `json:"ids"`
}

type GetTopicExclusiveStatusRow struct {
	ExclusiveConsumerID        *uuid.UUID         `json:"exclusive_consumer_id"`
	ExclusiveConsumerExpiresAt pgtype.Timestamptz `json:"exclusive_consumer_expires_at"`
}

type GetTopicForUpdateRow struct {
	ExclusiveConsumerID        *uuid.UUID         `json:"exclusive_consumer_id"`
	ExclusiveConsumerExpiresAt pgtype.Timestamptz `json:"exclusive_consumer_expires_at"`
}

type InsertMaintenanceLeaseIfAbsentParams struct {
	Topic    string    `json:"topic"`
	HolderID uuid.UUID `json:"holder_id"`
}

type InsertMessageParams struct {
	Topic   string `json:"topic"`
	Payload []byte `json:"payload"`
}

type InsertTopicIfAbsentParams struct {
	Topic           string      `json:"topic"`
	ExpirationNanos pgtype.Int8 `json:"expiration_nanos"`
}

type MaintenanceLease struct {
	Topic      string             `json:"topic"`
	HolderID   uuid.UUID          `json:"holder_id"`
	AcquiredAt pgtype.Timestamptz `json:"acquired_at"`
}

type Message struct {
	ID         int64              `json:"id"`
	InsertedAt pgtype.Timestamptz `json:"inserted_at"`
	Topic      string             `json:"topic"`
	Payload    []byte             `json:"payload"`
}

type Queries struct {
}

type RenewTopicExclusiveConsumerParams struct {
	Topic                      string             `json:"topic"`
	ExclusiveConsumerID        *uuid.UUID         `json:"exclusive_consumer_id"`
	ExclusiveConsumerExpiresAt pgtype.Timestamptz `json:"exclusive_consumer_expires_at"`
}

type SelectMaintenanceLeaseForUpdateRow struct {
	HolderID   uuid.UUID          `json:"holder_id"`
	AcquiredAt pgtype.Timestamptz `json:"acquired_at"`
}

type SetTopicExclusiveConsumerParams struct {
	Topic                      string             `json:"topic"`
	ExclusiveConsumerID        *uuid.UUID         `json:"exclusive_consumer_id"`
	ExclusiveConsumerExpiresAt pgtype.Timestamptz `json:"exclusive_consumer_expires_at"`
}

type Topic struct {
	Topic                      string             `json:"topic"`
	ExpirationNanos            pgtype.Int8        `json:"expiration_nanos"`
	ExclusiveConsumerID        *uuid.UUID         `json:"exclusive_consumer_id"`
	ExclusiveConsumerExpiresAt pgtype.Timestamptz `json:"exclusive_consumer_expires_at"`
}

type UpdateMaintenanceLeaseParams struct {
	Topic    string    `json:"topic"`
	HolderID uuid.UUID `json:"holder_id"`
}