db

package
v0.0.0-...-95bf05a Latest Latest
Warning

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

 Go to latest Published: Nov 3, 2024 License: AGPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Article 

type Article struct {
	DbID       int64
	ReadTime   pgtype.Timestamptz
	Identifier string
	UserDbID   int64
	UpdatedAt  pgtype.Timestamptz
}

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 DeleteDeviceParams 

type DeleteDeviceParams struct {
	UserDbID int64
	DeviceID string
}

type DeleteDeviceWithLegacyIdParams 

type DeleteDeviceWithLegacyIdParams struct {
	UserDbID       int64
	LegacyDeviceID int64
}

type Device 

type Device struct {
	DbID           int64
	DeviceID       string
	LegacyDeviceID int64
	DeviceName     string
	LastSeen       pgtype.Timestamptz
	UserDbID       int64
}

type GetAllUsersRow 

type GetAllUsersRow struct {
	DbID   int64
	UserID string
}

type GetArticlesUpdatedSinceParams 

type GetArticlesUpdatedSinceParams struct {
	UserDbID  int64
	UpdatedAt pgtype.Timestamptz
}

type GetLegacyDeviceParams 

type GetLegacyDeviceParams struct {
	UserDbID       int64
	LegacyDeviceID int64
}

type GetSyncCodeAndLegacyDeviceParams 

type GetSyncCodeAndLegacyDeviceParams struct {
	LegacyDeviceID int64
	LegacySyncCode string
}

type GetSyncCodeAndLegacyDeviceRow 

type GetSyncCodeAndLegacyDeviceRow struct {
	User   User
	Device Device
}

type GetUserAndDeviceParams 

type GetUserAndDeviceParams struct {
	DeviceID string
	UserID   string
}

type GetUserAndDeviceRow 

type GetUserAndDeviceRow struct {
	User   User
	Device Device
}

type GetUsersWithDevicesRow 

type GetUsersWithDevicesRow struct {
	User     User
	LastSeen interface{}
}

type InsertArticleParams 

type InsertArticleParams struct {
	UserDbID   int64
	Identifier string
	ReadTime   pgtype.Timestamptz
	UpdatedAt  pgtype.Timestamptz
}

type InsertDeviceParams 

type InsertDeviceParams struct {
	DeviceID       string
	DeviceName     string
	LastSeen       pgtype.Timestamptz
	LegacyDeviceID int64
	UserDbID       int64
}

type InsertUserParams 

type InsertUserParams struct {
	UserID         string
	LegacySyncCode string
}

type LegacyFeed 

type LegacyFeed struct {
	DbID        int64
	ContentHash int64
	Content     string
	Etag        string
	UserDbID    int64
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) DeleteArticlesOlderThanDeviceLastSeen 

func (q *Queries) DeleteArticlesOlderThanDeviceLastSeen(ctx context.Context, userDbID int64) error

func (*Queries) DeleteArticlesWithUserDbId 

func (q *Queries) DeleteArticlesWithUserDbId(ctx context.Context, userDbID int64) ([]string, error)

func (*Queries) DeleteDevice 

func (q *Queries) DeleteDevice(ctx context.Context, arg DeleteDeviceParams) ([]string, error)

func (*Queries) DeleteDeviceWithLegacyId 

func (q *Queries) DeleteDeviceWithLegacyId(ctx context.Context, arg DeleteDeviceWithLegacyIdParams) (Device, error)

func (*Queries) DeleteDevicesWithUserDbId 

func (q *Queries) DeleteDevicesWithUserDbId(ctx context.Context, userDbID int64) ([]string, error)

func (*Queries) DeleteLegacyFeedsWithUserDbId 

func (q *Queries) DeleteLegacyFeedsWithUserDbId(ctx context.Context, userDbID int64) ([]int64, error)

func (*Queries) DeleteOldDevices 

func (q *Queries) DeleteOldDevices(ctx context.Context, lastSeen pgtype.Timestamptz) error

func (*Queries) DeleteUser 

func (q *Queries) DeleteUser(ctx context.Context, userID string) ([]string, error)

func (*Queries) GetAllArticles 

