postgresql

package
v0.0.0-...-5d14948 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const OtelName = "github.com/danicc097/openapi-go-gin-postgres-sqlc/internal/repos/postgresql"

Variables

This section is empty.

Functions

func DynamicQuery 

func DynamicQuery(d models.DBTX, query string) (string, error)

DynamicQuery returns an SQL query result as JSON.

func GenerateDefaultFilters 

func GenerateDefaultFilters(entity models.TableEntity, paginationParams models.PaginationItems) (map[string][]interface{}, error)

GenerateDefaultFilters generates SQL where clauses for a given set of pagination params.

func New 

func New(logger *zap.SugaredLogger, options ...Option) (*pgxpool.Pool, *sql.DB, error)

New instantiates the PostgreSQL database using configuration defined in environment variables.

func ParseDBErrorDetail 

func ParseDBErrorDetail(err error) error

Types

type Activity 

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

Activity represents the repository used for interacting with Activity records.

func NewActivity 

func NewActivity() *Activity

NewActivity instantiates the Activity repository.

func (*Activity) ByID 

func (a *Activity) ByID(ctx context.Context, d models.DBTX, id models.ActivityID, opts ...models.ActivitySelectConfigOption) (*models.Activity, error)

func (*Activity) ByName 

func (a *Activity) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) (*models.Activity, error)

func (*Activity) ByProjectID 

func (a *Activity) ByProjectID(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.ActivitySelectConfigOption) ([]models.Activity, error)

func (*Activity) Create 

func (a *Activity) Create(ctx context.Context, d models.DBTX, params *models.ActivityCreateParams) (*models.Activity, error)

func (*Activity) Delete 

func (a *Activity) Delete(ctx context.Context, d models.DBTX, id models.ActivityID) (*models.Activity, error)

func (*Activity) Restore 

func (a *Activity) Restore(ctx context.Context, d models.DBTX, id models.ActivityID) error

func (*Activity) Update 

func (a *Activity) Update(ctx context.Context, d models.DBTX, id models.ActivityID, params *models.ActivityUpdateParams) (*models.Activity, error)

type DBOptions 

type DBOptions struct {
	DBName string
}

type DemoTwoWorkItem 

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

DemoTwoWorkItem represents the repository used for interacting with DemoTwoWorkItem records.

func NewDemoTwoWorkItem 

func NewDemoTwoWorkItem() *DemoTwoWorkItem

NewDemoTwoWorkItem instantiates the DemoTwoWorkItem repository.

func (*DemoTwoWorkItem) ByID 

func (u *DemoTwoWorkItem) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (*models.WorkItem, error)

func (*DemoTwoWorkItem) Create 

func (u *DemoTwoWorkItem) Create(ctx context.Context, d models.DBTX, params repos.DemoTwoWorkItemCreateParams) (*models.WorkItem, error)

func (*DemoTwoWorkItem) Update 

func (u *DemoTwoWorkItem) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params repos.DemoTwoWorkItemUpdateParams) (*models.WorkItem, error)

type DemoWorkItem 

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

DemoWorkItem represents the repository used for interacting with DemoWorkItem records.

func NewDemoWorkItem 

func NewDemoWorkItem() *DemoWorkItem

NewDemoWorkItem instantiates the DemoWorkItem repository.

func (*DemoWorkItem) ByID 

func (u *DemoWorkItem) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (*models.WorkItem, error)

func (*DemoWorkItem) Create 

func (u *DemoWorkItem) Create(ctx context.Context, d models.DBTX, params repos.DemoWorkItemCreateParams) (*models.WorkItem, error)

func (*DemoWorkItem) Paginated 

func (u *DemoWorkItem) Paginated(ctx context.Context, d models.DBTX, cursor models.WorkItemID, opts ...models.CacheDemoWorkItemSelectConfigOption) ([]models.CacheDemoWorkItem, error)

func (*DemoWorkItem) Update 

func (u *DemoWorkItem) Update(ctx context.Context, d models.DBTX, id models.WorkItemID, params repos.DemoWorkItemUpdateParams) (*models.WorkItem, error)

type KanbanStep 

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

KanbanStep represents the repository used for interacting with KanbanStep records.

func NewKanbanStep 

func NewKanbanStep() *KanbanStep

NewKanbanStep instantiates the KanbanStep repository.

