postgres

type Connection interface {
	BeginFunc(ctx context.Context, f func(pgx.Tx) error) error
	// contains filtered or unexported methods
}

type CreateChatRow struct {
	ID        int64              `json:"id"`
	CreatedAt pgtype.Timestamptz `json:"created_at"`
}

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

type FindAllActiveChatsRow struct {
	ID        int64              `json:"id"`
	ChatID    int64              `json:"chat_id"`
	GroupID   int                `json:"group_id"`
	CreatedAt pgtype.Timestamptz `json:"created_at"`
	DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}

type FindByIDRow struct {
	ID        int64              `json:"id"`
	ChatID    int64              `json:"chat_id"`
	GroupID   int                `json:"group_id"`
	CreatedAt pgtype.Timestamptz `json:"created_at"`
	DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}

type FindByTgIDRow struct {
	ID        int64              `json:"id"`
	ChatID    int64              `json:"chat_id"`
	GroupID   int                `json:"group_id"`
	CreatedAt pgtype.Timestamptz `json:"created_at"`
	DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}

type Querier interface {
	CreateChat(ctx context.Context, chatID int64) (CreateChatRow, error)
	// CreateChatBatch enqueues a CreateChat query into batch to be executed
	// later by the batch.
	CreateChatBatch(batch genericBatch, chatID int64)
	// CreateChatScan scans the result of an executed CreateChatBatch query.
	CreateChatScan(results pgx.BatchResults) (CreateChatRow, error)

	FindByTgID(ctx context.Context, chatID int64) (FindByTgIDRow, error)
	// FindByTgIDBatch enqueues a FindByTgID query into batch to be executed
	// later by the batch.
	FindByTgIDBatch(batch genericBatch, chatID int64)
	// FindByTgIDScan scans the result of an executed FindByTgIDBatch query.
	FindByTgIDScan(results pgx.BatchResults) (FindByTgIDRow, 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)

	FindAllActiveChats(ctx context.Context) ([]FindAllActiveChatsRow, error)
	// FindAllActiveChatsBatch enqueues a FindAllActiveChats query into batch to be executed
	// later by the batch.
	FindAllActiveChatsBatch(batch genericBatch)
	// FindAllActiveChatsScan scans the result of an executed FindAllActiveChatsBatch query.
	FindAllActiveChatsScan(results pgx.BatchResults) ([]FindAllActiveChatsRow, error)

	UndeleteChat(ctx context.Context, chatID int64) (pgconn.CommandTag, error)
	// UndeleteChatBatch enqueues a UndeleteChat query into batch to be executed
	// later by the batch.
	UndeleteChatBatch(batch genericBatch, chatID int64)
	// UndeleteChatScan scans the result of an executed UndeleteChatBatch query.
	UndeleteChatScan(results pgx.BatchResults) (pgconn.CommandTag, error)

	Delete(ctx context.Context, chatID int64) (pgconn.CommandTag, error)
	// DeleteBatch enqueues a Delete query into batch to be executed
	// later by the batch.
	DeleteBatch(batch genericBatch, chatID 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
}