database

package
v0.0.0-...-e4e1157 Latest Latest
Warning

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

Go to latest
Published: May 22, 2025 License: Apache-2.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 APIKeyByEnvironmentIDQuery

type APIKeyByEnvironmentIDQuery struct{ EnvironmentID uuid.UUID }

type APIKeyByEnvironmentIDsQuery

type APIKeyByEnvironmentIDsQuery struct{ EnvironmentIDs []uuid.UUID }

type APIKeyByIDQuery

type APIKeyByIDQuery struct{ ID uuid.UUID }

type APIKeyByKeyHashQuery

type APIKeyByKeyHashQuery struct{ KeyHash string }

type APIKeyByOrganizationIDQuery

type APIKeyByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type APIKeyByUserIDQuery

type APIKeyByUserIDQuery struct{ UserID uuid.UUID }

type APIKeyQuery

type APIKeyQuery interface {
	// contains filtered or unexported methods
}

func APIKeyByEnvironmentID

func APIKeyByEnvironmentID(environmentID uuid.UUID) APIKeyQuery

func APIKeyByEnvironmentIDs

func APIKeyByEnvironmentIDs(environmentIDs []uuid.UUID) APIKeyQuery

func APIKeyByID

func APIKeyByID(id uuid.UUID) APIKeyQuery

func APIKeyByKeyHash

func APIKeyByKeyHash(keyHash string) APIKeyQuery

func APIKeyByOrganizationID

func APIKeyByOrganizationID(organizationID uuid.UUID) APIKeyQuery

func APIKeyByUserID

func APIKeyByUserID(userID uuid.UUID) APIKeyQuery

type APIKeyStore

type APIKeyStore interface {
	Get(ctx context.Context, queries ...APIKeyQuery) (*core.APIKey, error)
	List(ctx context.Context, queries ...APIKeyQuery) ([]*core.APIKey, error)
	Create(ctx context.Context, m *core.APIKey) error
	Update(ctx context.Context, m *core.APIKey) error
	Delete(ctx context.Context, m *core.APIKey) error
}

type DB

type DB interface {
	Stores
	WithTx(ctx context.Context, fn func(tx Tx) error) error
	WithTxOptions(ctx context.Context, opts *sql.TxOptions, fn func(tx Tx) error) error
}

type EnvironmentByAPIKeyIDsQuery

type EnvironmentByAPIKeyIDsQuery struct{ APIKeyIDs []uuid.UUID }

type EnvironmentByIDQuery

type EnvironmentByIDQuery struct{ ID uuid.UUID }

type EnvironmentByOrganizationIDQuery

type EnvironmentByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type EnvironmentBySlugQuery

type EnvironmentBySlugQuery struct{ Slug string }

type EnvironmentQuery

type EnvironmentQuery interface {
	// contains filtered or unexported methods
}

func EnvironmentByAPIKeyIDs

func EnvironmentByAPIKeyIDs(ids []uuid.UUID) EnvironmentQuery

func EnvironmentByID

func EnvironmentByID(id uuid.UUID) EnvironmentQuery

func EnvironmentByOrganizationID

func EnvironmentByOrganizationID(organizationID uuid.UUID) EnvironmentQuery

func EnvironmentBySlug

func EnvironmentBySlug(slug string) EnvironmentQuery

type EnvironmentStore

type EnvironmentStore interface {
	Get(ctx context.Context, queries ...EnvironmentQuery) (*core.Environment, error)
	List(ctx context.Context, queries ...EnvironmentQuery) ([]*core.Environment, error)
	Create(ctx context.Context, m *core.Environment) error
	Update(ctx context.Context, m *core.Environment) error
	Delete(ctx context.Context, m *core.Environment) error
	BulkInsert(ctx context.Context, m []*core.Environment) error
	MapByAPIKeyIDs(ctx context.Context, ids []uuid.UUID) (map[uuid.UUID]*core.Environment, error)
	IsSlugExistsInOrganization(ctx context.Context, orgID uuid.UUID, slug string) (bool, error)
}

type GroupByIDQuery

type GroupByIDQuery struct{ ID uuid.UUID }

type GroupByOrganizationIDQuery

type GroupByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type GroupBySlugQuery

type GroupBySlugQuery struct{ Slug string }

type GroupBySlugsQuery

type GroupBySlugsQuery struct{ Slugs []string }

type GroupPageByEnvironmentIDQuery

type GroupPageByEnvironmentIDQuery struct{ EnvironmentID uuid.UUID }

type GroupPageByOrganizationIDQuery

type GroupPageByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type GroupPageByPageIDsQuery

type GroupPageByPageIDsQuery struct{ PageIDs []uuid.UUID }

type GroupPageQuery

type GroupPageQuery interface {
	// contains filtered or unexported methods
}

func GroupPageByEnvironmentID

func GroupPageByEnvironmentID(environmentID uuid.UUID) GroupPageQuery

func GroupPageByOrganizationID

func GroupPageByOrganizationID(organizationID uuid.UUID) GroupPageQuery

func GroupPageByPageIDs

func GroupPageByPageIDs(pageIDs []uuid.UUID) GroupPageQuery

type GroupQuery

type GroupQuery interface {
	// contains filtered or unexported methods
}

func GroupByID

func GroupByID(id uuid.UUID) GroupQuery

func GroupByOrganizationID

func GroupByOrganizationID(organizationID uuid.UUID) GroupQuery

func GroupBySlug

func GroupBySlug(slug string) GroupQuery

func GroupBySlugs

func GroupBySlugs(slugs []string) GroupQuery

type GroupStore

type GroupStore interface {
	Get(ctx context.Context, queries ...GroupQuery) (*core.Group, error)
	List(ctx context.Context, queries ...GroupQuery) ([]*core.Group, error)
	Create(ctx context.Context, m *core.Group) error
	Update(ctx context.Context, m *core.Group) error
	Delete(ctx context.Context, m *core.Group) error
	IsSlugExistsInOrganization(ctx context.Context, orgID uuid.UUID, slug string) (bool, error)

	ListPages(ctx context.Context, queries ...GroupPageQuery) ([]*core.GroupPage, error)
	BulkInsertPages(ctx context.Context, pages []*core.GroupPage) error
	BulkUpdatePages(ctx context.Context, pages []*core.GroupPage) error
	BulkDeletePages(ctx context.Context, pages []*core.GroupPage) error
}

type HostInstanceByAPIKeyIDQuery

type HostInstanceByAPIKeyIDQuery struct{ APIKeyID uuid.UUID }

type HostInstanceByAPIKeyQuery

type HostInstanceByAPIKeyQuery struct{ APIKey string }

type HostInstanceByIDQuery

type HostInstanceByIDQuery struct{ ID uuid.UUID }

type HostInstanceByOrganizationIDQuery

type HostInstanceByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type HostInstanceBySessionIDQuery

type HostInstanceBySessionIDQuery struct{ SessionID uuid.UUID }

type HostInstanceByStatusQuery

type HostInstanceByStatusQuery struct{ Status core.HostInstanceStatus }

type HostInstanceQuery

type HostInstanceQuery interface {
	// contains filtered or unexported methods
}

func HostInstanceByAPIKey

func HostInstanceByAPIKey(apiKey string) HostInstanceQuery

func HostInstanceByAPIKeyID

func HostInstanceByAPIKeyID(apiKeyID uuid.UUID) HostInstanceQuery

func HostInstanceByID

func HostInstanceByID(id uuid.UUID) HostInstanceQuery

func HostInstanceByOrganizationID

func HostInstanceByOrganizationID(organizationID uuid.UUID) HostInstanceQuery

func HostInstanceBySessionID

func HostInstanceBySessionID(sessionID uuid.UUID) HostInstanceQuery

func HostInstanceByStatus

func HostInstanceByStatus(status core.HostInstanceStatus) HostInstanceQuery

type HostInstanceStore

type HostInstanceStore interface {
	Get(ctx context.Context, queries ...HostInstanceQuery) (*core.HostInstance, error)
	List(ctx context.Context, queries ...HostInstanceQuery) ([]*core.HostInstance, error)
	Create(ctx context.Context, m *core.HostInstance) error
	Update(ctx context.Context, m *core.HostInstance) error
	Delete(ctx context.Context, m *core.HostInstance) error
}

type OrganizationByIDQuery

type OrganizationByIDQuery struct{ ID uuid.UUID }

type OrganizationBySubdomainQuery

type OrganizationBySubdomainQuery struct{ Subdomain string }

type OrganizationByUserIDQuery

type OrganizationByUserIDQuery struct{ ID uuid.UUID }

type OrganizationQuery

type OrganizationQuery interface {
	// contains filtered or unexported methods
}

func OrganizationByID

func OrganizationByID(id uuid.UUID) OrganizationQuery

func OrganizationBySubdomain

func OrganizationBySubdomain(subdomain string) OrganizationQuery

func OrganizationByUserID

func OrganizationByUserID(id uuid.UUID) OrganizationQuery

type OrganizationStore

type OrganizationStore interface {
	Get(ctx context.Context, queries ...OrganizationQuery) (*core.Organization, error)
	List(ctx context.Context, queries ...OrganizationQuery) ([]*core.Organization, error)
	Create(ctx context.Context, m *core.Organization) error
	IsSubdomainExists(ctx context.Context, subdomain string) (bool, error)
}

type PageByAPIKeyIDQuery

type PageByAPIKeyIDQuery struct{ APIKeyID uuid.UUID }

type PageByEnvironmentIDQuery

type PageByEnvironmentIDQuery struct{ EnvironmentID uuid.UUID }

type PageByIDQuery

type PageByIDQuery struct{ ID uuid.UUID }

type PageByOrganizationIDQuery

type PageByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type PageBySessionIDQuery

type PageBySessionIDQuery struct{ SessionID uuid.UUID }

type PageLimitQuery

type PageLimitQuery struct{ Limit uint64 }

type PageOffsetQuery

type PageOffsetQuery struct{ Offset uint64 }

type PageOrderByQuery

type PageOrderByQuery struct{ OrderBy string }

type PageQuery

type PageQuery interface {
	// contains filtered or unexported methods
}

func PageByAPIKeyID

func PageByAPIKeyID(id uuid.UUID) PageQuery

func PageByEnvironmentID

func PageByEnvironmentID(id uuid.UUID) PageQuery

func PageByID

func PageByID(id uuid.UUID) PageQuery

func PageByOrganizationID

func PageByOrganizationID(id uuid.UUID) PageQuery

func PageBySessionID

func PageBySessionID(id uuid.UUID) PageQuery

func PageLimit

func PageLimit(limit uint64) PageQuery

func PageOffset

func PageOffset(offset uint64) PageQuery

func PageOrderBy

func PageOrderBy(orderBy string) PageQuery

type PageStore

type PageStore interface {
	Get(ctx context.Context, queries ...PageQuery) (*core.Page, error)
	List(ctx context.Context, queries ...PageQuery) ([]*core.Page, error)
	BulkInsert(ctx context.Context, m []*core.Page) error
	BulkUpdate(ctx context.Context, m []*core.Page) error
	BulkDelete(ctx context.Context, m []*core.Page) error
}

type SessionByIDQuery

type SessionByIDQuery struct{ ID uuid.UUID }

type SessionQuery

type SessionQuery interface {
	// contains filtered or unexported methods
}

func SessionByID

func SessionByID(id uuid.UUID) SessionQuery

type SessionStore

type SessionStore interface {
	Get(ctx context.Context, queries ...SessionQuery) (*core.Session, error)
	Create(ctx context.Context, m *core.Session) error
	Delete(ctx context.Context, m *core.Session) error

	CreateHostInstance(ctx context.Context, m *core.SessionHostInstance) error
}

type Stores

type Stores interface {
	APIKey() APIKeyStore
	Environment() EnvironmentStore
	Group() GroupStore
	HostInstance() HostInstanceStore
	Organization() OrganizationStore
	Page() PageStore
	Session() SessionStore
	User() UserStore
}

type Tx

type Tx interface {
	Stores
}

type UserByEmailQuery

type UserByEmailQuery struct{ Email string }

type UserByIDQuery

type UserByIDQuery struct{ ID uuid.UUID }

type UserByOrganizationIDQuery

type UserByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type UserByRefreshTokenHashQuery

type UserByRefreshTokenHashQuery struct{ RefreshTokenHash string }

type UserGroupByGroupIDQuery

type UserGroupByGroupIDQuery struct{ GroupID uuid.UUID }

type UserGroupByOrganizationIDQuery

type UserGroupByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type UserGroupByUserIDQuery

type UserGroupByUserIDQuery struct{ UserID uuid.UUID }

type UserGroupQuery

type UserGroupQuery interface {
	// contains filtered or unexported methods
}

func UserGroupByGroupID

func UserGroupByGroupID(groupID uuid.UUID) UserGroupQuery

func UserGroupByOrganizationID

func UserGroupByOrganizationID(organizationID uuid.UUID) UserGroupQuery

func UserGroupByUserID

func UserGroupByUserID(userID uuid.UUID) UserGroupQuery

type UserInvitationByEmailQuery

type UserInvitationByEmailQuery struct{ Email string }

type UserInvitationByIDQuery

type UserInvitationByIDQuery struct{ ID uuid.UUID }

type UserInvitationByOrganizationIDQuery

type UserInvitationByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type UserInvitationQuery

type UserInvitationQuery interface {
	// contains filtered or unexported methods
}

func UserInvitationByEmail

func UserInvitationByEmail(email string) UserInvitationQuery

func UserInvitationByID

func UserInvitationByID(id uuid.UUID) UserInvitationQuery