func (*KanbanStep) ByID 

func (k *KanbanStep) ByID(ctx context.Context, d models.DBTX, id models.KanbanStepID, opts ...models.KanbanStepSelectConfigOption) (*models.KanbanStep, error)

func (*KanbanStep) ByProject 

func (k *KanbanStep) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID, opts ...models.KanbanStepSelectConfigOption) ([]models.KanbanStep, error)

type Notification 

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

Notification represents the repository used for interacting with Notification records.

func NewNotification 

func NewNotification() *Notification

NewNotification instantiates the Notification repository.

func (*Notification) Create 

func (u *Notification) Create(ctx context.Context, d models.DBTX, params *models.NotificationCreateParams) (*models.UserNotification, error)

func (*Notification) Delete 

func (u *Notification) Delete(ctx context.Context, d models.DBTX, id models.NotificationID) (*models.Notification, error)

func (*Notification) LatestNotifications 

func (u *Notification) LatestNotifications(ctx context.Context, d models.DBTX, params *models.GetUserNotificationsParams) ([]models.GetUserNotificationsRow, error)

func (*Notification) PaginatedUserNotifications 

func (u *Notification) PaginatedUserNotifications(ctx context.Context, d models.DBTX, userID models.UserID, params models.GetPaginatedNotificationsParams) ([]models.UserNotification, error)

type Option 

type Option func(*DBOptions)

func WithDBName 

func WithDBName(db string) Option

WithDBName sets the postgres database to connect to.

type Project 

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

Project represents the repository used for interacting with Project records.

func NewProject 

func NewProject() *Project

NewProject instantiates the Project repository.

func (*Project) ByID 

func (u *Project) ByID(ctx context.Context, d models.DBTX, id models.ProjectID, opts ...models.ProjectSelectConfigOption) (*models.Project, error)

func (*Project) ByName 

func (u *Project) ByName(ctx context.Context, d models.DBTX, name models.ProjectName, opts ...models.ProjectSelectConfigOption) (*models.Project, error)

func (*Project) IsTeamInProject 

func (u *Project) IsTeamInProject(ctx context.Context, d models.DBTX, arg models.IsTeamInProjectParams) (bool, error)

func (*Project) UpdateBoardConfig 

func (u *Project) UpdateBoardConfig(ctx context.Context, d models.DBTX, projectID models.ProjectID, paths []string, obj any) error

type QuerierWrapper 

type QuerierWrapper struct{ _sourceModels.Querier }

QuerierWrapper implements _sourceModels.Querier and wraps errors with the associated query name.

func NewQuerierWrapper 

func NewQuerierWrapper(base _sourceModels.Querier) QuerierWrapper

NewQuerierWrapper returns QuerierWrapper with wrapped pgx errors.

func (QuerierWrapper) GetExtraSchemaNotifications 

func (w QuerierWrapper) GetExtraSchemaNotifications(ctx context.Context, d _sourceModels.DBTX, arg _sourceModels.GetExtraSchemaNotificationsParams) (ga1 []_sourceModels.GetExtraSchemaNotificationsRow, err error)

func (QuerierWrapper) GetUser 

func (w QuerierWrapper) GetUser(ctx context.Context, d _sourceModels.DBTX, arg _sourceModels.GetUserParams) (g1 _sourceModels.GetUserRow, err error)

func (QuerierWrapper) GetUserNotifications 

func (w QuerierWrapper) GetUserNotifications(ctx context.Context, d _sourceModels.DBTX, arg _sourceModels.GetUserNotificationsParams) (ga1 []_sourceModels.GetUserNotificationsRow, err error)

func (QuerierWrapper) IsTeamInProject 

func (w QuerierWrapper) IsTeamInProject(ctx context.Context, d _sourceModels.DBTX, arg _sourceModels.IsTeamInProjectParams) (b1 bool, err error)

type Team 

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

Team represents the repository used for interacting with Team records.

func NewTeam 

func NewTeam() *Team

NewTeam instantiates the Team repository.

func (*Team) ByID 

func (t *Team) ByID(ctx context.Context, d models.DBTX, id models.TeamID, opts ...models.TeamSelectConfigOption) (*models.Team, error)

func (*Team) ByName 

func (t *Team) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.TeamSelectConfigOption) (*models.Team, error)

func (*Team) Create 

