codegen

package
v0.0.0-...-ed00c80 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 11, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateInfoParams

type CreateInfoParams struct {
	MagnetID sql.NullInt32 `json:"magnet_id"`
	Content  string        `json:"content"`
}

type CreateTaskParams

type CreateTaskParams struct {
	Name      string        `json:"name"`
	Directory string        `json:"directory"`
	MagnetID  sql.NullInt32 `json:"magnet_id"`
}

type CreateTorrentParams

type CreateTorrentParams struct {
	MagnetID sql.NullInt32 `json:"magnet_id"`
	Filename string        `json:"filename"`
	Path     string        `json:"path"`
	Md5      string        `json:"md5"`
}

type DBTX

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 FilterURLAndDirByTaskStatusRow

type FilterURLAndDirByTaskStatusRow struct {
	ID        sql.NullInt32  `json:"id"`
	Url       string         `json:"url"`
	Directory sql.NullString `json:"directory"`
}

type GetURLAndDirByTaskIDRow

type GetURLAndDirByTaskIDRow struct {
	Url       string         `json:"url"`
	Directory sql.NullString `json:"directory"`
}

type Info

type Info struct {
	ID       int32         `json:"id"`
	MagnetID sql.NullInt32 `json:"magnet_id"`
	Content  string        `json:"content"`
}

type ListTasksParams

type ListTasksParams struct {
	Limit  int32 `json:"limit"`
	Offset int32 `json:"offset"`
}

type Magnet

type Magnet struct {
	ID        int32     `json:"id"`
	Url       string    `json:"url"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateInfo

func (q *Queries) CreateInfo(ctx context.Context, arg CreateInfoParams) (int32, error)

func (*Queries) CreateMagnet

func (q *Queries) CreateMagnet(ctx context.Context, url string) (int32, error)

func (*Queries) CreateTask

func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (int32, error)

func (*Queries) CreateTorrent

func (q *Queries) CreateTorrent(ctx context.Context, arg CreateTorrentParams) (int32, error)

func (*Queries) DeleteInfoByID

func (q *Queries) DeleteInfoByID(ctx context.Context, id int32) error

func (*Queries) DeleteMagnetByID

func (q *Queries) DeleteMagnetByID(ctx context.Context, id int32) error

func (*Queries) DeleteTaskByID

func (q *Queries) DeleteTaskByID(ctx context.Context, id int32) error

func (*Queries) DeleteTorrentByID

func (q *Queries) DeleteTorrentByID(ctx context.Context, id int32) error

func (*Queries) FilterTaskByStatus

func (q *Queries) FilterTaskByStatus(ctx context.Context, status string) ([]Task, error)

func (*Queries) FilterURLAndDirByTaskStatus

func (q *Queries) FilterURLAndDirByTaskStatus(ctx context.Context, status string) ([]FilterURLAndDirByTaskStatusRow, error)

func (*Queries) GetInfoByID

func (q *Queries) GetInfoByID(ctx context.Context, id int32) (Info, error)

func (*Queries) GetMagnetByID

func (q *Queries) GetMagnetByID(ctx context.Context, id int32) (Magnet, error)

func (*Queries) GetMagnetByURL

func (q *Queries) GetMagnetByURL(ctx context.Context, url string) (Magnet, error)

func (*Queries) GetTaskByID

func (q *Queries) GetTaskByID(ctx context.Context, id int32) (Task, error)

func (*Queries) GetTorrentByID

func (q *Queries) GetTorrentByID(ctx context.Context, id int32) (Torrent, error)

func (*Queries) GetTorrentByMd5

func (q *Queries) GetTorrentByMd5(ctx context.Context, md5 string) (Torrent, error)

func (*Queries) GetURLAndDirByTaskID

func (q *Queries) GetURLAndDirByTaskID(ctx context.Context, id int32) (GetURLAndDirByTaskIDRow, error)

func (*Queries) ListTasks

func (q *Queries) ListTasks(ctx context.Context, arg ListTasksParams) ([]Task, error)

func (*Queries) UpdateTaksDownloaded

func (q *Queries) UpdateTaksDownloaded(ctx context.Context, arg UpdateTaksDownloadedParams) error

func (*Queries) UpdateTaksStatus

func (q *Queries) UpdateTaksStatus(ctx context.Context, arg UpdateTaksStatusParams) error

func (*Queries) UpdateTaksTotalBytes

func (q *Queries) UpdateTaksTotalBytes(ctx context.Context, arg UpdateTaksTotalBytesParams) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type Task

type Task struct {
	ID            int32         `json:"id"`
	Name          string        `json:"name"`
	MagnetID      sql.NullInt32 `json:"magnet_id"`
	Directory     string        `json:"directory"`
	TotalBytes    int64         `json:"total_bytes"`
	DownloadBytes int64         `json:"download_bytes"`
	Status        string        `json:"status"`
	CreatedAt     time.Time     `json:"created_at"`
	UpdatedAt     time.Time     `json:"updated_at"`
}

type Torrent

type Torrent struct {
	ID        int32         `json:"id"`
	MagnetID  sql.NullInt32 `json:"magnet_id"`
	Filename  string        `json:"filename"`
	Path      string        `json:"path"`
	Md5       string        `json:"md5"`
	CreatedAt time.Time     `json:"created_at"`
	UpdatedAt time.Time     `json:"updated_at"`
}

type UpdateTaksDownloadedParams

type UpdateTaksDownloadedParams struct {
	ID            int32 `json:"id"`
	DownloadBytes int64 `json:"download_bytes"`
}

type UpdateTaksStatusParams

type UpdateTaksStatusParams struct {
	ID     int32  `json:"id"`
	Status string `json:"status"`
}

type UpdateTaksTotalBytesParams

type UpdateTaksTotalBytesParams struct {
	ID         int32 `json:"id"`
	TotalBytes int64 `json:"total_bytes"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL