pg

package
v0.7.8 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Package pg contains generated code for schema 'public'.

Index

Constants

View Source 
const (
	CursorOrderColumnName = "created_at"
	CursorDefaultLimit    = 15
)

Variables

This section is empty.

Functions

func ApplyTo added in v0.7.5 

func ApplyTo(p *pgdb.CursorPageParams, sql squirrel.SelectBuilder) squirrel.SelectBuilder

ApplyTo returns a new SelectBuilder after applying the paging effects of `p` to `sql`. This method provides the default case for paging: int64 cursor-based paging by an id column.

func NewClaimQ 

func NewClaimQ(db *pgdb.DB) data.ClaimQ

NewClaimQ - creates new instance

func NewClaimsSchemaQ added in v0.2.0 

func NewClaimsSchemaQ(db *pgdb.DB) data.ClaimsSchemaQ

NewClaimsSchemaQ - creates new instance

func NewEmailInvitationQ 

func NewEmailInvitationQ(db *pgdb.DB) data.EmailInvitationQ

NewEmailInvitationQ - creates new instance

func NewGorpMigrationQ 

func NewGorpMigrationQ(db *pgdb.DB) data.GorpMigrationQ

NewGorpMigrationQ - creates new instance

func NewGroupQ 

func NewGroupQ(db *pgdb.DB) data.GroupQ

NewGroupQ - creates new instance

func NewGroupUserQ 

func NewGroupUserQ(db *pgdb.DB) data.GroupUserQ

NewGroupUserQ - creates new instance

func NewOrganizationQ 

func NewOrganizationQ(db *pgdb.DB) data.OrganizationQ

NewOrganizationQ - creates new instance

func NewRequestQ 

func NewRequestQ(db *pgdb.DB) data.RequestQ

NewRequestQ - creates new instance

func NewUserQ 

func NewUserQ(db *pgdb.DB) data.UserQ

NewUserQ - creates new instance

Types

type ClaimQ 

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

ClaimQ represents helper struct to access row of 'claims'.

func (ClaimQ) ClaimByID added in v0.3.0 

func (q ClaimQ) ClaimByID(id int64, isForUpdate bool) (*data.Claim, error)

ClaimByID retrieves a row from 'public.claims' as a Claim.

Generated from index 'claims_pkey'.

func (ClaimQ) ClaimByIDCtx added in v0.3.0 

func (q ClaimQ) ClaimByIDCtx(ctx context.Context, id int64, isForUpdate bool) (*data.Claim, error)

ClaimByIDCtx retrieves a row from 'public.claims' as a Claim.

Generated from index 'claims_pkey'.

func (ClaimQ) Delete added in v0.3.0 

func (q ClaimQ) Delete(c *data.Claim) error

Delete deletes the Claim from the database.

func (ClaimQ) DeleteCtx added in v0.3.0 

func (q ClaimQ) DeleteCtx(ctx context.Context, c *data.Claim) error

DeleteCtx deletes the Claim from the database.

func (ClaimQ) Insert added in v0.3.0 

func (q ClaimQ) Insert(c *data.Claim) error

Insert insert a Claim to the database.

func (ClaimQ) InsertCtx added in v0.3.0 

func (q ClaimQ) InsertCtx(ctx context.Context, c *data.Claim) error

InsertCtx inserts a Claim to the database.

func (ClaimQ) SelectCtx added in v0.3.0 

func (q ClaimQ) SelectCtx(ctx context.Context, selector data.ClaimsSelector) ([]data.Claim, error)

func (ClaimQ) Update added in v0.3.0 

func (q ClaimQ) Update(c *data.Claim) error

Update updates a Claim in the database.

func (ClaimQ) UpdateCtx added in v0.3.0 

func (q ClaimQ) UpdateCtx(ctx context.Context, c *data.Claim) error

UpdateCtx updates a Claim in the database.

func (ClaimQ) Upsert added in v0.3.0 

func (q ClaimQ) Upsert(c *data.Claim) error