func UserInvitationByOrganizationID

func UserInvitationByOrganizationID(organizationID uuid.UUID) UserInvitationQuery

type UserLimitQuery

type UserLimitQuery struct{ Limit uint64 }

type UserOffsetQuery

type UserOffsetQuery struct{ Offset uint64 }

type UserOrderByQuery

type UserOrderByQuery struct{ OrderBy string }

type UserOrganizationAccessByOrganizationIDQuery

type UserOrganizationAccessByOrganizationIDQuery struct{ OrganizationID uuid.UUID }

type UserOrganizationAccessByOrganizationSubdomainQuery

type UserOrganizationAccessByOrganizationSubdomainQuery struct{ OrganizationSubdomain string }

type UserOrganizationAccessByRoleQuery

type UserOrganizationAccessByRoleQuery struct{ Role core.UserOrganizationRole }

type UserOrganizationAccessByUserIDQuery

type UserOrganizationAccessByUserIDQuery struct{ UserID uuid.UUID }

type UserOrganizationAccessByUserIDsQuery

type UserOrganizationAccessByUserIDsQuery struct{ UserIDs []uuid.UUID }

type UserOrganizationAccessOrderByQuery

type UserOrganizationAccessOrderByQuery struct{ OrderBy string }

type UserOrganizationAccessQuery

type UserOrganizationAccessQuery interface {
	// contains filtered or unexported methods
}

func UserOrganizationAccessByOrganizationID

func UserOrganizationAccessByOrganizationID(organizationID uuid.UUID) UserOrganizationAccessQuery

func UserOrganizationAccessByOrganizationSubdomain

func UserOrganizationAccessByOrganizationSubdomain(subdomain string) UserOrganizationAccessQuery

func UserOrganizationAccessByUserID

func UserOrganizationAccessByUserID(userID uuid.UUID) UserOrganizationAccessQuery

func UserOrganizationAccessByUserIDs

func UserOrganizationAccessByUserIDs(userIDs []uuid.UUID) UserOrganizationAccessQuery

func UserOrganizationAccessOrderBy

func UserOrganizationAccessOrderBy(orderBy string) UserOrganizationAccessQuery

type UserQuery

type UserQuery interface {
	// contains filtered or unexported methods
}

func UserByEmail

func UserByEmail(email string) UserQuery

func UserByID

func UserByID(id uuid.UUID) UserQuery

func UserByOrganizationID

func UserByOrganizationID(organizationID uuid.UUID) UserQuery

func UserByRefreshTokenHash

func UserByRefreshTokenHash(refreshTokenHash string) UserQuery

func UserLimit

func UserLimit(limit uint64) UserQuery

func UserOffset

func UserOffset(offset uint64) UserQuery

func UserOrderBy

func UserOrderBy(orderBy string) UserQuery

type UserStore

type UserStore interface {
	Get(ctx context.Context, queries ...UserQuery) (*core.User, error)
	List(ctx context.Context, queries ...UserQuery) ([]*core.User, error)
	Create(ctx context.Context, m *core.User) error
	Update(ctx context.Context, m *core.User) error
	IsEmailExists(ctx context.Context, email string) (bool, error)

	GetOrganizationAccess(ctx context.Context, queries ...UserOrganizationAccessQuery) (*core.UserOrganizationAccess, error)
	ListOrganizationAccesses(ctx context.Context, queries ...UserOrganizationAccessQuery) ([]*core.UserOrganizationAccess, error)
	CreateOrganizationAccess(ctx context.Context, m *core.UserOrganizationAccess) error
	UpdateOrganizationAccess(ctx context.Context, m *core.UserOrganizationAccess) error
	DeleteOrganizationAccess(ctx context.Context, m *core.UserOrganizationAccess) error

	GetGroup(ctx context.Context, queries ...UserGroupQuery) (*core.UserGroup, error)
	ListGroups(ctx context.Context, queries ...UserGroupQuery) ([]*core.UserGroup, error)
	BulkInsertGroups(ctx context.Context, m []*core.UserGroup) error
	BulkDeleteGroups(ctx context.Context, m []*core.UserGroup) error

	GetInvitation(ctx context.Context, queries ...UserInvitationQuery) (*core.UserInvitation, error)
	ListInvitations(ctx context.Context, queries ...UserInvitationQuery) ([]*core.UserInvitation, error)
	DeleteInvitation(ctx context.Context, m *core.UserInvitation) error
	BulkInsertInvitations(ctx context.Context, m []*core.UserInvitation) error
	IsInvitationEmailExists(ctx context.Context, orgID uuid.UUID, email string) (bool, error)
}

Jump to

Keyboard shortcuts

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