postgres

type Connection genericConn

type CreateJobParams struct {
	ChatID int64
	SendAt time.Time
	Flags  pgtype.Int2
	Title  pgtype.Varchar
}

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

type FindAtTimeRow struct {
	ID     int64          `json:"id"`
	ChatID int64          `json:"chat_id"`
	Title  pgtype.Varchar `json:"title"`
	SendAt time.Time      `json:"send_at"`
	Flags  pgtype.Int2    `json:"flags"`
}

type FindByChatRow struct {
	ID     int64          `json:"id"`
	ChatID int64          `json:"chat_id"`
	Title  pgtype.Varchar `json:"title"`
	SendAt time.Time      `json:"send_at"`
	Flags  pgtype.Int2    `json:"flags"`
}

type FindByIDRow struct {
	ID     int64          `json:"id"`
	ChatID int64          `json:"chat_id"`
	Title  pgtype.Varchar `json:"title"`
	SendAt time.Time      `json:"send_at"`
	Flags  pgtype.Int2    `json:"flags"`
}

type FindInPeriodRow struct {
	ID     int64          `json:"id"`
	ChatID int64          `json:"chat_id"`
	Title  pgtype.Varchar `json:"title"`
	SendAt time.Time      `json:"send_at"`
	Flags  pgtype.Int2    `json:"flags"`
}

type Querier interface {
	CreateJob(ctx context.Context, params CreateJobParams) (int64, error)
	// CreateJobBatch enqueues a CreateJob query into batch to be executed
	// later by the batch.
	CreateJobBatch(batch genericBatch, params CreateJobParams)
	// CreateJobScan scans the result of an executed CreateJobBatch query.
	CreateJobScan(results pgx.BatchResults) (int64, error)

	FindByID(ctx context.Context, id int64) (FindByIDRow, error)
	// FindByIDBatch enqueues a FindByID query into batch to be executed
	// later by the batch.
	FindByIDBatch(batch genericBatch, id int64)
	// FindByIDScan scans the result of an executed FindByIDBatch query.
	FindByIDScan(results pgx.BatchResults) (FindByIDRow, error)

	FindInPeriod(ctx context.Context, at time.Time, period time.Duration) ([]FindInPeriodRow, error)
	// FindInPeriodBatch enqueues a FindInPeriod query into batch to be executed
	// later by the batch.
	FindInPeriodBatch(batch genericBatch, at time.Time, period time.Duration)
	// FindInPeriodScan scans the result of an executed FindInPeriodBatch query.
	FindInPeriodScan(results pgx.BatchResults) ([]FindInPeriodRow, error)

	CountInChat(ctx context.Context, chatID int64) (int64, error)
	// CountInChatBatch enqueues a CountInChat query into batch to be executed
	// later by the batch.
	CountInChatBatch(batch genericBatch, chatID int64)
	// CountInChatScan scans the result of an executed CountInChatBatch query.
	CountInChatScan(results pgx.BatchResults) (int64, error)

	FindByChat(ctx context.Context, chatID int64) ([]FindByChatRow, error)
	// FindByChatBatch enqueues a FindByChat query into batch to be executed
	// later by the batch.
	FindByChatBatch(batch genericBatch, chatID int64)
	// FindByChatScan scans the result of an executed FindByChatBatch query.
	FindByChatScan(results pgx.BatchResults) ([]FindByChatRow, error)

	FindAtTime(ctx context.Context, at time.Time) ([]FindAtTimeRow, error)
	// FindAtTimeBatch enqueues a FindAtTime query into batch to be executed
	// later by the batch.
	FindAtTimeBatch(batch genericBatch, at time.Time)
	// FindAtTimeScan scans the result of an executed FindAtTimeBatch query.
	FindAtTimeScan(results pgx.BatchResults) ([]FindAtTimeRow, error)

	Delete(ctx context.Context, id int64) (pgconn.CommandTag, error)
	// DeleteBatch enqueues a Delete query into batch to be executed
	// later by the batch.
	DeleteBatch(batch genericBatch, id int64)
	// DeleteScan scans the result of an executed DeleteBatch query.
	DeleteScan(results pgx.BatchResults) (pgconn.CommandTag, error)
}

type QuerierConfig struct {
	// DataTypes contains pgtype.Value to use for encoding and decoding instead
	// of pggen-generated pgtype.ValueTranscoder.
	//
	// If OIDs are available for an input parameter type and all of its
	// transitive dependencies, pggen will use the binary encoding format for
	// the input parameter.
	DataTypes []pgtype.DataType
}

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