Upsert performs an upsert for Claim.

func (ClaimQ) UpsertCtx added in v0.3.0 

func (q ClaimQ) UpsertCtx(ctx context.Context, c *data.Claim) error

UpsertCtx performs an upsert for Claim.

type ClaimsSchemaQ added in v0.2.0 

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

ClaimsSchemaQ represents helper struct to access row of 'claims_schemas'.

func (ClaimsSchemaQ) ClaimsSchemaByID added in v0.2.0 

func (q ClaimsSchemaQ) ClaimsSchemaByID(id uuid.UUID, isForUpdate bool) (*data.ClaimsSchema, error)

ClaimsSchemaByID retrieves a row from 'public.claims_schemas' as a ClaimsSchema.

Generated from index 'claims_schemas_pkey'.

func (ClaimsSchemaQ) ClaimsSchemaByIDCtx added in v0.2.0 

func (q ClaimsSchemaQ) ClaimsSchemaByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.ClaimsSchema, error)

ClaimsSchemaByIDCtx retrieves a row from 'public.claims_schemas' as a ClaimsSchema.

Generated from index 'claims_schemas_pkey'.

func (ClaimsSchemaQ) Delete added in v0.2.0 

func (q ClaimsSchemaQ) Delete(cs *data.ClaimsSchema) error

Delete deletes the ClaimsSchema from the database.

func (ClaimsSchemaQ) DeleteCtx added in v0.2.0 

func (q ClaimsSchemaQ) DeleteCtx(ctx context.Context, cs *data.ClaimsSchema) error

DeleteCtx deletes the ClaimsSchema from the database.

func (ClaimsSchemaQ) Insert added in v0.2.0 

func (q ClaimsSchemaQ) Insert(cs *data.ClaimsSchema) error

Insert insert a ClaimsSchema to the database.

func (ClaimsSchemaQ) InsertCtx added in v0.2.0 

func (q ClaimsSchemaQ) InsertCtx(ctx context.Context, cs *data.ClaimsSchema) error

InsertCtx inserts a ClaimsSchema to the database.

func (ClaimsSchemaQ) SelectCtx added in v0.2.0 

func (q ClaimsSchemaQ) SelectCtx(ctx context.Context, selector data.ClaimsSchemasSelector) ([]data.ClaimsSchema, error)

func (ClaimsSchemaQ) Update added in v0.2.0 

func (q ClaimsSchemaQ) Update(cs *data.ClaimsSchema) error

Update updates a ClaimsSchema in the database.

func (ClaimsSchemaQ) UpdateCtx added in v0.2.0 

func (q ClaimsSchemaQ) UpdateCtx(ctx context.Context, cs *data.ClaimsSchema) error

UpdateCtx updates a ClaimsSchema in the database.

func (ClaimsSchemaQ) Upsert added in v0.2.0 

func (q ClaimsSchemaQ) Upsert(cs *data.ClaimsSchema) error

Upsert performs an upsert for ClaimsSchema.

func (ClaimsSchemaQ) UpsertCtx added in v0.2.0 

func (q ClaimsSchemaQ) UpsertCtx(ctx context.Context, cs *data.ClaimsSchema) error

UpsertCtx performs an upsert for ClaimsSchema.

type EmailInvitationQ 

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

EmailInvitationQ represents helper struct to access row of 'email_invitations'.

func (EmailInvitationQ) Delete 

func (q EmailInvitationQ) Delete(ei *data.EmailInvitation) error

Delete deletes the EmailInvitation from the database.

func (EmailInvitationQ) DeleteCtx 

func (q EmailInvitationQ) DeleteCtx(ctx context.Context, ei *data.EmailInvitation) error

DeleteCtx deletes the EmailInvitation from the database.

func (EmailInvitationQ) EmailInvitationByID 

func (q EmailInvitationQ) EmailInvitationByID(id uuid.UUID, isForUpdate bool) (*data.EmailInvitation, error)