func (q *Queries) GetAllArticles(ctx context.Context) ([]Article, error)

func (*Queries) GetAllDevices 

func (q *Queries) GetAllDevices(ctx context.Context) ([]Device, error)

func (*Queries) GetAllLegacyFeeds 

func (q *Queries) GetAllLegacyFeeds(ctx context.Context) ([]LegacyFeed, error)

func (*Queries) GetAllUsers 

func (q *Queries) GetAllUsers(ctx context.Context) ([]GetAllUsersRow, error)

func (*Queries) GetArticlesUpdatedSince 

func (q *Queries) GetArticlesUpdatedSince(ctx context.Context, arg GetArticlesUpdatedSinceParams) ([]Article, error)

func (*Queries) GetDevices 

func (q *Queries) GetDevices(ctx context.Context, userDbID int64) ([]Device, error)

func (*Queries) GetLegacyDevice 

func (q *Queries) GetLegacyDevice(ctx context.Context, arg GetLegacyDeviceParams) (Device, error)

func (*Queries) GetLegacyDevicesEtag 

func (q *Queries) GetLegacyDevicesEtag(ctx context.Context, userDbID int64) ([]byte, error)

func (*Queries) GetLegacyFeeds 

func (q *Queries) GetLegacyFeeds(ctx context.Context, userDbID int64) (LegacyFeed, error)

func (*Queries) GetLegacyFeedsEtag 

func (q *Queries) GetLegacyFeedsEtag(ctx context.Context, userDbID int64) (string, error)

func (*Queries) GetSyncCodeAndLegacyDevice 

func (q *Queries) GetSyncCodeAndLegacyDevice(ctx context.Context, arg GetSyncCodeAndLegacyDeviceParams) (GetSyncCodeAndLegacyDeviceRow, error)

func (*Queries) GetUserAndDevice 

func (q *Queries) GetUserAndDevice(ctx context.Context, arg GetUserAndDeviceParams) (GetUserAndDeviceRow, error)

func (*Queries) GetUserBySyncCode 

func (q *Queries) GetUserBySyncCode(ctx context.Context, legacySyncCode string) (User, error)

func (*Queries) GetUserByUserId 

func (q *Queries) GetUserByUserId(ctx context.Context, userID string) (User, error)

func (*Queries) GetUserDbId 

func (q *Queries) GetUserDbId(ctx context.Context, userID string) (int64, error)

func (*Queries) GetUserDbIdBySyncCode 

func (q *Queries) GetUserDbIdBySyncCode(ctx context.Context, legacySyncCode string) (int64, error)

func (*Queries) GetUsersWithDevices 

func (q *Queries) GetUsersWithDevices(ctx context.Context) ([]GetUsersWithDevicesRow, error)

func (*Queries) GetUsersWithoutDevices 

func (q *Queries) GetUsersWithoutDevices(ctx context.Context) ([]User, error)

func (*Queries) InsertArticle 

func (q *Queries) InsertArticle(ctx context.Context, arg InsertArticleParams) (Article, error)

func (*Queries) InsertDevice 

func (q *Queries) InsertDevice(ctx context.Context, arg InsertDeviceParams) (Device, error)

func (*Queries) InsertUser 

func (q *Queries) InsertUser(ctx context.Context, arg InsertUserParams) (User, error)

func (*Queries) UpdateLastSeenForDevice 

func (q *Queries) UpdateLastSeenForDevice(ctx context.Context, arg UpdateLastSeenForDeviceParams) error

func (*Queries) UpdateLegacyFeeds 

func (q *Queries) UpdateLegacyFeeds(ctx context.Context, arg UpdateLegacyFeedsParams) (int64, error)

func (*Queries) WithTx 

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

type UpdateLastSeenForDeviceParams 

type UpdateLastSeenForDeviceParams struct {
	LastSeen pgtype.Timestamptz
	DbID     int64
}

type UpdateLegacyFeedsParams 

type UpdateLegacyFeedsParams struct {
	UserDbID    int64
	ContentHash int64
	Content     string
	Etag        string
}

type User 

type User struct {
	DbID           int64
	UserID         string
	LegacySyncCode string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.