func (t *Team) Create(ctx context.Context, d models.DBTX, params *models.TeamCreateParams) (*models.Team, error)

func (*Team) Delete 

func (t *Team) Delete(ctx context.Context, d models.DBTX, id models.TeamID) (*models.Team, error)

func (*Team) Update 

func (t *Team) Update(ctx context.Context, d models.DBTX, id models.TeamID, params *models.TeamUpdateParams) (*models.Team, error)

type TimeEntry 

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

TimeEntry represents the repository used for interacting with TimeEntry records.

func NewTimeEntry 

func NewTimeEntry() *TimeEntry

NewTimeEntry instantiates the TimeEntry repository.

func (*TimeEntry) ByID 

func (wit *TimeEntry) ByID(ctx context.Context, d models.DBTX, id models.TimeEntryID, opts ...models.TimeEntrySelectConfigOption) (*models.TimeEntry, error)

func (*TimeEntry) Create 

func (wit *TimeEntry) Create(ctx context.Context, d models.DBTX, params *models.TimeEntryCreateParams) (*models.TimeEntry, error)

func (*TimeEntry) Delete 

func (wit *TimeEntry) Delete(ctx context.Context, d models.DBTX, id models.TimeEntryID) (*models.TimeEntry, error)

func (*TimeEntry) Update 

func (wit *TimeEntry) Update(ctx context.Context, d models.DBTX, id models.TimeEntryID, params *models.TimeEntryUpdateParams) (*models.TimeEntry, error)

type User 

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

User represents the repository used for interacting with User records.

func NewUser 

func NewUser() *User

NewUser instantiates the User repository.

func (*User) ByAPIKey 

func (u *User) ByAPIKey(ctx context.Context, d models.DBTX, apiKey string) (*models.User, error)

func (*User) ByEmail 

func (u *User) ByEmail(ctx context.Context, d models.DBTX, email string, opts ...models.UserSelectConfigOption) (*models.User, error)

func (*User) ByExternalID 

func (u *User) ByExternalID(ctx context.Context, d models.DBTX, extID string, opts ...models.UserSelectConfigOption) (*models.User, error)

func (*User) ByID 

func (u *User) ByID(ctx context.Context, d models.DBTX, id models.UserID, opts ...models.UserSelectConfigOption) (*models.User, error)

func (*User) ByProject 

func (u *User) ByProject(ctx context.Context, d models.DBTX, projectID models.ProjectID) ([]models.User, error)

func (*User) ByTeam 

func (u *User) ByTeam(ctx context.Context, d models.DBTX, teamID models.TeamID) ([]models.User, error)

func (*User) ByUsername 

func (u *User) ByUsername(ctx context.Context, d models.DBTX, username string, opts ...models.UserSelectConfigOption) (*models.User, error)

func (*User) Create 

func (u *User) Create(ctx context.Context, d models.DBTX, params *models.UserCreateParams) (*models.User, error)

func (*User) CreateAPIKey 

func (u *User) CreateAPIKey(ctx context.Context, d models.DBTX, user *models.User) (*models.UserAPIKey, error)

func (*User) Delete 

func (u *User) Delete(ctx context.Context, d models.DBTX, id models.UserID) (*models.User, error)

func (*User) DeleteAPIKey 

func (u *User) DeleteAPIKey(ctx context.Context, d models.DBTX, apiKey string) (*models.UserAPIKey, error)

func (*User) Paginated 

func (u *User) Paginated(ctx context.Context, d models.DBTX, params repos.GetPaginatedUsersParams) ([]models.User, error)

func (*User) Update 

func (u *User) Update(ctx context.Context, d models.DBTX, id models.UserID, params *models.UserUpdateParams) (*models.User, error)

type WorkItem 

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

WorkItem represents the repository used for interacting with WorkItem records.

func NewWorkItem 

func NewWorkItem() *WorkItem

NewWorkItem instantiates the WorkItem repository. NOTE: maybe we can consider work item an aggregate root, since we don't need distinction between projects for some tasks like assigning members, tags, generic functionality like Delete, Restore... and this simplifies everything a lot.

func (*WorkItem) AssignTag 

func (w *WorkItem) AssignTag(ctx context.Context, d models.DBTX, params *models.WorkItemWorkItemTagCreateParams) error

func (*WorkItem) AssignUser 