EmailInvitationByID retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_pkey'.

func (EmailInvitationQ) EmailInvitationByIDCtx 

func (q EmailInvitationQ) EmailInvitationByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.EmailInvitation, error)

EmailInvitationByIDCtx retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_pkey'.

func (EmailInvitationQ) EmailInvitationsByGroupID 

func (q EmailInvitationQ) EmailInvitationsByGroupID(groupID uuid.UUID, isForUpdate bool) ([]data.EmailInvitation, error)

EmailInvitationsByGroupID retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_group_index'.

func (EmailInvitationQ) EmailInvitationsByGroupIDCtx 

func (q EmailInvitationQ) EmailInvitationsByGroupIDCtx(ctx context.Context, groupID uuid.UUID, isForUpdate bool) ([]data.EmailInvitation, error)

EmailInvitationsByGroupIDCtx retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_group_index'.

func (EmailInvitationQ) EmailInvitationsByOrgID 

func (q EmailInvitationQ) EmailInvitationsByOrgID(orgID uuid.UUID, isForUpdate bool) ([]data.EmailInvitation, error)

EmailInvitationsByOrgID retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_organization_index'.

func (EmailInvitationQ) EmailInvitationsByOrgIDCtx 

func (q EmailInvitationQ) EmailInvitationsByOrgIDCtx(ctx context.Context, orgID uuid.UUID, isForUpdate bool) ([]data.EmailInvitation, error)

EmailInvitationsByOrgIDCtx retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_organization_index'.

func (EmailInvitationQ) EmailInvitationsByReqID 

func (q EmailInvitationQ) EmailInvitationsByReqID(reqID uuid.UUID, isForUpdate bool) ([]data.EmailInvitation, error)

EmailInvitationsByReqID retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_request_index'.

func (EmailInvitationQ) EmailInvitationsByReqIDCtx 

func (q EmailInvitationQ) EmailInvitationsByReqIDCtx(ctx context.Context, reqID uuid.UUID, isForUpdate bool) ([]data.EmailInvitation, error)

EmailInvitationsByReqIDCtx retrieves a row from 'public.email_invitations' as a EmailInvitation.

Generated from index 'email_invitations_request_index'.

func (EmailInvitationQ) Insert 

func (q EmailInvitationQ) Insert(ei *data.EmailInvitation) error

Insert insert a EmailInvitation to the database.

func (EmailInvitationQ) InsertCtx 

func (q EmailInvitationQ) InsertCtx(ctx context.Context, ei *data.EmailInvitation) error

InsertCtx inserts a EmailInvitation to the database.

func (EmailInvitationQ) Update 

func (q EmailInvitationQ) Update(ei *data.EmailInvitation) error

Update updates a EmailInvitation in the database.

func (EmailInvitationQ) UpdateCtx 

func (q EmailInvitationQ) UpdateCtx(ctx context.Context, ei *data.EmailInvitation) error

UpdateCtx updates a EmailInvitation in the database.

func (EmailInvitationQ) Upsert 

func (q EmailInvitationQ) Upsert(ei *data.EmailInvitation) error

Upsert performs an upsert for EmailInvitation.

func (EmailInvitationQ) UpsertCtx 

func (q EmailInvitationQ) UpsertCtx(ctx context.Context, ei *data.EmailInvitation) error

UpsertCtx performs an upsert for EmailInvitation.

type GorpMigrationQ 

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

GorpMigrationQ represents helper struct to access row of 'gorp_migrations'.

func (GorpMigrationQ) Delete 

func (q GorpMigrationQ) Delete(gm *data.GorpMigration) error

Delete deletes the GorpMigration from the database.

func (GorpMigrationQ) DeleteCtx 

func (q GorpMigrationQ) DeleteCtx(ctx context.Context, gm *data.GorpMigration) error

DeleteCtx deletes the GorpMigration from the database.

func (GorpMigrationQ) GorpMigrationByID 

func (q GorpMigrationQ) GorpMigrationByID(id string, isForUpdate bool) (*data.GorpMigration, error)

GorpMigrationByID retrieves a row from 'public.gorp_migrations' as a GorpMigration.

Generated from index 'gorp_migrations_pkey'.

func (GorpMigrationQ) GorpMigrationByIDCtx 

func (q GorpMigrationQ) GorpMigrationByIDCtx(ctx context.Context, id string, isForUpdate bool) (*data.GorpMigration, error)

GorpMigrationByIDCtx retrieves a row from 'public.gorp_migrations' as a GorpMigration.

Generated from index 'gorp_migrations_pkey'.

func (GorpMigrationQ) Insert 

func (q GorpMigrationQ) Insert(gm *data.GorpMigration) error

Insert insert a GorpMigration to the database.

func (GorpMigrationQ) InsertCtx 

func (q GorpMigrationQ) InsertCtx(ctx context.Context, gm *data.GorpMigration) error

InsertCtx inserts a GorpMigration to the database.

func (GorpMigrationQ) Update 

func (q GorpMigrationQ) Update(gm *data.GorpMigration) error

Update updates a GorpMigration in the database.

func (GorpMigrationQ) UpdateCtx 

func (q GorpMigrationQ) UpdateCtx(ctx context.Context, gm *data.GorpMigration) error

UpdateCtx updates a GorpMigration in the database.

func (GorpMigrationQ) Upsert 

func (q GorpMigrationQ) Upsert(gm *data.GorpMigration) error

Upsert performs an upsert for GorpMigration.

func (GorpMigrationQ) UpsertCtx 

func (q GorpMigrationQ) UpsertCtx(ctx context.Context, gm *data.GorpMigration) error

UpsertCtx performs an upsert for GorpMigration.

type GroupQ 

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

GroupQ represents helper struct to access row of 'groups'.

func (GroupQ) Delete 

func (q GroupQ) Delete(g *data.Group) error

Delete deletes the Group from the database.

func (GroupQ) DeleteCtx 

func (q GroupQ) DeleteCtx(ctx context.Context, g *data.Group) error

DeleteCtx deletes the Group from the database.

func (GroupQ) GroupByID 

func (q GroupQ) GroupByID(id uuid.UUID, isForUpdate bool) (*data.Group, error)

GroupByID retrieves a row from 'public.groups' as a Group.

Generated from index 'groups_pkey'.

func (GroupQ) GroupByIDCtx 

func (q GroupQ) GroupByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.Group, error)

GroupByIDCtx retrieves a row from 'public.groups' as a Group.

Generated from index 'groups_pkey'.

func (GroupQ) GroupsByOrgID 

func (q GroupQ) GroupsByOrgID(orgID uuid.UUID, isForUpdate bool) ([]data.Group, error)

GroupsByOrgID retrieves a row from 'public.groups' as a Group.

Generated from index 'groups_organization_index'.

func (GroupQ) GroupsByOrgIDCtx 

func (q GroupQ) GroupsByOrgIDCtx(ctx context.Context, orgID uuid.UUID, isForUpdate bool) ([]data.Group, error)

GroupsByOrgIDCtx retrieves a row from 'public.groups' as a Group.

Generated from index 'groups_organization_index'.

func (GroupQ) Insert 

func (q GroupQ) Insert(g *data.Group) error

Insert insert a Group to the database.

func (GroupQ) InsertCtx 

func (q GroupQ) InsertCtx(ctx context.Context, g *data.Group) error

InsertCtx inserts a Group to the database.

func (GroupQ) SelectCtx 

func (q GroupQ) SelectCtx(ctx context.Context, selector data.GroupsSelector) ([]data.Group, error)

func (GroupQ) Update 

func (q GroupQ) Update(g *data.Group) error

Update updates a Group in the database.

func (GroupQ) UpdateCtx 

func (q GroupQ) UpdateCtx(ctx context.Context, g *data.Group) error