func (w *WorkItem) AssignUser(ctx context.Context, d models.DBTX, params *models.WorkItemAssigneeCreateParams) error

func (*WorkItem) ByID 

func (w *WorkItem) ByID(ctx context.Context, d models.DBTX, id models.WorkItemID, opts ...models.WorkItemSelectConfigOption) (*models.WorkItem, error)

func (*WorkItem) Delete 

func (w *WorkItem) Delete(ctx context.Context, d models.DBTX, id models.WorkItemID) (*models.WorkItem, error)

func (*WorkItem) RemoveAssignedUser 

func (w *WorkItem) RemoveAssignedUser(ctx context.Context, d models.DBTX, memberID models.UserID, workItemID models.WorkItemID) error

func (*WorkItem) RemoveTag 

func (w *WorkItem) RemoveTag(ctx context.Context, d models.DBTX, tagID models.WorkItemTagID, workItemID models.WorkItemID) error

func (*WorkItem) Restore 

func (w *WorkItem) Restore(ctx context.Context, d models.DBTX, id models.WorkItemID) (*models.WorkItem, error)

type WorkItemComment 

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

WorkItemComment represents the repository used for interacting with work item comment records.

func NewWorkItemComment 

func NewWorkItemComment() *WorkItemComment

NewWorkItemComment instantiates the work item comment repository.

func (*WorkItemComment) ByID 

func (t *WorkItemComment) ByID(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, opts ...models.WorkItemCommentSelectConfigOption) (*models.WorkItemComment, error)

func (*WorkItemComment) Create 

func (t *WorkItemComment) Create(ctx context.Context, d models.DBTX, params *models.WorkItemCommentCreateParams) (*models.WorkItemComment, error)

func (*WorkItemComment) Delete 

func (t *WorkItemComment) Delete(ctx context.Context, d models.DBTX, id models.WorkItemCommentID) (*models.WorkItemComment, error)

func (*WorkItemComment) Update 

func (t *WorkItemComment) Update(ctx context.Context, d models.DBTX, id models.WorkItemCommentID, params *models.WorkItemCommentUpdateParams) (*models.WorkItemComment, error)

type WorkItemTag 

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

WorkItemTag represents the repository used for interacting with WorkItemTag records.

func NewWorkItemTag 

func NewWorkItemTag() *WorkItemTag

NewWorkItemTag instantiates the WorkItemTag repository.

func (*WorkItemTag) ByID 

func (wit *WorkItemTag) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTagID, opts ...models.WorkItemTagSelectConfigOption) (*models.WorkItemTag, error)

func (*WorkItemTag) ByName 

func (wit *WorkItemTag) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTagSelectConfigOption) (*models.WorkItemTag, error)

func (*WorkItemTag) Create 

func (wit *WorkItemTag) Create(ctx context.Context, d models.DBTX, params *models.WorkItemTagCreateParams) (*models.WorkItemTag, error)

func (*WorkItemTag) Delete 

func (wit *WorkItemTag) Delete(ctx context.Context, d models.DBTX, id models.WorkItemTagID) (*models.WorkItemTag, error)

func (*WorkItemTag) Update 

func (wit *WorkItemTag) Update(ctx context.Context, d models.DBTX, id models.WorkItemTagID, params *models.WorkItemTagUpdateParams) (*models.WorkItemTag, error)

type WorkItemType 

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

WorkItemType represents the repository used for interacting with WorkItemType records.

func NewWorkItemType 

func NewWorkItemType() *WorkItemType

NewWorkItemType instantiates the WorkItemType repository.

func (*WorkItemType) ByID 

func (wit *WorkItemType) ByID(ctx context.Context, d models.DBTX, id models.WorkItemTypeID, opts ...models.WorkItemTypeSelectConfigOption) (*models.WorkItemType, error)

func (*WorkItemType) ByName 

func (wit *WorkItemType) ByName(ctx context.Context, d models.DBTX, name string, projectID models.ProjectID, opts ...models.WorkItemTypeSelectConfigOption) (*models.WorkItemType, error)

Source Files

View all Source files

Directories

Path Synopsis
gen
jet/public/enum
jet/public/model
jet/public/table
models
Package models provides primitives to interact with the openapi HTTP API.
 Package models provides primitives to interact with the openapi HTTP API.
xo-templates
tests/got
tests/snapshot

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.