UpdateCtx updates a Group in the database.

func (GroupQ) Upsert 

func (q GroupQ) Upsert(g *data.Group) error

Upsert performs an upsert for Group.

func (GroupQ) UpsertCtx 

func (q GroupQ) UpsertCtx(ctx context.Context, g *data.Group) error

UpsertCtx performs an upsert for Group.

type GroupUserQ 

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

GroupUserQ represents helper struct to access row of 'group_users'.

func (GroupUserQ) Delete 

func (q GroupUserQ) Delete(gu *data.GroupUser) error

Delete deletes the GroupUser from the database.

func (GroupUserQ) DeleteCtx 

func (q GroupUserQ) DeleteCtx(ctx context.Context, gu *data.GroupUser) error

DeleteCtx deletes the GroupUser from the database.

func (GroupUserQ) GroupUserByID 

func (q GroupUserQ) GroupUserByID(id uuid.UUID, isForUpdate bool) (*data.GroupUser, error)

GroupUserByID retrieves a row from 'public.group_users' as a GroupUser.

Generated from index 'group_users_pkey'.

func (GroupUserQ) GroupUserByIDCtx 

func (q GroupUserQ) GroupUserByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.GroupUser, error)

GroupUserByIDCtx retrieves a row from 'public.group_users' as a GroupUser.

Generated from index 'group_users_pkey'.

func (GroupUserQ) GroupUsersByGroupID 

func (q GroupUserQ) GroupUsersByGroupID(groupID uuid.UUID, isForUpdate bool) ([]data.GroupUser, error)

GroupUsersByGroupID retrieves a row from 'public.group_users' as a GroupUser.

Generated from index 'group_users_group_index'.

func (GroupUserQ) GroupUsersByGroupIDCtx 

func (q GroupUserQ) GroupUsersByGroupIDCtx(ctx context.Context, groupID uuid.UUID, isForUpdate bool) ([]data.GroupUser, error)

GroupUsersByGroupIDCtx retrieves a row from 'public.group_users' as a GroupUser.

Generated from index 'group_users_group_index'.

func (GroupUserQ) GroupUsersByUserID 

func (q GroupUserQ) GroupUsersByUserID(userID uuid.UUID, isForUpdate bool) ([]data.GroupUser, error)

GroupUsersByUserID retrieves a row from 'public.group_users' as a GroupUser.

Generated from index 'group_users_user_index'.

func (GroupUserQ) GroupUsersByUserIDCtx 

func (q GroupUserQ) GroupUsersByUserIDCtx(ctx context.Context, userID uuid.UUID, isForUpdate bool) ([]data.GroupUser, error)

GroupUsersByUserIDCtx retrieves a row from 'public.group_users' as a GroupUser.

Generated from index 'group_users_user_index'.

func (GroupUserQ) Insert 

func (q GroupUserQ) Insert(gu *data.GroupUser) error

Insert insert a GroupUser to the database.

func (GroupUserQ) InsertCtx 

func (q GroupUserQ) InsertCtx(ctx context.Context, gu *data.GroupUser) error

InsertCtx inserts a GroupUser to the database.

func (GroupUserQ) SelectCtx 

func (q GroupUserQ) SelectCtx(ctx context.Context, groupID uuid.UUID) ([]data.GroupUser, error)

func (GroupUserQ) Update 

func (q GroupUserQ) Update(gu *data.GroupUser) error

Update updates a GroupUser in the database.

func (GroupUserQ) UpdateCtx 

func (q GroupUserQ) UpdateCtx(ctx context.Context, gu *data.GroupUser) error

UpdateCtx updates a GroupUser in the database.

func (GroupUserQ) Upsert 

func (q GroupUserQ) Upsert(gu *data.GroupUser) error

Upsert performs an upsert for GroupUser.

func (GroupUserQ) UpsertCtx 

func (q GroupUserQ) UpsertCtx(ctx context.Context, gu *data.GroupUser) error

UpsertCtx performs an upsert for GroupUser.

type OrganizationQ 

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

OrganizationQ represents helper struct to access row of 'organizations'.

func (OrganizationQ) CountCtx added in v0.7.0 

func (q OrganizationQ) CountCtx(ctx context.Context, selector data.OrgsSelector) (uint64, error)

func (OrganizationQ) Delete 

func (q OrganizationQ) Delete(o *data.Organization) error

Delete deletes the Organization from the database.

func (OrganizationQ) DeleteCtx 

func (q OrganizationQ) DeleteCtx(ctx context.Context, o *data.Organization) error

DeleteCtx deletes the Organization from the database.

func (OrganizationQ) Insert 

func (q OrganizationQ) Insert(o *data.Organization) error

Insert insert a Organization to the database.

func (OrganizationQ) InsertCtx 

func (q OrganizationQ) InsertCtx(ctx context.Context, o *data.Organization) error

InsertCtx inserts a Organization to the database.

func (OrganizationQ) OrganizationByDid added in v0.6.0 

func (q OrganizationQ) OrganizationByDid(did sql.NullString, isForUpdate bool) (*data.Organization, error)

OrganizationByDid retrieves a row from 'public.organizations' as a Organization.

Generated from index 'organizations_did_key'.

func (OrganizationQ) OrganizationByDidCtx added in v0.6.0 

func (q OrganizationQ) OrganizationByDidCtx(ctx context.Context, did sql.NullString, isForUpdate bool) (*data.Organization, error)

OrganizationByDidCtx retrieves a row from 'public.organizations' as a Organization.

Generated from index 'organizations_did_key'.

func (OrganizationQ) OrganizationByID 

func (q OrganizationQ) OrganizationByID(id uuid.UUID, isForUpdate bool) (*data.Organization, error)

OrganizationByID retrieves a row from 'public.organizations' as a Organization.

Generated from index 'organizations_pkey'.

func (OrganizationQ) OrganizationByIDCtx 

func (q OrganizationQ) OrganizationByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.Organization, error)

OrganizationByIDCtx retrieves a row from 'public.organizations' as a Organization.

Generated from index 'organizations_pkey'.

func (OrganizationQ) OrganizationsByOwner 

func (q OrganizationQ) OrganizationsByOwner(owner uuid.UUID, isForUpdate bool) ([]data.Organization, error)

OrganizationsByOwner retrieves a row from 'public.organizations' as a Organization.

Generated from index 'organizations_owner_index'.

func (OrganizationQ) OrganizationsByOwnerCtx 

func (q OrganizationQ) OrganizationsByOwnerCtx(ctx context.Context, owner uuid.UUID, isForUpdate bool) ([]data.Organization, error)

OrganizationsByOwnerCtx retrieves a row from 'public.organizations' as a Organization.

Generated from index 'organizations_owner_index'.

func (OrganizationQ) SelectCtx 

func (q OrganizationQ) SelectCtx(ctx context.Context, selector data.OrgsSelector) ([]data.Organization, error)

func (OrganizationQ) Update 

func (q OrganizationQ) Update(o *data.Organization) error

Update updates a Organization in the database.

func (OrganizationQ) UpdateCtx 

func (q OrganizationQ) UpdateCtx(ctx context.Context, o *data.Organization) error

UpdateCtx updates a Organization in the database.

func (OrganizationQ) Upsert 

func (q OrganizationQ) Upsert(o *data.Organization) error

Upsert performs an upsert for Organization.

func (OrganizationQ) UpsertCtx 

func (q OrganizationQ) UpsertCtx(ctx context.Context, o *data.Organization) error

UpsertCtx performs an upsert for Organization.

type RequestQ 

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

RequestQ represents helper struct to access row of 'requests'.

func (RequestQ) Delete 

func (q RequestQ) Delete(r *data.Request) error

Delete deletes the Request from the database.

func (RequestQ) DeleteCtx 

func (q RequestQ) DeleteCtx(ctx context.Context, r *data.Request) error

DeleteCtx deletes the Request from the database.

func (RequestQ) Insert 

func (q RequestQ) Insert(r *data.Request) error

Insert insert a Request to the database.

func (RequestQ) InsertCtx 

func (q RequestQ) InsertCtx(ctx context.Context, r *data.Request) error

InsertCtx inserts a Request to the database.

func (RequestQ) RequestByID 

func (q RequestQ) RequestByID(id uuid.UUID, isForUpdate bool) (*data.Request, error)

RequestByID retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_pkey'.

func (RequestQ) RequestByIDCtx 

func (q RequestQ) RequestByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.Request, error)

RequestByIDCtx retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_pkey'.

func (RequestQ) RequestsByGroupID 

func (q RequestQ) RequestsByGroupID(groupID uuid.UUID, isForUpdate bool) ([]data.Request, error)

RequestsByGroupID retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_group_index'.

func (RequestQ) RequestsByGroupIDCtx 

func (q RequestQ) RequestsByGroupIDCtx(ctx context.Context, groupID uuid.UUID, isForUpdate bool) ([]data.Request, error)

RequestsByGroupIDCtx retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_group_index'.

func (RequestQ) RequestsByOrgID 

func (q RequestQ) RequestsByOrgID(orgID uuid.UUID, isForUpdate bool) ([]data.Request, error)

RequestsByOrgID retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_organization_index'.

func (RequestQ) RequestsByOrgIDCtx 

func (q RequestQ) RequestsByOrgIDCtx(ctx context.Context, orgID uuid.UUID, isForUpdate bool) ([]data.Request, error)

RequestsByOrgIDCtx retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_organization_index'.

func (RequestQ) RequestsByUserDid 

func (q RequestQ) RequestsByUserDid(userDid sql.NullString, isForUpdate bool) ([]data.Request, error)

RequestsByUserDid retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_user_index'.

func (RequestQ) RequestsByUserDidCtx 

func (q RequestQ) RequestsByUserDidCtx(ctx context.Context, userDid sql.NullString, isForUpdate bool) ([]data.Request, error)

RequestsByUserDidCtx retrieves a row from 'public.requests' as a Request.

Generated from index 'requests_user_index'.

func (RequestQ) SelectCtx 

func (q RequestQ) SelectCtx(ctx context.Context, selector data.RequestsSelector) ([]data.Request, error)

func (RequestQ) Update 

func (q RequestQ) Update(r *data.Request) error

Update updates a Request in the database.

func (RequestQ) UpdateCtx 

func (q RequestQ) UpdateCtx(ctx context.Context, r *data.Request) error

UpdateCtx updates a Request in the database.

func (RequestQ) Upsert 

func (q RequestQ) Upsert(r *data.Request) error

Upsert performs an upsert for Request.

func (RequestQ) UpsertCtx 

func (q RequestQ) UpsertCtx(ctx context.Context, r *data.Request) error

UpsertCtx performs an upsert for Request.

type Storage 

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

Storage is the helper struct for database operations

func New 

func New(db *pgdb.DB) *Storage

New - returns new instance of storage

func (Storage) ClaimQ added in v0.3.0 

func (s Storage) ClaimQ() data.ClaimQ

ClaimQ - creates new instance of ClaimQ

func (Storage) ClaimsSchemaQ added in v0.2.0 

func (s Storage) ClaimsSchemaQ() data.ClaimsSchemaQ

ClaimsSchemaQ - creates new instance of ClaimsSchemaQ

func (*Storage) Clone 

func (s *Storage) Clone() data.Storage

Clone - returns new storage with clone of db

func (*Storage) DB 

func (s *Storage) DB() *pgdb.DB

DB - returns db used by Storage

func (Storage) EmailInvitationQ 

func (s Storage) EmailInvitationQ() data.EmailInvitationQ

EmailInvitationQ - creates new instance of EmailInvitationQ

func (Storage) GorpMigrationQ 

func (s Storage) GorpMigrationQ() data.GorpMigrationQ

GorpMigrationQ - creates new instance of GorpMigrationQ

func (Storage) GroupQ 

func (s Storage) GroupQ() data.GroupQ

GroupQ - creates new instance of GroupQ

func (Storage) GroupUserQ 

func (s Storage) GroupUserQ() data.GroupUserQ

GroupUserQ - creates new instance of GroupUserQ

func (Storage) OrganizationQ 

func (s Storage) OrganizationQ() data.OrganizationQ

OrganizationQ - creates new instance of OrganizationQ

func (Storage) RequestQ 

func (s Storage) RequestQ() data.RequestQ

RequestQ - creates new instance of RequestQ

func (*Storage) Transaction 

func (s *Storage) Transaction(tx func() error) error

Transaction begins a transaction on repo.

func (Storage) UserQ 

func (s Storage) UserQ() data.UserQ

UserQ - creates new instance of UserQ

type UserQ 

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

UserQ represents helper struct to access row of 'users'.

func (UserQ) Delete 

func (q UserQ) Delete(u *data.User) error

Delete deletes the User from the database.

func (UserQ) DeleteCtx 

func (q UserQ) DeleteCtx(ctx context.Context, u *data.User) error

DeleteCtx deletes the User from the database.

func (UserQ) Insert 

func (q UserQ) Insert(u *data.User) error

Insert insert a User to the database.

func (UserQ) InsertCtx 

func (q UserQ) InsertCtx(ctx context.Context, u *data.User) error

InsertCtx inserts a User to the database.

func (UserQ) SelectCtx 

func (q UserQ) SelectCtx(ctx context.Context, selector data.UsersSelector) ([]data.User, error)

func (UserQ) Update 

func (q UserQ) Update(u *data.User) error

Update updates a User in the database.

func (UserQ) UpdateCtx 

func (q UserQ) UpdateCtx(ctx context.Context, u *data.User) error

UpdateCtx updates a User in the database.

func (UserQ) Upsert 

func (q UserQ) Upsert(u *data.User) error

Upsert performs an upsert for User.

func (UserQ) UpsertCtx 

func (q UserQ) UpsertCtx(ctx context.Context, u *data.User) error

UpsertCtx performs an upsert for User.

func (UserQ) UserByDidOrgID added in v0.6.0 

func (q UserQ) UserByDidOrgID(did string, orgID uuid.UUID, isForUpdate bool) (*data.User, error)

UserByDidOrgID retrieves a row from 'public.users' as a User.

Generated from index 'users_did_org_id_key'.

func (UserQ) UserByDidOrgIDCtx added in v0.6.0 

func (q UserQ) UserByDidOrgIDCtx(ctx context.Context, did string, orgID uuid.UUID, isForUpdate bool) (*data.User, error)

UserByDidOrgIDCtx retrieves a row from 'public.users' as a User.

Generated from index 'users_did_org_id_key'.

func (UserQ) UserByID 

func (q UserQ) UserByID(id uuid.UUID, isForUpdate bool) (*data.User, error)

UserByID retrieves a row from 'public.users' as a User.

Generated from index 'users_pkey'.

func (UserQ) UserByIDCtx 

func (q UserQ) UserByIDCtx(ctx context.Context, id uuid.UUID, isForUpdate bool) (*data.User, error)

UserByIDCtx retrieves a row from 'public.users' as a User.

Generated from index 'users_pkey'.

func (UserQ) UsersByDid 

func (q UserQ) UsersByDid(did string, isForUpdate bool) ([]data.User, error)

UsersByDid retrieves a row from 'public.users' as a User.

Generated from index 'users_did_index'.

func (UserQ) UsersByDidCtx 

func (q UserQ) UsersByDidCtx(ctx context.Context, did string, isForUpdate bool) ([]data.User, error)

UsersByDidCtx retrieves a row from 'public.users' as a User.

Generated from index 'users_did_index'.

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.